org.apache.flink.runtime.profiling.impl

Class InstanceProfiler

java.lang.Object

org.apache.flink.runtime.profiling.impl.InstanceProfiler

public class InstanceProfiler
extends Object

Constructor Summary

Constructors

Constructor and Description
InstanceProfiler(String instancePath)

Method Summary

Modifier and Type	Method and Description
InternalInstanceProfilingData	generateCheckpointProfilingData()
InternalInstanceProfilingData	generateProfilingData(long timestamp)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InstanceProfiler

public InstanceProfiler(String instancePath)
                 throws ProfilingException

Throws:

ProfilingException

Method Detail

generateProfilingData

public InternalInstanceProfilingData generateProfilingData(long timestamp)
                                                    throws ProfilingException

Throws:

ProfilingException

generateCheckpointProfilingData

public InternalInstanceProfilingData generateCheckpointProfilingData()
                                                              throws ProfilingException

Returns:

InternalInstanceProfilingData ProfilingData for the instance from execution-start to currentTime

Throws:

ProfilingException