Serialized Form (flink-runtime 0.9.0-milestone-1 API)

Package org.apache.flink.runtime
- Class org.apache.flink.runtime.JobException extends Exception implements Serializable
  
  serialVersionUID:
  
  1275864691743020176L
Package org.apache.flink.runtime.accumulators
- Class org.apache.flink.runtime.accumulators.AccumulatorEvent extends Object implements Serializable
  
  serialVersionUID:
  
  8965894516006882735L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - jobID
```
JobID jobID
```
    - accumulators
```
Map<K,V> accumulators
```
    - serializedData
```
byte[] serializedData
```
Package org.apache.flink.runtime.blob
- Class org.apache.flink.runtime.blob.BlobKey extends Object implements Serializable
  
  serialVersionUID:
  
  3847117712521785209L
  - Serialized Fields
    - key
```
byte[] key
```
      The byte buffer storing the actual key data.
Package org.apache.flink.runtime.broadcast
- Class org.apache.flink.runtime.broadcast.InitializationTypeConflictException extends Exception implements Serializable
  
  serialVersionUID:
  
  -3930913982433642882L
  - Serialized Fields
    - type
```
Class<T> type
```
- Class org.apache.flink.runtime.broadcast.MaterializationExpiredException extends Exception implements Serializable
  
  serialVersionUID:
  
  7476456353634121934L
Package org.apache.flink.runtime.client
- Class org.apache.flink.runtime.client.JobCancellationException extends JobExecutionException implements Serializable
  
  serialVersionUID:
  
  2818087325120827526L
- Class org.apache.flink.runtime.client.JobExecutionException extends Exception implements Serializable
  
  serialVersionUID:
  
  2818087325120827525L
  - Serialized Fields
    - jobID
```
JobID jobID
```
- Class org.apache.flink.runtime.client.JobStatusMessage extends Object implements Serializable
  - Serialized Fields
    - jobId
```
JobID jobId
```
    - jobName
```
String jobName
```
    - jobState
```
JobStatus jobState
```
    - startTime
```
long startTime
```
- Class org.apache.flink.runtime.client.JobSubmissionException extends JobExecutionException implements Serializable
  
  serialVersionUID:
  
  2818087325120827526L
- Class org.apache.flink.runtime.client.JobTimeoutException extends JobExecutionException implements Serializable
  
  serialVersionUID:
  
  2818087325120827529L
Package org.apache.flink.runtime.deployment
- Class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptor extends Object implements Serializable
  - Serialized Fields
    - consumedPartitionId
```
ResultPartitionID consumedPartitionId
```
      The ID of the partition the input channel is going to consume.
    - consumedPartitionLocation
```
ResultPartitionLocation consumedPartitionLocation
```
      The location of the partition the input channel is going to consume.
- Class org.apache.flink.runtime.deployment.InputGateDeploymentDescriptor extends Object implements Serializable
  - Serialized Fields
    - consumedResultId
```
IntermediateDataSetID consumedResultId
```
      The ID of the consumed intermediate result. Each input gate consumes partitions of the intermediate result specified by this ID. This ID also identifies the input gate at the consuming task.
    - consumedSubpartitionIndex
```
int consumedSubpartitionIndex
```
      The index of the consumed subpartition of each consumed partition. This index depends on the DistributionPattern and the subtask indices of the producing and consuming task.
    - inputChannels
```
InputChannelDeploymentDescriptor[] inputChannels
```
      An input channel for each consumed subpartition.
- Class org.apache.flink.runtime.deployment.ResultPartitionDeploymentDescriptor extends Object implements Serializable
  - Serialized Fields
    - resultId
```
IntermediateDataSetID resultId
```
      The ID of the result this partition belongs to.
    - partitionId
```
IntermediateResultPartitionID partitionId
```
      The ID of the partition.
    - partitionType
```
ResultPartitionType partitionType
```
      The type of the partition.
    - numberOfSubpartitions
```
int numberOfSubpartitions
```
      The number of subpartitions.
- Class org.apache.flink.runtime.deployment.ResultPartitionLocation extends Object implements Serializable
  - Serialized Fields
    - locationType
```
org.apache.flink.runtime.deployment.ResultPartitionLocation.LocationType locationType
```
      The type of location for the result partition.
    - connectionId
```
ConnectionID connectionId
```
      The connection ID of a remote result partition.
- Class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor extends Object implements Serializable
  
  serialVersionUID:
  
  -3233562176034358530L
  - Serialized Fields
    - jobID
```
JobID jobID
```
      The ID of the job the tasks belongs to.
    - vertexID
```
JobVertexID vertexID
```
      The task's job vertex ID.
    - executionId
```
ExecutionAttemptID executionId
```
      The ID referencing the attempt to execute the task.
    - taskName
```
String taskName
```
      The task's name.
    - indexInSubtaskGroup
```
int indexInSubtaskGroup
```
      The task's index in the subtask group.
    - numberOfSubtasks
```
int numberOfSubtasks
```
      The number of sub tasks.
    - jobConfiguration
```
Configuration jobConfiguration
```
      The configuration of the job the task belongs to.
    - taskConfiguration
```
Configuration taskConfiguration
```
      The task's configuration object.
    - invokableClassName
```
String invokableClassName
```
      The name of the class containing the task code to be executed.
    - producedPartitions
```
List<E> producedPartitions
```
      The list of produced intermediate result partition deployment descriptors.
    - inputGates
```
List<E> inputGates
```
      The list of consumed intermediate result partitions.
    - targetSlotNumber
```
int targetSlotNumber
```
    - requiredJarFiles
```
List<E> requiredJarFiles
```
      The list of JAR files required to run this task.
    - operatorStates
```
StateHandle operatorStates
```
Package org.apache.flink.runtime.event.job
- Class org.apache.flink.runtime.event.job.AbstractEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - timestamp
```
long timestamp
```
      The timestamp of the event.
    - sequenceNumber
```
long sequenceNumber
```
      The sequence number of the event.
Package org.apache.flink.runtime.event.task
- Class org.apache.flink.runtime.event.task.EventList extends SerializableArrayList<AbstractEvent> implements Serializable
  
  serialVersionUID:
  
  4788250278393432776L
Package org.apache.flink.runtime.execution
- Class org.apache.flink.runtime.execution.CancelTaskException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.runtime.executiongraph
- Class org.apache.flink.runtime.executiongraph.Execution extends Object implements Serializable
  
  serialVersionUID:
  
  42L
  - Serialized Fields
    - vertex
```
ExecutionVertex vertex
```
    - attemptId
```
ExecutionAttemptID attemptId
```
    - stateTimestamps
```
long[] stateTimestamps
```
    - attemptNumber
```
int attemptNumber
```
    - timeout
```
scala.concurrent.duration.FiniteDuration timeout
```
    - partialInputChannelDeploymentDescriptors
```
ConcurrentLinkedQueue<E> partialInputChannelDeploymentDescriptors
```
    - state
```
ExecutionState state
```
    - assignedResource
```
SimpleSlot assignedResource
```
    - failureCause
```
Throwable failureCause
```
    - assignedResourceLocation
```
InstanceConnectionInfo assignedResourceLocation
```
    - operatorState
```
StateHandle operatorState
```
- Class org.apache.flink.runtime.executiongraph.ExecutionAttemptID extends AbstractID implements Serializable
  
  serialVersionUID:
  
  -1169683445778281344L
- Class org.apache.flink.runtime.executiongraph.ExecutionGraph extends Object implements Serializable
  
  serialVersionUID:
  
  42L
  - Serialized Fields
    - jobID
```
JobID jobID
```
      The ID of the job this graph has been built for.
    - jobName
```
String jobName
```
      The name of the original job graph.
    - jobConfiguration
```
Configuration jobConfiguration
```
      The job configuration that was originally attached to the JobGraph.
    - userClassLoader
```
ClassLoader userClassLoader
```
      The classloader for the user code. Needed for calls into user code classes
    - tasks
```
ConcurrentHashMap<K,V> tasks
```
      All job vertices that are part of this graph
    - verticesInCreationOrder
```
List<E> verticesInCreationOrder
```
      All vertices, in the order in which they were created
    - intermediateResults
```
ConcurrentHashMap<K,V> intermediateResults
```
      All intermediate results that are part of this graph
    - currentExecutions
```
ConcurrentHashMap<K,V> currentExecutions
```
      The currently executed tasks, for callbacks
    - requiredJarFiles
```
List<E> requiredJarFiles
```
      A list of all libraries required during the job execution. Libraries have to be stored inside the BlobService and are referenced via the BLOB keys.
    - jobStatusListenerActors
```
List<E> jobStatusListenerActors
```
    - executionListenerActors
```
List<E> executionListenerActors
```
    - stateTimestamps
```
long[] stateTimestamps
```
      Timestamps (in milliseconds as returned by System.currentTimeMillis() when the execution graph transitioned into a certain state. The index into this array is the ordinal of the enum value, i.e. the timestamp when the graph went into state "RUNNING" is at stateTimestamps[RUNNING.ordinal()].
    - progressLock
```
Object progressLock
```
      The lock used to secure all access to mutable fields, especially the tracking of progress within the job.
    - timeout
```
scala.concurrent.duration.FiniteDuration timeout
```
      The timeout for all messages that require a response/acknowledgement
    - numberOfRetriesLeft
```
int numberOfRetriesLeft
```
      The number of times failed executions should be retried.
    - delayBeforeRetrying
```
long delayBeforeRetrying
```
      The delay that the system should wait before restarting failed executions.
    - allowQueuedScheduling
```
boolean allowQueuedScheduling
```
      Flag to indicate whether the scheduler may queue tasks for execution, or needs to be able to deploy them immediately.
    - scheduleMode
```
ScheduleMode scheduleMode
```
      The mode of scheduling. Decides how to select the initial set of tasks to be deployed. May indicate to deploy all sources, or to deploy everything, or to deploy via backtracking from results than need to be materialized.
    - state
```
JobStatus state
```
      Current status of the job execution
    - failureCause
```
Throwable failureCause
```
      The exception that caused the job to fail. This is set to the first root exception that was not recoverable and triggered job failure
    - scheduler
```
Scheduler scheduler
```
      The scheduler to use for scheduling new tasks as they are needed
    - nextVertexToFinish
```
int nextVertexToFinish
```
      The position of the vertex that is next expected to finish. This is an index into the "verticesInCreationOrder" collection. Once this value has reached the number of vertices, the job is done.
    - parentContext
```
akka.actor.ActorContext parentContext
```
    - stateCheckpointerActor
```
akka.actor.ActorRef stateCheckpointerActor
```
    - checkpointingEnabled
```
boolean checkpointingEnabled
```
    - checkpointingInterval
```
long checkpointingInterval
```
- Class org.apache.flink.runtime.executiongraph.ExecutionJobVertex extends Object implements Serializable
  
  serialVersionUID:
  
  42L
  - Serialized Fields
    - stateMonitor
```
Object stateMonitor
```
    - graph
```
ExecutionGraph graph
```
    - jobVertex
```
AbstractJobVertex jobVertex
```
    - taskVertices
```
ExecutionVertex[] taskVertices
```
    - producedDataSets
```
IntermediateResult[] producedDataSets
```
    - inputs
```
List<E> inputs
```
    - parallelism
```
int parallelism
```
    - finishedSubtasks
```
boolean[] finishedSubtasks
```
    - numSubtasksInFinalState
```
int numSubtasksInFinalState
```
    - slotSharingGroup
```
SlotSharingGroup slotSharingGroup
```
    - coLocationGroup
```
CoLocationGroup coLocationGroup
```
    - inputSplits
```
InputSplit[] inputSplits
```
    - inputSplitsPerSubtask
```
List<E>[] inputSplitsPerSubtask
```
    - splitAssigner
```
InputSplitAssigner splitAssigner
```
- Class org.apache.flink.runtime.executiongraph.ExecutionVertex extends Object implements Serializable
  
  serialVersionUID:
  
  42L
  - Serialized Fields
    - jobVertex
```
ExecutionJobVertex jobVertex
```
    - resultPartitions
```
Map<K,V> resultPartitions
```
    - inputEdges
```
ExecutionEdge[][] inputEdges
```
    - subTaskIndex
```
int subTaskIndex
```
    - priorExecutions
```
List<E> priorExecutions
```
    - timeout
```
scala.concurrent.duration.FiniteDuration timeout
```
    - locationConstraint
```
CoLocationConstraint locationConstraint
```
    - currentExecution
```
Execution currentExecution
```
    - locationConstraintInstances
```
List<E> locationConstraintInstances
```
    - scheduleLocalOnly
```
boolean scheduleLocalOnly
```
    - operatorState
```
StateHandle operatorState
```
Package org.apache.flink.runtime.instance
- Class org.apache.flink.runtime.instance.HardwareDescription extends Object implements Serializable
  
  serialVersionUID:
  
  3380016608300325361L
  - Serialized Fields
    - numberOfCPUCores
```
int numberOfCPUCores
```
      The number of CPU cores available to the JVM on the compute node.
    - sizeOfPhysicalMemory
```
long sizeOfPhysicalMemory
```
      The size of physical memory in bytes available on the compute node.
    - sizeOfJvmHeap
```
long sizeOfJvmHeap
```
      The size of the JVM heap memory
    - sizeOfManagedMemory
```
long sizeOfManagedMemory
```
      The size of the memory managed by the system for caching, hashing, sorting, ...
- Class org.apache.flink.runtime.instance.InstanceConnectionInfo extends Object implements Serializable
  
  serialVersionUID:
  
  -8254407801276350716L
  - Serialized Fields
    - inetAddress
```
InetAddress inetAddress
```
      The network address the instance's task manager binds its sockets to.
    - dataPort
```
int dataPort
```
      The port the instance's task manager expects to receive transfer envelopes on.
    - fqdnHostName
```
String fqdnHostName
```
      The fully qualified host name of the instance.
    - hostName
```
String hostName
```
      The hostname, derived from the fully qualified host name.
- Class org.apache.flink.runtime.instance.InstanceDiedException extends Exception implements Serializable
  
  serialVersionUID:
  
  -4917918318403135745L
  - Serialized Fields
    - instance
```
Instance instance
```
- Class org.apache.flink.runtime.instance.InstanceID extends AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.runtime.io.disk.iomanager
- Class org.apache.flink.runtime.io.disk.iomanager.RequestQueue extends LinkedBlockingQueue<E> implements Serializable
  
  serialVersionUID:
  
  3804115535778471680L
  - Serialized Fields
    - closed
```
boolean closed
```
      Flag marking this queue as closed.
Package org.apache.flink.runtime.io.network
- Class org.apache.flink.runtime.io.network.ConnectionID extends Object implements Serializable
  - Serialized Fields
    - address
```
InetSocketAddress address
```
    - connectionIndex
```
int connectionIndex
```
Package org.apache.flink.runtime.io.network.partition
- Class org.apache.flink.runtime.io.network.partition.ResultPartitionID extends Object implements Serializable
  - Serialized Fields
    - partitionId
```
IntermediateResultPartitionID partitionId
```
    - producerId
```
ExecutionAttemptID producerId
```
Package org.apache.flink.runtime.io.network.partition.consumer
- Class org.apache.flink.runtime.io.network.partition.consumer.InputChannelID extends AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel.BufferReorderingException extends IOException implements Serializable
  
  serialVersionUID:
  
  -888282210356266816L
  - Serialized Fields
    - expectedSequenceNumber
```
int expectedSequenceNumber
```
    - actualSequenceNumber
```
int actualSequenceNumber
```
Package org.apache.flink.runtime.iterative.convergence
- Class org.apache.flink.runtime.iterative.convergence.WorksetEmptyConvergenceCriterion extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.runtime.jobgraph
- Class org.apache.flink.runtime.jobgraph.AbstractJobVertex extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - id
```
JobVertexID id
```
      The ID of the vertex.
    - results
```
ArrayList<E> results
```
      List of produced data sets, one per writer
    - inputs
```
ArrayList<E> inputs
```
      List of edges with incoming data. One per Reader.
    - parallelism
```
int parallelism
```
      Number of subtasks to split this task into at runtime.
    - configuration
```
Configuration configuration
```
      Custom configuration passed to the assigned task at runtime.
    - invokableClassName
```
String invokableClassName
```
      The class of the invokable.
    - inputSplitSource
```
InputSplitSource<T extends InputSplit> inputSplitSource
```
      Optionally, a source of input splits
    - name
```
String name
```
      The name of the vertex
    - slotSharingGroup
```
SlotSharingGroup slotSharingGroup
```
      Optionally, a sharing group that allows subtasks from different job vertices to run concurrently in one slot
    - coLocationGroup
```
CoLocationGroup coLocationGroup
```
      The group inside which the vertex subtasks share slots
- Class org.apache.flink.runtime.jobgraph.InputFormatVertex extends AbstractJobVertex implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - formatDescription
```
String formatDescription
```
- Class org.apache.flink.runtime.jobgraph.IntermediateDataSet extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - id
```
IntermediateDataSetID id
```
    - producer
```
AbstractJobVertex producer
```
    - consumers
```
List<E> consumers
```
    - resultType
```
ResultPartitionType resultType
```
- Class org.apache.flink.runtime.jobgraph.IntermediateDataSetID extends AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.jobgraph.IntermediateResultPartitionID extends AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.jobgraph.JobEdge extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - target
```
AbstractJobVertex target
```
      The vertex connected to this edge.
    - distributionPattern
```
DistributionPattern distributionPattern
```
      The distribution pattern that should be used for this job edge.
    - source
```
IntermediateDataSet source
```
      The data set at the source of the edge, may be null if the edge is not yet connected
    - sourceId
```
IntermediateDataSetID sourceId
```
      The id of the source intermediate data set
- Class org.apache.flink.runtime.jobgraph.JobGraph extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - taskVertices
```
Map<K,V> taskVertices
```
      List of task vertices included in this job graph.
    - jobConfiguration
```
Configuration jobConfiguration
```
      The job configuration attached to this job.
    - userJars
```
List<E> userJars
```
      Set of JAR files required to run this job.
    - userJarBlobKeys
```
List<E> userJarBlobKeys
```
      Set of blob keys identifying the JAR files required to run this job.
    - jobID
```
JobID jobID
```
      ID of this job.
    - jobName
```
String jobName
```
      Name of this job.
    - numExecutionRetries
```
int numExecutionRetries
```
      The number of times that failed tasks should be re-executed
    - allowQueuedScheduling
```
boolean allowQueuedScheduling
```
      flag to enable queued scheduling
    - scheduleMode
```
ScheduleMode scheduleMode
```
    - jobType
```
JobGraph.JobType jobType
```
    - checkpointingEnabled
```
boolean checkpointingEnabled
```
    - checkpointingInterval
```
long checkpointingInterval
```
- Class org.apache.flink.runtime.jobgraph.JobVertexID extends AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.jobgraph.OutputFormatVertex extends AbstractJobVertex implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - formatDescription
```
String formatDescription
```
Package org.apache.flink.runtime.jobmanager
- Class org.apache.flink.runtime.jobmanager.BarrierTimeout extends Object implements Serializable
- Class org.apache.flink.runtime.jobmanager.BarrierTimeout$ extends scala.runtime.AbstractFunction0<org.apache.flink.runtime.jobmanager.BarrierTimeout> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.jobmanager.CompactAndUpdate extends Object implements Serializable
- Class org.apache.flink.runtime.jobmanager.CompactAndUpdate$ extends scala.runtime.AbstractFunction0<org.apache.flink.runtime.jobmanager.CompactAndUpdate> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.jobmanager.InitBarrierScheduler extends Object implements Serializable
- Class org.apache.flink.runtime.jobmanager.InitBarrierScheduler$ extends scala.runtime.AbstractFunction0<org.apache.flink.runtime.jobmanager.InitBarrierScheduler> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.jobmanager.JobManagerCLIConfiguration extends Object implements Serializable
  - Serialized Fields
    - configDir
```
String configDir
```
    - executionMode
```
JobManagerMode executionMode
```
- Class org.apache.flink.runtime.jobmanager.JobManagerCLIConfiguration$ extends scala.runtime.AbstractFunction2<String,JobManagerMode,org.apache.flink.runtime.jobmanager.JobManagerCLIConfiguration> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
Package org.apache.flink.runtime.jobmanager.scheduler
- Class org.apache.flink.runtime.jobmanager.scheduler.CoLocationGroup extends Object implements Serializable
  
  serialVersionUID:
  
  -2605819490401895297L
  - Serialized Fields
    - id
```
AbstractID id
```
    - vertices
```
List<E> vertices
```
- Class org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException extends JobException implements Serializable
  
  serialVersionUID:
  
  -2249953165298717803L
- Class org.apache.flink.runtime.jobmanager.scheduler.ResourceId extends AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.jobmanager.scheduler.SlotSharingGroup extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ids
```
Set<E> ids
```
Package org.apache.flink.runtime.jobmanager.web
- Class org.apache.flink.runtime.jobmanager.web.JobManagerInfoServlet extends javax.servlet.http.HttpServlet implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jobmanager
```
akka.actor.ActorRef jobmanager
```
      Underlying JobManager
    - archive
```
akka.actor.ActorRef archive
```
    - timeout
```
scala.concurrent.duration.FiniteDuration timeout
```
- Class org.apache.flink.runtime.jobmanager.web.LogfileInfoServlet extends javax.servlet.http.HttpServlet implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - logDirs
```
File[] logDirs
```
- Class org.apache.flink.runtime.jobmanager.web.MenuServlet extends javax.servlet.http.HttpServlet implements Serializable
  
  serialVersionUID:
  
  117543213991787547L
- Class org.apache.flink.runtime.jobmanager.web.SetupInfoServlet extends javax.servlet.http.HttpServlet implements Serializable
  
  serialVersionUID:
  
  3704963598772630435L
  - Serialized Fields
    - configuration
```
Configuration configuration
```
    - jobmanager
```
akka.actor.ActorRef jobmanager
```
    - timeout
```
scala.concurrent.duration.FiniteDuration timeout
```
Package org.apache.flink.runtime.memorymanager
- Class org.apache.flink.runtime.memorymanager.MemoryAllocationException extends Exception implements Serializable
  
  serialVersionUID:
  
  -403983866457947012L
Package org.apache.flink.runtime.operators.chaining
- Class org.apache.flink.runtime.operators.chaining.ExceptionInChainedStubException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  -7966910518892776903L
  - Serialized Fields
    - taskName
```
String taskName
```
    - exception
```
Exception exception
```
Package org.apache.flink.runtime.operators.util
- Class org.apache.flink.runtime.operators.util.CorruptConfigurationException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  854450995262666207L
- Class org.apache.flink.runtime.operators.util.TaskConfig extends Object implements Serializable
  - Serialized Fields
    - config
```
Configuration config
```
- Class org.apache.flink.runtime.operators.util.TaskConfig.DelegatingConfiguration extends Configuration implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - backingConfig
```
Configuration backingConfig
```
    - prefix
```
String prefix
```
Package org.apache.flink.runtime.profiling
- Class org.apache.flink.runtime.profiling.ProfilingException extends Exception implements Serializable
  
  serialVersionUID:
  
  -3282996556813630561L
Package org.apache.flink.runtime.profiling.types
- Class org.apache.flink.runtime.profiling.types.InstanceProfilingEvent extends ProfilingEvent implements Serializable
  
  serialVersionUID:
  
  5964092674722506040L
  - Serialized Fields
    - profilingInterval
```
int profilingInterval
```
      The interval of time this profiling event covers in milliseconds.
    - ioWaitCPU
```
int ioWaitCPU
```
      The percentage of time the CPU(s) spent in state IOWAIT during the profiling interval.
    - idleCPU
```
int idleCPU
```
      The percentage of time the CPU(s) spent in state IDLE during the profiling interval.
    - userCPU
```
int userCPU
```
      The percentage of time the CPU(s) spent in state USER during the profiling interval.
    - systemCPU
```
int systemCPU
```
      The percentage of time the CPU(s) spent in state SYSTEM during the profiling interval.
    - hardIrqCPU
```
int hardIrqCPU
```
      The percentage of time the CPU(s) spent in state HARD_IRQ during the profiling interval.
    - softIrqCPU
```
int softIrqCPU
```
      The percentage of time the CPU(s) spent in state SOFT_IRQ during the profiling interval.
    - totalMemory
```
long totalMemory
```
      The total amount of this instance's main memory in bytes.
    - freeMemory
```
long freeMemory
```
      The free amount of this instance's main memory in bytes.
    - bufferedMemory
```
long bufferedMemory
```
      The amount of main memory the instance uses for file buffers.
    - cachedMemory
```
long cachedMemory
```
      The amount of main memory the instance uses as cache memory.
    - cachedSwapMemory
```
long cachedSwapMemory
```
      The amount of main memory the instance uses for cached swaps.
    - receivedBytes
```
long receivedBytes
```
      The number of bytes received via network during the profiling interval.
    - transmittedBytes
```
long transmittedBytes
```
      The number of bytes transmitted via network during the profiling interval.
- Class org.apache.flink.runtime.profiling.types.InstanceSummaryProfilingEvent extends InstanceProfilingEvent implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.profiling.types.ProfilingEvent extends AbstractEvent implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jobID
```
JobID jobID
```
      The ID of the job the profiling data belongs to.
    - profilingTimestamp
```
long profilingTimestamp
```
      The profiling time stamp.
- Class org.apache.flink.runtime.profiling.types.SingleInstanceProfilingEvent extends InstanceProfilingEvent implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - instanceName
```
String instanceName
```
- Class org.apache.flink.runtime.profiling.types.ThreadProfilingEvent extends VertexProfilingEvent implements Serializable
  
  serialVersionUID:
  
  -3006867830244444710L
  - Serialized Fields
    - userTime
```
int userTime
```
    - systemTime
```
int systemTime
```
    - blockedTime
```
int blockedTime
```
    - waitedTime
```
int waitedTime
```
- Class org.apache.flink.runtime.profiling.types.VertexProfilingEvent extends ProfilingEvent implements Serializable
  
  serialVersionUID:
  
  -5364961557518174880L
  - Serialized Fields
    - vertexId
```
JobVertexID vertexId
```
    - subtask
```
int subtask
```
    - executionId
```
ExecutionAttemptID executionId
```
    - profilingInterval
```
int profilingInterval
```
Package org.apache.flink.runtime.state
- Class org.apache.flink.runtime.state.LocalStateHandle extends Object implements Serializable
  - Serialized Fields
    - state
```
byte[] state
```
- Class org.apache.flink.runtime.state.OperatorState extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - stateObject
```
Object stateObject
```
- Class org.apache.flink.runtime.state.StateCheckpoint extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - checkpointedState
```
OperatorState<T> checkpointedState
```
Package org.apache.flink.runtime.taskmanager
- Class org.apache.flink.runtime.taskmanager.NetworkEnvironmentConfiguration extends Object implements Serializable
  - Serialized Fields
    - numNetworkBuffers
```
int numNetworkBuffers
```
    - networkBufferSize
```
int networkBufferSize
```
    - ioMode
```
IOManager.IOMode ioMode
```
    - nettyConfig
```
scala.Option<A> nettyConfig
```
- Class org.apache.flink.runtime.taskmanager.NetworkEnvironmentConfiguration$ extends scala.runtime.AbstractFunction4<Object,Object,IOManager.IOMode,scala.Option<NettyConfig>,org.apache.flink.runtime.taskmanager.NetworkEnvironmentConfiguration> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.taskmanager.TaskExecutionState extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jobID
```
JobID jobID
```
    - executionId
```
ExecutionAttemptID executionId
```
    - executionState
```
ExecutionState executionState
```
    - serializedError
```
byte[] serializedError
```
- Class org.apache.flink.runtime.taskmanager.TaskManagerCLIConfiguration extends Object implements Serializable
  - Serialized Fields
    - configDir
```
String configDir
```
- Class org.apache.flink.runtime.taskmanager.TaskManagerCLIConfiguration$ extends scala.runtime.AbstractFunction1<String,org.apache.flink.runtime.taskmanager.TaskManagerCLIConfiguration> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.taskmanager.TaskManagerConfiguration extends Object implements Serializable
  - Serialized Fields
    - tmpDirPaths
```
String[] tmpDirPaths
```
    - cleanupInterval
```
long cleanupInterval
```
    - timeout
```
scala.concurrent.duration.FiniteDuration timeout
```
    - maxRegistrationDuration
```
scala.Option<A> maxRegistrationDuration
```
    - numberOfSlots
```
int numberOfSlots
```
    - configuration
```
Configuration configuration
```
- Class org.apache.flink.runtime.taskmanager.TaskManagerConfiguration$ extends scala.runtime.AbstractFunction6<String[],Object,scala.concurrent.duration.FiniteDuration,scala.Option<scala.concurrent.duration.FiniteDuration>,Object,Configuration,org.apache.flink.runtime.taskmanager.TaskManagerConfiguration> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
Package org.apache.flink.runtime.util
- Class org.apache.flink.runtime.util.SerializableArrayList extends ArrayList<E extends IOReadableWritable> implements Serializable
  
  serialVersionUID:
  
  8196856588290198537L
- Class org.apache.flink.runtime.util.SerializableHashMap extends HashMap<K extends IOReadableWritable,V extends IOReadableWritable> implements Serializable
  
  serialVersionUID:
  
  6693468726881121924L
- Class org.apache.flink.runtime.util.SerializableHashSet extends HashSet<T extends IOReadableWritable> implements Serializable
  
  serialVersionUID:
  
  -4615823301768215807L
Package org.apache.flink.runtime.yarn
- Class org.apache.flink.runtime.yarn.FlinkYarnClusterStatus extends Object implements Serializable
  - Serialized Fields
    - numberOfTaskManagers
```
int numberOfTaskManagers
```
    - numberOfSlots
```
int numberOfSlots
```

Serialized Form

Package org.apache.flink.runtime

Class org.apache.flink.runtime.JobException extends Exception implements Serializable

Package org.apache.flink.runtime.accumulators

Class org.apache.flink.runtime.accumulators.AccumulatorEvent extends Object implements Serializable

Serialization Methods

readObject

writeObject

Serialized Fields

jobID

accumulators

serializedData

Package org.apache.flink.runtime.blob

Class org.apache.flink.runtime.blob.BlobKey extends Object implements Serializable

Serialized Fields

key

Package org.apache.flink.runtime.broadcast

Class org.apache.flink.runtime.broadcast.InitializationTypeConflictException extends Exception implements Serializable

Serialized Fields

type

Class org.apache.flink.runtime.broadcast.MaterializationExpiredException extends Exception implements Serializable

Package org.apache.flink.runtime.client

Class org.apache.flink.runtime.client.JobCancellationException extends JobExecutionException implements Serializable

Class org.apache.flink.runtime.client.JobExecutionException extends Exception implements Serializable

Serialized Fields

jobID

Class org.apache.flink.runtime.client.JobStatusMessage extends Object implements Serializable

Serialized Fields

jobId

jobName

jobState

startTime

Class org.apache.flink.runtime.client.JobSubmissionException extends JobExecutionException implements Serializable

Class org.apache.flink.runtime.client.JobTimeoutException extends JobExecutionException implements Serializable

Package org.apache.flink.runtime.deployment

Class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptor extends Object implements Serializable

Serialized Fields

consumedPartitionId

consumedPartitionLocation

Class org.apache.flink.runtime.deployment.InputGateDeploymentDescriptor extends Object implements Serializable

Serialized Fields

consumedResultId

consumedSubpartitionIndex

inputChannels

Class org.apache.flink.runtime.deployment.ResultPartitionDeploymentDescriptor extends Object implements Serializable

Serialized Fields

resultId

partitionId

partitionType

numberOfSubpartitions

Class org.apache.flink.runtime.deployment.ResultPartitionLocation extends Object implements Serializable

Serialized Fields

locationType

connectionId

Class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor extends Object implements Serializable

Serialized Fields

jobID

vertexID

executionId

taskName

indexInSubtaskGroup

numberOfSubtasks

jobConfiguration

taskConfiguration

invokableClassName

producedPartitions

inputGates

targetSlotNumber

requiredJarFiles

operatorStates

Package org.apache.flink.runtime.event.job

Class org.apache.flink.runtime.event.job.AbstractEvent extends Object implements Serializable

Serialized Fields

timestamp

sequenceNumber

Package org.apache.flink.runtime.event.task

Class org.apache.flink.runtime.event.task.EventList extends SerializableArrayList<AbstractEvent> implements Serializable

Package org.apache.flink.runtime.execution

Class org.apache.flink.runtime.execution.CancelTaskException extends RuntimeException implements Serializable

Package org.apache.flink.runtime.executiongraph