Serialized Form (flink 1.8-SNAPSHOT API)

Package <Unnamed>
- Class StreamingFileSinkProgram.Generator extends Object implements Serializable
  
  serialVersionUID:
  
  -2819385275681175792L
  - Serialized Fields
    - numKeys
```
int numKeys
```
    - idlenessMs
```
int idlenessMs
```
    - recordsToEmit
```
int recordsToEmit
```
    - numRecordsEmitted
```
int numRecordsEmitted
```
    - canceled
```
boolean canceled
```
- Class StreamingFileSinkProgram.KeyBucketAssigner extends Object implements Serializable
  
  serialVersionUID:
  
  987325769970523326L
Package example.avro
- Class example.avro.User extends org.apache.avro.specific.SpecificRecordBase implements Serializable
  
  serialVersionUID:
  
  3144724849436857910L
  - Serialization Methods
    - readExternal
```
public void readExternal(ObjectInput in)
                  throws IOException
```
      Throws:
      
      IOException
    - writeExternal
```
public void writeExternal(ObjectOutput out)
                   throws IOException
```
      Throws:
      
      IOException
Package org.apache.calcite.avatica.util
- Class org.apache.calcite.avatica.util.ByteString extends Object implements Serializable
  - Serialized Fields
    - bytes
```
byte[] bytes
```
Package org.apache.calcite.sql.validate
- Class org.apache.calcite.sql.validate.CyclicDefinitionException extends RuntimeException implements Serializable
  - Serialized Fields
    - depth
```
int depth
```
    - path
```
List<E> path
```
- Class org.apache.calcite.sql.validate.SqlValidatorException extends Exception implements Serializable
  
  serialVersionUID:
  
  -831683113957131387L
Package org.apache.calcite.sql2rel
- Class org.apache.calcite.sql2rel.RelFieldTrimmer.TrimResult extends org.apache.calcite.util.Pair<org.apache.calcite.rel.RelNode,org.apache.calcite.util.mapping.Mapping> implements Serializable
Package org.apache.flink.addons.hbase
- Class org.apache.flink.addons.hbase.AbstractTableInputFormat extends RichInputFormat<T,TableInputSplit> implements Serializable
  - Serialized Fields
    - endReached
```
boolean endReached
```
    - resultScanner
```
org.apache.hadoop.hbase.client.ResultScanner resultScanner
```
      HBase iterator wrapper.
    - currentRow
```
byte[] currentRow
```
    - scannedRows
```
long scannedRows
```
- Class org.apache.flink.addons.hbase.HBaseRowInputFormat extends AbstractTableInputFormat<Row> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableName
```
String tableName
```
    - schema
```
HBaseTableSchema schema
```
    - families
```
byte[][] families
```
    - qualifiers
```
byte[][][] qualifiers
```
    - types
```
int[][] types
```
    - resultRow
```
Row resultRow
```
    - familyRows
```
Row[] familyRows
```
- Class org.apache.flink.addons.hbase.HBaseTableSchema extends Object implements Serializable
  - Serialized Fields
    - familyMap
```
Map<K,V> familyMap
```
    - charset
```
String charset
```
- Class org.apache.flink.addons.hbase.TableInputFormat extends AbstractTableInputFormat<T extends Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.addons.hbase.TableInputSplit extends LocatableInputSplit implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableName
```
byte[] tableName
```
      The name of the table to retrieve data from.
    - startRow
```
byte[] startRow
```
      The start row of the split.
    - endRow
```
byte[] endRow
```
      The end row of the split.
Package org.apache.flink.api.common
- Class org.apache.flink.api.common.ArchivedExecutionConfig extends Object implements Serializable
  
  serialVersionUID:
  
  2126156250920316528L
  - Serialized Fields
    - executionMode
```
String executionMode
```
    - restartStrategyDescription
```
String restartStrategyDescription
```
    - parallelism
```
int parallelism
```
    - objectReuseEnabled
```
boolean objectReuseEnabled
```
    - globalJobParameters
```
Map<K,V> globalJobParameters
```
- Class org.apache.flink.api.common.ExecutionConfig extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - executionMode
```
ExecutionMode executionMode
```
      Defines how data exchange happens - batch or pipelined
    - closureCleanerLevel
```
ExecutionConfig.ClosureCleanerLevel closureCleanerLevel
```
    - parallelism
```
int parallelism
```
    - maxParallelism
```
int maxParallelism
```
      The program wide maximum parallelism used for operators which haven't specified a maximum parallelism. The maximum parallelism specifies the upper limit for dynamic scaling and the number of key groups used for partitioned state.
    - numberOfExecutionRetries
```
int numberOfExecutionRetries
```
      Deprecated. Should no longer be used because it is subsumed by RestartStrategyConfiguration
    - forceKryo
```
boolean forceKryo
```
    - disableGenericTypes
```
boolean disableGenericTypes
```
      Flag to indicate whether generic types (through Kryo) are supported
    - objectReuse
```
boolean objectReuse
```
    - autoTypeRegistrationEnabled
```
boolean autoTypeRegistrationEnabled
```
    - forceAvro
```
boolean forceAvro
```
    - codeAnalysisMode
```
CodeAnalysisMode codeAnalysisMode
```
    - printProgressDuringExecution
```
boolean printProgressDuringExecution
```
      If set to true, progress updates are printed to System.out during execution
    - autoWatermarkInterval
```
long autoWatermarkInterval
```
    - latencyTrackingInterval
```
long latencyTrackingInterval
```
      Interval in milliseconds for sending latency tracking marks from the sources to the sinks.
    - isLatencyTrackingConfigured
```
boolean isLatencyTrackingConfigured
```
    - executionRetryDelay
```
long executionRetryDelay
```
      Deprecated. Should no longer be used because it is subsumed by RestartStrategyConfiguration
    - restartStrategyConfiguration
```
RestartStrategies.RestartStrategyConfiguration restartStrategyConfiguration
```
    - taskCancellationIntervalMillis
```
long taskCancellationIntervalMillis
```
    - taskCancellationTimeoutMillis
```
long taskCancellationTimeoutMillis
```
      Timeout after which an ongoing task cancellation will lead to a fatal TaskManager error, usually killing the JVM.
    - useSnapshotCompression
```
boolean useSnapshotCompression
```
      This flag defines if we use compression for the state snapshot data or not. Default: false
    - failTaskOnCheckpointError
```
boolean failTaskOnCheckpointError
```
      Determines if a task fails or not if there is an error in writing its checkpoint data. Default: true
    - defaultInputDependencyConstraint
```
InputDependencyConstraint defaultInputDependencyConstraint
```
      The default input dependency constraint to schedule tasks.
    - globalJobParameters
```
ExecutionConfig.GlobalJobParameters globalJobParameters
```
    - registeredTypesWithKryoSerializers
```
LinkedHashMap<K,V> registeredTypesWithKryoSerializers
```
    - registeredTypesWithKryoSerializerClasses
```
LinkedHashMap<K,V> registeredTypesWithKryoSerializerClasses
```
    - defaultKryoSerializers
```
LinkedHashMap<K,V> defaultKryoSerializers
```
    - defaultKryoSerializerClasses
```
LinkedHashMap<K,V> defaultKryoSerializerClasses
```
    - registeredKryoTypes
```
LinkedHashSet<E> registeredKryoTypes
```
    - registeredPojoTypes
```
LinkedHashSet<E> registeredPojoTypes
```
- Class org.apache.flink.api.common.ExecutionConfig.GlobalJobParameters extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.ExecutionConfig.SerializableSerializer extends Object implements Serializable
  
  serialVersionUID:
  
  4687893502781067189L
  - Serialized Fields
    - serializer
```
com.esotericsoftware.kryo.Serializer<T> serializer
```
- Class org.apache.flink.api.common.InvalidProgramException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  3119881934024032887L
- Class org.apache.flink.api.common.JobID extends AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.NonSerializableUserCodeException extends InvalidProgramException implements Serializable
  
  serialVersionUID:
  
  2L
Package org.apache.flink.api.common.accumulators
- Class org.apache.flink.api.common.accumulators.AverageAccumulator extends Object implements Serializable
  
  serialVersionUID:
  
  3672555084179165255L
  - Serialized Fields
    - count
```
long count
```
    - sum
```
double sum
```
- Class org.apache.flink.api.common.accumulators.DoubleCounter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - localValue
```
double localValue
```
- Class org.apache.flink.api.common.accumulators.DoubleMaximum extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - max
```
double max
```
- Class org.apache.flink.api.common.accumulators.DoubleMinimum extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - min
```
double min
```
- Class org.apache.flink.api.common.accumulators.Histogram extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - treeMap
```
TreeMap<K,V> treeMap
```
- Class org.apache.flink.api.common.accumulators.IntCounter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - localValue
```
int localValue
```
- Class org.apache.flink.api.common.accumulators.IntMaximum extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - max
```
int max
```
- Class org.apache.flink.api.common.accumulators.IntMinimum extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - min
```
int min
```
- Class org.apache.flink.api.common.accumulators.ListAccumulator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - localValue
```
ArrayList<E> localValue
```
- Class org.apache.flink.api.common.accumulators.LongCounter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - localValue
```
long localValue
```
- Class org.apache.flink.api.common.accumulators.LongMaximum extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - max
```
long max
```
- Class org.apache.flink.api.common.accumulators.LongMinimum extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - min
```
long min
```
- Class org.apache.flink.api.common.accumulators.SerializedListAccumulator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - localValue
```
ArrayList<E> localValue
```
Package org.apache.flink.api.common.aggregators
- Class org.apache.flink.api.common.aggregators.DoubleSumAggregator extends Object implements Serializable
  - Serialized Fields
    - wrapper
```
DoubleValue wrapper
```
    - sum
```
double sum
```
- Class org.apache.flink.api.common.aggregators.DoubleZeroConvergence extends Object implements Serializable
- Class org.apache.flink.api.common.aggregators.LongSumAggregator extends Object implements Serializable
  - Serialized Fields
    - sum
```
long sum
```
- Class org.apache.flink.api.common.aggregators.LongZeroConvergence extends Object implements Serializable
Package org.apache.flink.api.common.cache
- Class org.apache.flink.api.common.cache.DistributedCache.DistributedCacheEntry extends Object implements Serializable
  - Serialized Fields
    - filePath
```
String filePath
```
    - isExecutable
```
Boolean isExecutable
```
    - isZipped
```
boolean isZipped
```
    - blobKey
```
byte[] blobKey
```
Package org.apache.flink.api.common.distributions
- Class org.apache.flink.api.common.distributions.CommonRangeBoundaries extends Object implements Serializable
  - Serialized Fields
    - typeComparator
```
TypeComparator<T> typeComparator
```
    - boundaries
```
Object[][] boundaries
```
    - flatComparators
```
TypeComparator<T>[] flatComparators
```
    - keys
```
Object[] keys
```
Package org.apache.flink.api.common.functions
- Class org.apache.flink.api.common.functions.AbstractRichFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.InvalidTypesException extends InvalidProgramException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichAggregateFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichCoGroupFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichCrossFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichFilterFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichFlatJoinFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichFlatMapFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichFoldFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichGroupCombineFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichGroupReduceFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichJoinFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichMapFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichMapPartitionFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichReduceFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.common.functions.util
- Class org.apache.flink.api.common.functions.util.NoOpFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.util.PrintSinkOutputWriter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - target
```
boolean target
```
    - sinkIdentifier
```
String sinkIdentifier
```
Package org.apache.flink.api.common.io
- Class org.apache.flink.api.common.io.BinaryInputFormat extends FileInputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - blockSize
```
long blockSize
```
      The block size to use.
    - readRecords
```
long readRecords
```
      The number of records already read from the block. This is used to decide if the end of the block has been reached.
- Class org.apache.flink.api.common.io.BinaryOutputFormat extends FileOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - blockSize
```
long blockSize
```
      The block size to use.
- Class org.apache.flink.api.common.io.DelimitedInputFormat extends FileInputFormat<OT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - charsetName
```
String charsetName
```
    - offset
```
long offset
```
    - delimiter
```
byte[] delimiter
```
    - delimiterString
```
String delimiterString
```
    - lineLengthLimit
```
int lineLengthLimit
```
    - bufferSize
```
int bufferSize
```
    - numLineSamples
```
int numLineSamples
```
- Class org.apache.flink.api.common.io.FileInputFormat extends RichInputFormat<OT,FileInputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - filePath
```
Path filePath
```
      Deprecated. Please override FileInputFormat.supportsMultiPaths() and use FileInputFormat.getFilePaths() and FileInputFormat.setFilePaths(Path...).
      
      The path to the file that contains the input.
    - filePaths
```
Path[] filePaths
```
      The list of paths to files and directories that contain the input.
    - minSplitSize
```
long minSplitSize
```
      The minimal split size, set by the configure() method.
    - numSplits
```
int numSplits
```
      The desired number of splits, as set by the configure() method.
    - openTimeout
```
long openTimeout
```
      Stream opening timeout.
    - unsplittable
```
boolean unsplittable
```
      Some file input formats are not splittable on a block level (avro, deflate) Therefore, the FileInputFormat can only read whole files.
    - enumerateNestedFiles
```
boolean enumerateNestedFiles
```
      The flag to specify whether recursive traversal of the input directory structure is enabled.
    - filesFilter
```
FilePathFilter filesFilter
```
      Files filter for determining what files/directories should be included.
- Class org.apache.flink.api.common.io.FileOutputFormat extends RichOutputFormat<IT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - outputFilePath
```
Path outputFilePath
```
      The path of the file to be written.
    - writeMode
```
FileSystem.WriteMode writeMode
```
      The write mode of the output.
    - outputDirectoryMode
```
FileOutputFormat.OutputDirectoryMode outputDirectoryMode
```
      The output directory mode
- Class org.apache.flink.api.common.io.FilePathFilter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.io.FilePathFilter.DefaultFilter extends FilePathFilter implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.io.GenericCsvInputFormat extends DelimitedInputFormat<OT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - lineDelimiterIsLinebreak
```
boolean lineDelimiterIsLinebreak
```
    - fieldTypes
```
Class<T>[] fieldTypes
```
    - fieldIncluded
```
boolean[] fieldIncluded
```
    - fieldDelim
```
byte[] fieldDelim
```
    - fieldDelimString
```
String fieldDelimString
```
    - lenient
```
boolean lenient
```
    - skipFirstLineAsHeader
```
boolean skipFirstLineAsHeader
```
    - quotedStringParsing
```
boolean quotedStringParsing
```
    - quoteCharacter
```
byte quoteCharacter
```
    - commentPrefix
```
byte[] commentPrefix
```
    - commentPrefixString
```
String commentPrefixString
```
- Class org.apache.flink.api.common.io.GenericInputFormat extends RichInputFormat<OT,GenericInputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partitionNumber
```
int partitionNumber
```
      The partition of this split.
- Class org.apache.flink.api.common.io.GlobFilePathFilter extends FilePathFilter implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - includePatterns
```
List<E> includePatterns
```
    - excludePatterns
```
List<E> excludePatterns
```
- Class org.apache.flink.api.common.io.ParseException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  -6721968786653128017L
- Class org.apache.flink.api.common.io.ReplicatingInputFormat extends RichInputFormat<OT,S extends InputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - replicatedIF
```
InputFormat<OT,T extends InputSplit> replicatedIF
```
- Class org.apache.flink.api.common.io.RichInputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.io.RichOutputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.io.SerializedInputFormat extends BinaryInputFormat<T extends IOReadableWritable> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.io.SerializedOutputFormat extends BinaryOutputFormat<T extends IOReadableWritable> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.common.io.ratelimiting
- Class org.apache.flink.api.common.io.ratelimiting.GuavaFlinkConnectorRateLimiter extends Object implements Serializable
  
  serialVersionUID:
  
  -3680641524643737192L
  - Serialized Fields
    - globalRateBytesPerSecond
```
long globalRateBytesPerSecond
```
      Rate in bytes per second for the consumer on a whole.
    - localRateBytesPerSecond
```
long localRateBytesPerSecond
```
      Rate in bytes per second per subtask of the consumer.
    - runtimeContext
```
RuntimeContext runtimeContext
```
      Runtime context.
    - rateLimiter
```
org.apache.flink.shaded.guava18.com.google.common.util.concurrent.RateLimiter rateLimiter
```
      RateLimiter.
Package org.apache.flink.api.common.operators
- Class org.apache.flink.api.common.operators.DualInputSemanticProperties extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldMapping1
```
Map<K,V> fieldMapping1
```
      Mapping from fields in the source record(s) in the first input to fields in the destination record(s).
    - fieldMapping2
```
Map<K,V> fieldMapping2
```
      Mapping from fields in the source record(s) in the second input to fields in the destination record(s).
    - readFields1
```
FieldSet readFields1
```
      Set of fields that are read in the source record(s) from the first input.
    - readFields2
```
FieldSet readFields2
```
      Set of fields that are read in the source record(s) from the second input.
- Class org.apache.flink.api.common.operators.Keys.IncompatibleKeysException extends Exception implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.operators.ResourceSpec extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - cpuCores
```
double cpuCores
```
      How many cpu cores are needed, use double so we can specify cpu like 0.1.
    - heapMemoryInMB
```
int heapMemoryInMB
```
      How many java heap memory in mb are needed.
    - directMemoryInMB
```
int directMemoryInMB
```
      How many nio direct memory in mb are needed.
    - nativeMemoryInMB
```
int nativeMemoryInMB
```
      How many native memory in mb are needed.
    - stateSizeInMB
```
int stateSizeInMB
```
      How many state size in mb are used.
    - extendedResources
```
Map<K,V> extendedResources
```
- Class org.apache.flink.api.common.operators.SemanticProperties.EmptySemanticProperties extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.operators.SemanticProperties.InvalidSemanticAnnotationException extends InvalidProgramException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.operators.SingleInputSemanticProperties extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldMapping
```
Map<K,V> fieldMapping
```
      Mapping from fields in the source record(s) to fields in the destination record(s).
    - readFields
```
FieldSet readFields
```
      Set of fields that are read in the source record(s).
- Class org.apache.flink.api.common.operators.SingleInputSemanticProperties.AllFieldsForwardedProperties extends SingleInputSemanticProperties implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.common.operators.base
- Class org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionAggregationConvergence extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionAggregator extends Object implements Serializable
  - Serialized Fields
    - count
```
long count
```
- Class org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionMapper extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - aggregator
```
BulkIterationBase.TerminationCriterionAggregator aggregator
```
Package org.apache.flink.api.common.operators.util
- Class org.apache.flink.api.common.operators.util.UserCodeClassWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - userCodeClass
```
Class<T> userCodeClass
```
- Class org.apache.flink.api.common.operators.util.UserCodeObjectWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - userCodeObject
```
Object userCodeObject
```
Package org.apache.flink.api.common.resources
- Class org.apache.flink.api.common.resources.GPUResource extends Resource implements Serializable
  
  serialVersionUID:
  
  -2276080061777135142L
- Class org.apache.flink.api.common.resources.Resource extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - name
```
String name
```
    - value
```
double value
```
    - resourceAggregateType
```
Resource.ResourceAggregateType resourceAggregateType
```
Package org.apache.flink.api.common.restartstrategy
- Class org.apache.flink.api.common.restartstrategy.RestartStrategies.FailureRateRestartStrategyConfiguration extends RestartStrategies.RestartStrategyConfiguration implements Serializable
  
  serialVersionUID:
  
  1195028697539661739L
  - Serialized Fields
    - maxFailureRate
```
int maxFailureRate
```
    - failureInterval
```
Time failureInterval
```
    - delayBetweenAttemptsInterval
```
Time delayBetweenAttemptsInterval
```
- Class org.apache.flink.api.common.restartstrategy.RestartStrategies.FallbackRestartStrategyConfiguration extends RestartStrategies.RestartStrategyConfiguration implements Serializable
  
  serialVersionUID:
  
  -4441787204284085544L
- Class org.apache.flink.api.common.restartstrategy.RestartStrategies.FixedDelayRestartStrategyConfiguration extends RestartStrategies.RestartStrategyConfiguration implements Serializable
  
  serialVersionUID:
  
  4149870149673363190L
  - Serialized Fields
    - restartAttempts
```
int restartAttempts
```
    - delayBetweenAttemptsInterval
```
Time delayBetweenAttemptsInterval
```
- Class org.apache.flink.api.common.restartstrategy.RestartStrategies.NoRestartStrategyConfiguration extends RestartStrategies.RestartStrategyConfiguration implements Serializable
  
  serialVersionUID:
  
  -5894362702943349962L
- Class org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration extends Object implements Serializable
  
  serialVersionUID:
  
  6285853591578313960L
Package org.apache.flink.api.common.serialization
- Class org.apache.flink.api.common.serialization.AbstractDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - type
```
TypeInformation<T> type
```
      The type produced by this DeserializationSchema.
- Class org.apache.flink.api.common.serialization.SimpleStringEncoder extends Object implements Serializable
  
  serialVersionUID:
  
  -6865107843734614452L
  - Serialized Fields
    - charsetName
```
String charsetName
```
- Class org.apache.flink.api.common.serialization.SimpleStringSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
- Class org.apache.flink.api.common.serialization.TypeInformationSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  -5359448468131559102L
  - Serialized Fields
    - typeInfo
```
TypeInformation<T> typeInfo
```
      The type information, to be returned by TypeInformationSerializationSchema.getProducedType().
    - serializer
```
TypeSerializer<T> serializer
```
      The serializer for the actual de-/serialization.
Package org.apache.flink.api.common.state
- Class org.apache.flink.api.common.state.AggregatingStateDescriptor extends StateDescriptor<AggregatingState<IN,OUT>,ACC> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - aggFunction
```
AggregateFunction<IN,ACC,OUT> aggFunction
```
      The aggregation function for the state.
- Class org.apache.flink.api.common.state.FoldingStateDescriptor extends StateDescriptor<FoldingState<T,ACC>,ACC> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - foldFunction
```
FoldFunction<O,T> foldFunction
```
      Deprecated.
- Class org.apache.flink.api.common.state.ListStateDescriptor extends StateDescriptor<ListState<T>,List<T>> implements Serializable
  
  serialVersionUID:
  
  2L
- Class org.apache.flink.api.common.state.MapStateDescriptor extends StateDescriptor<MapState<UK,UV>,Map<UK,UV>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.state.ReducingStateDescriptor extends StateDescriptor<ReducingState<T>,T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - reduceFunction
```
ReduceFunction<T> reduceFunction
```
- Class org.apache.flink.api.common.state.StateDescriptor extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - 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
    - name
```
String name
```
      Name that uniquely identifies state created from this StateDescriptor.
    - serializerAtomicReference
```
AtomicReference<V> serializerAtomicReference
```
      The serializer for the type. May be eagerly initialized in the constructor, or lazily once the StateDescriptor.initializeSerializerUnlessSet(ExecutionConfig) method is called.
    - typeInfo
```
TypeInformation<T> typeInfo
```
      The type information describing the value type. Only used to if the serializer is created lazily.
    - queryableStateName
```
String queryableStateName
```
      Name for queries against state created from this StateDescriptor.
    - ttlConfig
```
StateTtlConfig ttlConfig
```
      Name for queries against state created from this StateDescriptor.
- Class org.apache.flink.api.common.state.StateTtlConfig extends Object implements Serializable
  
  serialVersionUID:
  
  -7592693245044289793L
  - Serialized Fields
    - updateType
```
StateTtlConfig.UpdateType updateType
```
    - stateVisibility
```
StateTtlConfig.StateVisibility stateVisibility
```
    - timeCharacteristic
```
StateTtlConfig.TimeCharacteristic timeCharacteristic
```
    - ttl
```
Time ttl
```
    - cleanupStrategies
```
StateTtlConfig.CleanupStrategies cleanupStrategies
```
- Class org.apache.flink.api.common.state.StateTtlConfig.CleanupStrategies extends Object implements Serializable
  
  serialVersionUID:
  
  -1617740467277313524L
  - Serialized Fields
    - isCleanupInBackground
```
boolean isCleanupInBackground
```
    - strategies
```
EnumMap<K extends Enum<K>,V> strategies
```
- Class org.apache.flink.api.common.state.StateTtlConfig.IncrementalCleanupStrategy extends Object implements Serializable
  
  serialVersionUID:
  
  3109278696501988780L
  - Serialized Fields
    - cleanupSize
```
int cleanupSize
```
      Max number of keys pulled from queue for clean up upon state touch for any key.
    - runCleanupForEveryRecord
```
boolean runCleanupForEveryRecord
```
      Whether to run incremental cleanup per each processed record.
- Class org.apache.flink.api.common.state.StateTtlConfig.RocksdbCompactFilterCleanupStrategy extends Object implements Serializable
  
  serialVersionUID:
  
  3109278796506988980L
  - Serialized Fields
    - queryTimeAfterNumEntries
```
long queryTimeAfterNumEntries
```
      Number of state entries to process by compaction filter before updating current timestamp.
- Class org.apache.flink.api.common.state.ValueStateDescriptor extends StateDescriptor<ValueState<T>,T> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.common.time
- Class org.apache.flink.api.common.time.Time extends Object implements Serializable
  
  serialVersionUID:
  
  -350254188460915999L
  - Serialized Fields
    - unit
```
TimeUnit unit
```
      The time unit for this policy's time interval.
    - size
```
long size
```
      The size of the windows generated by this policy.
Package org.apache.flink.api.common.typeinfo
- Class org.apache.flink.api.common.typeinfo.BasicArrayTypeInfo extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - arrayClass
```
Class<T> arrayClass
```
    - componentInfo
```
TypeInformation<T> componentInfo
```
- Class org.apache.flink.api.common.typeinfo.BasicTypeInfo extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  -430955220409131770L
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
    - serializer
```
TypeSerializer<T> serializer
```
    - possibleCastTargetTypes
```
Class<T>[] possibleCastTargetTypes
```
    - comparatorClass
```
Class<T> comparatorClass
```
- Class org.apache.flink.api.common.typeinfo.FractionalTypeInfo extends NumericTypeInfo<T> implements Serializable
  
  serialVersionUID:
  
  554334260950199994L
- Class org.apache.flink.api.common.typeinfo.IntegerTypeInfo extends NumericTypeInfo<T> implements Serializable
  
  serialVersionUID:
  
  -8068827354966766955L
- Class org.apache.flink.api.common.typeinfo.NothingTypeInfo extends TypeInformation<Nothing> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeinfo.NumericTypeInfo extends BasicTypeInfo<T> implements Serializable
  
  serialVersionUID:
  
  -5937777910658986986L
- Class org.apache.flink.api.common.typeinfo.PrimitiveArrayTypeInfo extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - arrayClass
```
Class<T> arrayClass
```
      The class of the array (such as int[].class).
    - serializer
```
TypeSerializer<T> serializer
```
      The serializer for the array.
    - comparatorClass
```
Class<T> comparatorClass
```
      The class of the comparator for the array.
- Class org.apache.flink.api.common.typeinfo.SqlTimeTypeInfo extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  -132955295409131880L
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
    - serializer
```
TypeSerializer<T> serializer
```
    - comparatorClass
```
Class<T> comparatorClass
```
- Class org.apache.flink.api.common.typeinfo.TypeInformation extends Object implements Serializable
  
  serialVersionUID:
  
  -7742311969684489493L
Package org.apache.flink.api.common.typeutils
- Class org.apache.flink.api.common.typeutils.CompositeSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldSerializers
```
TypeSerializer<T>[] fieldSerializers
```
      Serializers for fields which constitute T.
    - precomputed
```
CompositeSerializer.PrecomputedParameters precomputed
```
- Class org.apache.flink.api.common.typeutils.CompositeSerializer.PrecomputedParameters extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - immutableTargetType
```
boolean immutableTargetType
```
      Whether target type is immutable.
    - immutable
```
boolean immutable
```
      Whether target type and its fields are immutable.
    - length
```
int length
```
      Byte length of target object in serialized form.
    - stateful
```
boolean stateful
```
      Whether any field serializer is stateful.
- Class org.apache.flink.api.common.typeutils.CompositeType extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
- Class org.apache.flink.api.common.typeutils.CompositeType.InvalidFieldReferenceException extends IllegalArgumentException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.CompositeTypeComparator extends TypeComparator<T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.GenericPairComparator extends TypePairComparator<T1,T2> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - comparator1
```
TypeComparator<T> comparator1
```
    - comparator2
```
TypeComparator<T> comparator2
```
    - comparators1
```
TypeComparator<T>[] comparators1
```
    - comparators2
```
TypeComparator<T>[] comparators2
```
    - referenceKeyFields
```
Object[] referenceKeyFields
```
    - candidateKeyFields
```
Object[] candidateKeyFields
```
- Class org.apache.flink.api.common.typeutils.SingleThreadAccessCheckingTypeSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  131020282727167064L
  - Serialization Methods
    - writeObject
```
private void writeObject(ObjectOutputStream outputStream)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - singleThreadAccessChecker
```
org.apache.flink.api.common.typeutils.SingleThreadAccessCheckingTypeSerializer.SingleThreadAccessChecker singleThreadAccessChecker
```
    - originalSerializer
```
TypeSerializer<T> originalSerializer
```
- Class org.apache.flink.api.common.typeutils.TypeComparator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.TypeSerializer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.UnloadableDummyTypeSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  2526330533671642711L
  - Serialized Fields
    - actualBytes
```
byte[] actualBytes
```
    - originalError
```
Throwable originalError
```
Package org.apache.flink.api.common.typeutils.base
- Class org.apache.flink.api.common.typeutils.base.BasicTypeComparator extends TypeComparator<T extends Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.BigDecComparator extends BasicTypeComparator<BigDecimal> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BigDecSerializer extends TypeSerializerSingleton<BigDecimal> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BigIntComparator extends BasicTypeComparator<BigInteger> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BigIntSerializer extends TypeSerializerSingleton<BigInteger> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BooleanComparator extends BasicTypeComparator<Boolean> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BooleanSerializer extends TypeSerializerSingleton<Boolean> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BooleanValueComparator extends TypeComparator<BooleanValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
BooleanValue reference
```
    - tempReference
```
BooleanValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.BooleanValueSerializer extends TypeSerializerSingleton<BooleanValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ByteComparator extends BasicTypeComparator<Byte> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ByteSerializer extends TypeSerializerSingleton<Byte> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ByteValueComparator extends TypeComparator<ByteValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
ByteValue reference
```
    - tempReference
```
ByteValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.ByteValueSerializer extends TypeSerializerSingleton<ByteValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.CharComparator extends BasicTypeComparator<Character> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.CharSerializer extends TypeSerializerSingleton<Character> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.CharValueComparator extends TypeComparator<CharValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
CharValue reference
```
    - tempReference
```
CharValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.CharValueSerializer extends TypeSerializerSingleton<CharValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.DateComparator extends BasicTypeComparator<Date> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.DateSerializer extends TypeSerializerSingleton<Date> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.DoubleComparator extends BasicTypeComparator<Double> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.DoubleSerializer extends TypeSerializerSingleton<Double> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.DoubleValueComparator extends TypeComparator<DoubleValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
DoubleValue reference
```
    - tempReference
```
DoubleValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.DoubleValueSerializer extends TypeSerializerSingleton<DoubleValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.EnumComparator extends BasicTypeComparator<T extends Enum<T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.EnumSerializer extends TypeSerializer<T extends Enum<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - enumClass
```
Class<T> enumClass
```
    - valueToOrdinal
```
Map<K,V> valueToOrdinal
```
      Maintain our own map of enum value to their ordinal, instead of directly using Enum.ordinal(). This allows us to maintain backwards compatibility for previous serialized data in the case that the order of enum constants was changed or new constants were added.
      On a fresh start with no reconfiguration, the ordinals would simply be identical to the enum constants actual ordinals. Ordinals may change after reconfiguration.
    - values
```
Enum<E extends Enum<E>>[] values
```
      Array of enum constants with their indexes identical to their ordinals in the EnumSerializer.valueToOrdinal map. Serves as a bidirectional map to have fast access from ordinal to value. May be reordered after reconfiguration.
- Class org.apache.flink.api.common.typeutils.base.FloatComparator extends BasicTypeComparator<Float> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.FloatSerializer extends TypeSerializerSingleton<Float> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.FloatValueComparator extends TypeComparator<FloatValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
FloatValue reference
```
    - tempReference
```
FloatValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.FloatValueSerializer extends TypeSerializerSingleton<FloatValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.GenericArraySerializer extends TypeSerializer<C[]> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - componentClass
```
Class<T> componentClass
```
    - componentSerializer
```
TypeSerializer<T> componentSerializer
```
- Class org.apache.flink.api.common.typeutils.base.InstantComparator extends BasicTypeComparator<java.time.Instant> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.InstantSerializer extends TypeSerializerSingleton<java.time.Instant> implements Serializable
  
  serialVersionUID:
  
  -4131715684999061277L
- Class org.apache.flink.api.common.typeutils.base.IntComparator extends BasicTypeComparator<Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.IntSerializer extends TypeSerializerSingleton<Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.IntValueComparator extends TypeComparator<IntValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
IntValue reference
```
    - tempReference
```
IntValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.IntValueSerializer extends TypeSerializerSingleton<IntValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ListSerializer extends TypeSerializer<List<T>> implements Serializable
  
  serialVersionUID:
  
  1119562170939152304L
  - Serialized Fields
    - elementSerializer
```
TypeSerializer<T> elementSerializer
```
      The serializer for the elements of the list.
- Class org.apache.flink.api.common.typeutils.base.LongComparator extends BasicTypeComparator<Long> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.LongSerializer extends TypeSerializerSingleton<Long> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.LongValueComparator extends TypeComparator<LongValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
LongValue reference
```
    - tempReference
```
LongValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.LongValueSerializer extends TypeSerializerSingleton<LongValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.MapSerializer extends TypeSerializer<Map<K,V>> implements Serializable
  
  serialVersionUID:
  
  -6885593032367050078L
  - Serialized Fields
    - keySerializer
```
TypeSerializer<T> keySerializer
```
      The serializer for the keys in the map
    - valueSerializer
```
TypeSerializer<T> valueSerializer
```
      The serializer for the values in the map
- Class org.apache.flink.api.common.typeutils.base.NullValueComparator extends TypeComparator<NullValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.NullValueSerializer extends TypeSerializerSingleton<NullValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ShortComparator extends BasicTypeComparator<Short> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ShortSerializer extends TypeSerializerSingleton<Short> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ShortValueComparator extends TypeComparator<ShortValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
ShortValue reference
```
    - tempReference
```
ShortValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.ShortValueSerializer extends TypeSerializerSingleton<ShortValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.SqlDateSerializer extends TypeSerializerSingleton<Date> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.SqlTimeSerializer extends TypeSerializerSingleton<Time> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.SqlTimestampComparator extends BasicTypeComparator<Date> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.SqlTimestampSerializer extends TypeSerializerSingleton<Timestamp> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.StringComparator extends BasicTypeComparator<String> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.StringSerializer extends TypeSerializerSingleton<String> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.StringValueComparator extends TypeComparator<StringValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
StringValue reference
```
    - tempReference
```
StringValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.StringValueSerializer extends TypeSerializerSingleton<StringValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  8766687317209282373L
- Class org.apache.flink.api.common.typeutils.base.VoidSerializer extends TypeSerializerSingleton<Void> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.common.typeutils.base.array
- Class org.apache.flink.api.common.typeutils.base.array.BooleanPrimitiveArrayComparator extends PrimitiveArrayComparator<boolean[],BooleanComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.BooleanPrimitiveArraySerializer extends TypeSerializerSingleton<boolean[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.BytePrimitiveArrayComparator extends PrimitiveArrayComparator<byte[],ByteComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.BytePrimitiveArraySerializer extends TypeSerializerSingleton<byte[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.CharPrimitiveArrayComparator extends PrimitiveArrayComparator<char[],CharComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.CharPrimitiveArraySerializer extends TypeSerializerSingleton<char[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.DoublePrimitiveArrayComparator extends PrimitiveArrayComparator<double[],DoubleComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.DoublePrimitiveArraySerializer extends TypeSerializerSingleton<double[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.FloatPrimitiveArrayComparator extends PrimitiveArrayComparator<float[],FloatComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.FloatPrimitiveArraySerializer extends TypeSerializerSingleton<float[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.IntPrimitiveArrayComparator extends PrimitiveArrayComparator<int[],IntComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.IntPrimitiveArraySerializer extends TypeSerializerSingleton<int[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.LongPrimitiveArrayComparator extends PrimitiveArrayComparator<long[],LongComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.LongPrimitiveArraySerializer extends TypeSerializerSingleton<long[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.PrimitiveArrayComparator extends TypeComparator<T> implements Serializable
  - Serialized Fields
    - comparators
```
TypeComparator<T>[] comparators
```
    - ascending
```
boolean ascending
```
    - comparator
```
BasicTypeComparator<T extends Comparable<T>> comparator
```
- Class org.apache.flink.api.common.typeutils.base.array.ShortPrimitiveArrayComparator extends PrimitiveArrayComparator<short[],ShortComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.ShortPrimitiveArraySerializer extends TypeSerializerSingleton<short[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.StringArraySerializer extends TypeSerializerSingleton<String[]> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.java
- Class org.apache.flink.api.java.Utils.ChecksumHashCode extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - count
```
long count
```
    - checksum
```
long checksum
```
- Class org.apache.flink.api.java.Utils.ChecksumHashCodeHelper extends RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - id
```
String id
```
    - counter
```
long counter
```
    - checksum
```
long checksum
```
- Class org.apache.flink.api.java.Utils.CollectHelper extends RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - id
```
String id
```
    - serializer
```
TypeSerializer<T> serializer
```
    - accumulator
```
SerializedListAccumulator<T> accumulator
```
- Class org.apache.flink.api.java.Utils.CountHelper extends RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - id
```
String id
```
    - counter
```
long counter
```
Package org.apache.flink.api.java.aggregation
- Class org.apache.flink.api.java.aggregation.AggregationFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.aggregation.MaxAggregationFunction extends AggregationFunction<T extends Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.aggregation.MaxAggregationFunction.MaxAggregationFunctionFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.aggregation.MinAggregationFunction extends AggregationFunction<T extends Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.aggregation.MinAggregationFunction.MinAggregationFunctionFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.aggregation.SumAggregationFunction extends AggregationFunction<T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.aggregation.SumAggregationFunction.SumAggregationFunctionFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.aggregation.UnsupportedAggregationTypeException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  -1721898801986321005L
Package org.apache.flink.api.java.functions
- Class org.apache.flink.api.java.functions.FirstReducer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - count
```
int count
```
- Class org.apache.flink.api.java.functions.FlatMapIterator extends RichFlatMapFunction<IN,OUT> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.functions.FormattingMapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - formatter
```
TextOutputFormat.TextFormatter<IN> formatter
```
- Class org.apache.flink.api.java.functions.GroupReduceIterator extends RichGroupReduceFunction<IN,OUT> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.functions.IdPartitioner extends Object implements Serializable
  
  serialVersionUID:
  
  -1206233785103357568L
- Class org.apache.flink.api.java.functions.NullByteKeySelector extends Object implements Serializable
  
  serialVersionUID:
  
  614256539098549020L
- Class org.apache.flink.api.java.functions.SampleInCoordinator extends Object implements Serializable
  - Serialized Fields
    - withReplacement
```
boolean withReplacement
```
    - numSample
```
int numSample
```
    - seed
```
long seed
```
- Class org.apache.flink.api.java.functions.SampleInPartition extends RichMapPartitionFunction<T,IntermediateSampleData<T>> implements Serializable
  - Serialized Fields
    - withReplacement
```
boolean withReplacement
```
    - numSample
```
int numSample
```
    - seed
```
long seed
```
- Class org.apache.flink.api.java.functions.SampleWithFraction extends RichMapPartitionFunction<T,T> implements Serializable
  - Serialized Fields
    - withReplacement
```
boolean withReplacement
```
    - fraction
```
double fraction
```
    - seed
```
long seed
```
- Class org.apache.flink.api.java.functions.SelectByMaxFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fields
```
int[] fields
```
- Class org.apache.flink.api.java.functions.SelectByMinFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fields
```
int[] fields
```
Package org.apache.flink.api.java.hadoop.common
- Class org.apache.flink.api.java.hadoop.common.HadoopInputFormatCommonBase extends RichInputFormat<T,SPITTYPE extends InputSplit> implements Serializable
- Class org.apache.flink.api.java.hadoop.common.HadoopOutputFormatCommonBase extends RichOutputFormat<T> implements Serializable
Package org.apache.flink.api.java.hadoop.mapred
- Class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormat extends HadoopInputFormatBase<K,V,Tuple2<K,V>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase extends HadoopInputFormatCommonBase<T,HadoopInputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - 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
    - mapredInputFormat
```
org.apache.hadoop.mapred.InputFormat<K,V> mapredInputFormat
```
    - keyClass
```
Class<T> keyClass
```
    - valueClass
```
Class<T> valueClass
```
    - jobConf
```
org.apache.hadoop.mapred.JobConf jobConf
```
- Class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormat extends HadoopOutputFormatBase<K,V,Tuple2<K,V>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase extends HadoopOutputFormatCommonBase<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - 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
    - jobConf
```
org.apache.hadoop.mapred.JobConf jobConf
```
    - mapredOutputFormat
```
org.apache.hadoop.mapred.OutputFormat<K,V> mapredOutputFormat
```
Package org.apache.flink.api.java.hadoop.mapred.wrapper
- Class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit extends LocatableInputSplit implements Serializable
  
  serialVersionUID:
  
  -6990336376163226160L
  - 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
    - splitType
```
Class<T> splitType
```
Package org.apache.flink.api.java.hadoop.mapreduce
- Class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat extends HadoopInputFormatBase<K,V,Tuple2<K,V>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase extends HadoopInputFormatCommonBase<T,HadoopInputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - 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
    - mapreduceInputFormat
```
org.apache.hadoop.mapreduce.InputFormat<K,V> mapreduceInputFormat
```
    - keyClass
```
Class<T> keyClass
```
    - valueClass
```
Class<T> valueClass
```
    - configuration
```
Configuration configuration
```
    - fetched
```
boolean fetched
```
    - hasNext
```
boolean hasNext
```
- Class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormat extends HadoopOutputFormatBase<K,V,Tuple2<K,V>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase extends HadoopOutputFormatCommonBase<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - 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
    - configuration
```
Configuration configuration
```
    - mapreduceOutputFormat
```
org.apache.hadoop.mapreduce.OutputFormat<K,V> mapreduceOutputFormat
```
Package org.apache.flink.api.java.hadoop.mapreduce.wrapper
- Class org.apache.flink.api.java.hadoop.mapreduce.wrapper.HadoopInputSplit extends LocatableInputSplit implements Serializable
  
  serialVersionUID:
  
  6119153593707857235L
  - 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
    - splitType
```
Class<T> splitType
```
Package org.apache.flink.api.java.io
- Class org.apache.flink.api.java.io.CollectionInputFormat extends GenericInputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - 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
    - serializer
```
TypeSerializer<T> serializer
```
- Class org.apache.flink.api.java.io.CsvInputFormat extends GenericCsvInputFormat<OUT> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.io.CsvOutputFormat extends FileOutputFormat<T extends Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldDelimiter
```
String fieldDelimiter
```
    - recordDelimiter
```
String recordDelimiter
```
    - charsetName
```
String charsetName
```
    - allowNullValues
```
boolean allowNullValues
```
    - quoteStrings
```
boolean quoteStrings
```
- Class org.apache.flink.api.java.io.DiscardingOutputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.io.IteratorInputFormat extends GenericInputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - iterator
```
Iterator<E> iterator
```
- Class org.apache.flink.api.java.io.LocalCollectionOutputFormat extends RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - typeSerializer
```
TypeSerializer<T> typeSerializer
```
    - id
```
int id
```
- Class org.apache.flink.api.java.io.ParallelIteratorInputFormat extends GenericInputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - source
```
SplittableIterator<T> source
```
- Class org.apache.flink.api.java.io.PojoCsvInputFormat extends CsvInputFormat<OUT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - pojoTypeClass
```
Class<T> pojoTypeClass
```
    - pojoFieldNames
```
String[] pojoFieldNames
```
- Class org.apache.flink.api.java.io.PrimitiveInputFormat extends DelimitedInputFormat<OT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - primitiveClass
```
Class<T> primitiveClass
```
- Class org.apache.flink.api.java.io.PrintingOutputFormat extends RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - writer
```
PrintSinkOutputWriter<IN> writer
```
- Class org.apache.flink.api.java.io.RowCsvInputFormat extends CsvInputFormat<Row> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - arity
```
int arity
```
    - fieldTypeInfos
```
TypeInformation<T>[] fieldTypeInfos
```
    - fieldPosMap
```
int[] fieldPosMap
```
    - emptyColumnAsNull
```
boolean emptyColumnAsNull
```
- Class org.apache.flink.api.java.io.SplitDataProperties.SourcePartitionerMarker extends Object implements Serializable
  
  serialVersionUID:
  
  -8554223652384442571L
  - Serialized Fields
    - partitionMarker
```
String partitionMarker
```
- Class org.apache.flink.api.java.io.TextInputFormat extends DelimitedInputFormat<String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - charsetName
```
String charsetName
```
      The name of the charset to use for decoding.
- Class org.apache.flink.api.java.io.TextOutputFormat extends FileOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - charsetName
```
String charsetName
```
- Class org.apache.flink.api.java.io.TextValueInputFormat extends DelimitedInputFormat<StringValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - charsetName
```
String charsetName
```
    - skipInvalidLines
```
boolean skipInvalidLines
```
- Class org.apache.flink.api.java.io.TupleCsvInputFormat extends CsvInputFormat<OUT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tupleSerializer
```
TupleSerializerBase<T> tupleSerializer
```
- Class org.apache.flink.api.java.io.TypeSerializerInputFormat extends BinaryInputFormat<T> implements Serializable
  
  serialVersionUID:
  
  2123068581665107480L
  - Serialized Fields
    - serializer
```
TypeSerializer<T> serializer
```
- Class org.apache.flink.api.java.io.TypeSerializerOutputFormat extends BinaryOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  -6653022644629315158L
  - Serialized Fields
    - serializer
```
TypeSerializer<T> serializer
```
Package org.apache.flink.api.java.io.jdbc
- Class org.apache.flink.api.java.io.jdbc.JDBCInputFormat extends RichInputFormat<Row,InputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - username
```
String username
```
    - password
```
String password
```
    - drivername
```
String drivername
```
    - dbURL
```
String dbURL
```
    - queryTemplate
```
String queryTemplate
```
    - resultSetType
```
int resultSetType
```
    - resultSetConcurrency
```
int resultSetConcurrency
```
    - rowTypeInfo
```
RowTypeInfo rowTypeInfo
```
    - fetchSize
```
int fetchSize
```
    - hasNext
```
boolean hasNext
```
    - parameterValues
```
Object[][] parameterValues
```
- Class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat extends RichOutputFormat<Row> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - username
```
String username
```
    - password
```
String password
```
    - drivername
```
String drivername
```
    - dbURL
```
String dbURL
```
    - query
```
String query
```
    - batchInterval
```
int batchInterval
```
    - dbConn
```
Connection dbConn
```
    - upload
```
PreparedStatement upload
```
    - batchCount
```
int batchCount
```
    - typesArray
```
int[] typesArray
```
Package org.apache.flink.api.java.operators
- Class org.apache.flink.api.java.operators.CrossOperator.ProjectCrossFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fields
```
int[] fields
```
    - isFromFirst
```
boolean[] isFromFirst
```
    - outTuple
```
Tuple outTuple
```
- Class org.apache.flink.api.java.operators.JoinOperator.DefaultJoin.WrappingFlatJoinFunction extends WrappingFunction<JoinFunction<IN1,IN2,OUT>> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.java.operators.translation
- Class org.apache.flink.api.java.operators.translation.CombineToGroupCombineWrapper extends Object implements Serializable
  - Serialized Fields
    - wrappedFunction
```
CombineFunction<IN,OUT> wrappedFunction
```
- Class org.apache.flink.api.java.operators.translation.KeyExtractingMapper extends RichMapFunction<T,Tuple2<K,T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - keySelector
```
KeySelector<IN,KEY> keySelector
```
    - tuple
```
Tuple2<T0,T1> tuple
```
- Class org.apache.flink.api.java.operators.translation.KeyRemovingMapper extends RichMapFunction<Tuple2<K,T>,T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.operators.translation.PlanFilterOperator.FlatMapFilter extends WrappingFunction<FilterFunction<T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.operators.translation.RichCombineToGroupCombineWrapper extends RichGroupCombineFunction<IN,IN> implements Serializable
  - Serialized Fields
    - wrappedFunction
```
RichGroupReduceFunction<IN,OUT> wrappedFunction
```
- Class org.apache.flink.api.java.operators.translation.Tuple3UnwrappingIterator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - lastGroupKey
```
Object lastGroupKey
```
    - lastSortKey
```
Object lastSortKey
```
    - iterator
```
Iterator<E> iterator
```
    - iteratorAvailable
```
boolean iteratorAvailable
```
- Class org.apache.flink.api.java.operators.translation.Tuple3WrappingCollector extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tui
```
Tuple3UnwrappingIterator<T,K1,K2> tui
```
    - outTuple
```
Tuple3<T0,T1,T2> outTuple
```
    - wrappedCollector
```
Collector<T> wrappedCollector
```
- Class org.apache.flink.api.java.operators.translation.TupleLeftUnwrappingJoiner extends WrappingFunction<FlatJoinFunction<I1,I2,OUT>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.operators.translation.TupleRightUnwrappingJoiner extends WrappingFunction<FlatJoinFunction<I1,I2,OUT>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.operators.translation.TupleUnwrappingIterator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - lastKey
```
Object lastKey
```
    - iterator
```
Iterator<E> iterator
```
    - iteratorAvailable
```
boolean iteratorAvailable
```
- Class org.apache.flink.api.java.operators.translation.TupleUnwrappingJoiner extends WrappingFunction<FlatJoinFunction<I1,I2,OUT>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.operators.translation.TupleWrappingCollector extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tui
```
TupleUnwrappingIterator<T,K> tui
```
    - outTuple
```
Tuple2<T0,T1> outTuple
```
    - wrappedCollector
```
Collector<T> wrappedCollector
```
- Class org.apache.flink.api.java.operators.translation.TwoKeyExtractingMapper extends RichMapFunction<T,Tuple3<K1,K2,T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - keySelector1
```
KeySelector<IN,KEY> keySelector1
```
    - keySelector2
```
KeySelector<IN,KEY> keySelector2
```
    - tuple
```
Tuple3<T0,T1,T2> tuple
```
- Class org.apache.flink.api.java.operators.translation.WrappingFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - wrappedFunction
```
Function wrappedFunction
```
Package org.apache.flink.api.java.sca
- Class org.apache.flink.api.java.sca.CodeAnalyzerException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.sca.CodeErrorException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.java.summarize
- Class org.apache.flink.api.java.summarize.NumericColumnSummary extends ColumnSummary implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nonMissingCount
```
long nonMissingCount
```
    - nullCount
```
long nullCount
```
    - nanCount
```
long nanCount
```
    - infinityCount
```
long infinityCount
```
    - min
```
Object min
```
    - max
```
Object max
```
    - sum
```
Object sum
```
    - mean
```
Double mean
```
    - variance
```
Double variance
```
    - standardDeviation
```
Double standardDeviation
```
Package org.apache.flink.api.java.summarize.aggregation
- Class org.apache.flink.api.java.summarize.aggregation.BooleanSummaryAggregator extends Object implements Serializable
  - Serialized Fields
    - trueCount
```
long trueCount
```
    - falseCount
```
long falseCount
```
    - nullCount
```
long nullCount
```
- Class org.apache.flink.api.java.summarize.aggregation.CompensatedSum extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - value
```
double value
```
    - delta
```
double delta
```
- Class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator extends NumericSummaryAggregator<Double> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator.MaxDoubleAggregator extends Object implements Serializable
  - Serialized Fields
    - max
```
double max
```
- Class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator.MinDoubleAggregator extends Object implements Serializable
  - Serialized Fields
    - min
```
double min
```
- Class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator.SumDoubleAggregator extends Object implements Serializable
  - Serialized Fields
    - sum
```
CompensatedSum sum
```
- Class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator extends NumericSummaryAggregator<Float> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator.MaxFloatAggregator extends Object implements Serializable
  - Serialized Fields
    - max
```
float max
```
- Class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator.MinFloatAggregator extends Object implements Serializable
  - Serialized Fields
    - min
```
float min
```
- Class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator.SumFloatAggregator extends Object implements Serializable
  - Serialized Fields
    - sum
```
CompensatedSum sum
```
- Class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator extends NumericSummaryAggregator<Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator.MaxIntegerAggregator extends Object implements Serializable
  - Serialized Fields
    - max
```
int max
```
- Class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator.MinIntegerAggregator extends Object implements Serializable
  - Serialized Fields
    - min
```
int min
```
- Class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator.SumIntegerAggregator extends Object implements Serializable
  - Serialized Fields
    - sum
```
int sum
```
- Class org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator extends NumericSummaryAggregator<Long> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator.MaxLongAggregator extends Object implements Serializable
  - Serialized Fields
    - max
```
long max
```
- Class org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator.MinLongAggregator extends Object implements Serializable
  - Serialized Fields
    - min
```
long min
```
- Class org.apache.flink.api.java.summarize.aggregation.NumericSummaryAggregator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nonMissingCount
```
long nonMissingCount
```
    - nullCount
```
long nullCount
```
    - nanCount
```
long nanCount
```
    - infinityCount
```
long infinityCount
```
    - min
```
Aggregator<T,R> min
```
    - max
```
Aggregator<T,R> max
```
    - sum
```
Aggregator<T,R> sum
```
    - mean
```
CompensatedSum mean
```
    - m2
```
CompensatedSum m2
```
      Sum of squares of differences from the current mean (used to calculate variance).
      The algorithm is described in: "Scalable and Numerically Stable Descriptive Statistics in SystemML", Tian et al, International Conference on Data Engineering 2012
- Class org.apache.flink.api.java.summarize.aggregation.ObjectSummaryAggregator extends Object implements Serializable
  - Serialized Fields
    - nonNullCount
```
long nonNullCount
```
    - nullCount
```
long nullCount
```
- Class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator extends NumericSummaryAggregator<Short> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator.MaxShortAggregator extends Object implements Serializable
  - Serialized Fields
    - max
```
short max
```
- Class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator.MinShortAggregator extends Object implements Serializable
  - Serialized Fields
    - min
```
short min
```
- Class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator.SumShortAggregator extends Object implements Serializable
  - Serialized Fields
    - sum
```
short sum
```
- Class org.apache.flink.api.java.summarize.aggregation.StringSummaryAggregator extends Object implements Serializable
  - Serialized Fields
    - nonNullCount
```
long nonNullCount
```
    - nullCount
```
long nullCount
```
    - emptyCount
```
long emptyCount
```
    - minStringLength
```
int minStringLength
```
    - maxStringLength
```
int maxStringLength
```
    - meanLength
```
CompensatedSum meanLength
```
- Class org.apache.flink.api.java.summarize.aggregation.TupleSummaryAggregator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - columnAggregators
```
Aggregator<T,R>[] columnAggregators
```
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator extends Object implements Serializable
  - Serialized Fields
    - aggregator
```
Aggregator<T,R> aggregator
```
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.BooleanValueSummaryAggregator extends ValueSummaryAggregator<BooleanValue,Boolean,BooleanColumnSummary,BooleanSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.DoubleValueSummaryAggregator extends ValueSummaryAggregator<DoubleValue,Double,NumericColumnSummary<Double>,DoubleSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.FloatValueSummaryAggregator extends ValueSummaryAggregator<FloatValue,Float,NumericColumnSummary<Float>,FloatSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.IntegerValueSummaryAggregator extends ValueSummaryAggregator<IntValue,Integer,NumericColumnSummary<Integer>,IntegerSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.LongValueSummaryAggregator extends ValueSummaryAggregator<LongValue,Long,NumericColumnSummary<Long>,LongSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.ShortValueSummaryAggregator extends ValueSummaryAggregator<ShortValue,Short,NumericColumnSummary<Short>,ShortSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.StringValueSummaryAggregator extends ValueSummaryAggregator<StringValue,String,StringColumnSummary,StringSummaryAggregator> implements Serializable
Package org.apache.flink.api.java.tuple
- Class org.apache.flink.api.java.tuple.Tuple extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.tuple.Tuple0 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readResolve
```
private Object readResolve()
                    throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
- Class org.apache.flink.api.java.tuple.Tuple1 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple10 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple11 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple12 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple13 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple14 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple15 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple16 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple17 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple18 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple19 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
    - f18
```
Object f18
```
      Field 18 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple2 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple20 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
    - f18
```
Object f18
```
      Field 18 of the tuple.
    - f19
```
Object f19
```
      Field 19 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple21 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
    - f18
```
Object f18
```
      Field 18 of the tuple.
    - f19
```
Object f19
```
      Field 19 of the tuple.
    - f20
```
Object f20
```
      Field 20 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple22 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
    - f18
```
Object f18
```
      Field 18 of the tuple.
    - f19
```
Object f19
```
      Field 19 of the tuple.
    - f20
```
Object f20
```
      Field 20 of the tuple.
    - f21
```
Object f21
```
      Field 21 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple23 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
    - f18
```
Object f18
```
      Field 18 of the tuple.
    - f19
```
Object f19
```
      Field 19 of the tuple.
    - f20
```
Object f20
```
      Field 20 of the tuple.
    - f21
```
Object f21
```
      Field 21 of the tuple.
    - f22
```
Object f22
```
      Field 22 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple24 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
    - f18
```
Object f18
```
      Field 18 of the tuple.
    - f19
```
Object f19
```
      Field 19 of the tuple.
    - f20
```
Object f20
```
      Field 20 of the tuple.
    - f21
```
Object f21
```
      Field 21 of the tuple.
    - f22
```
Object f22
```
      Field 22 of the tuple.
    - f23
```
Object f23
```
      Field 23 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple25 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
    - f18
```
Object f18
```
      Field 18 of the tuple.
    - f19
```
Object f19
```
      Field 19 of the tuple.
    - f20
```
Object f20
```
      Field 20 of the tuple.
    - f21
```
Object f21
```
      Field 21 of the tuple.
    - f22
```
Object f22
```
      Field 22 of the tuple.
    - f23
```
Object f23
```
      Field 23 of the tuple.
    - f24
```
Object f24
```
      Field 24 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple3 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple4 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple5 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple6 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple7 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple8 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple9 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
Package org.apache.flink.api.java.typeutils
- Class org.apache.flink.api.java.typeutils.EitherTypeInfo extends TypeInformation<Either<L,R>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - leftType
```
TypeInformation<T> leftType
```
    - rightType
```
TypeInformation<T> rightType
```
- Class org.apache.flink.api.java.typeutils.EnumTypeInfo extends TypeInformation<T extends Enum<T>> implements Serializable
  
  serialVersionUID:
  
  8936740290137178660L
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
- Class org.apache.flink.api.java.typeutils.GenericTypeInfo extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  -7959114120287706504L
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
- Class org.apache.flink.api.java.typeutils.ListTypeInfo extends TypeInformation<List<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - elementTypeInfo
```
TypeInformation<T> elementTypeInfo
```
- Class org.apache.flink.api.java.typeutils.MapTypeInfo extends TypeInformation<Map<K,V>> implements Serializable
  - Serialized Fields
    - keyTypeInfo
```
TypeInformation<T> keyTypeInfo
```
    - valueTypeInfo
```
TypeInformation<T> valueTypeInfo
```
- Class org.apache.flink.api.java.typeutils.MissingTypeInfo extends TypeInformation<InvalidTypesException> implements Serializable
  
  serialVersionUID:
  
  -4212082837126702723L
  - Serialized Fields
    - functionName
```
String functionName
```
    - typeException
```
InvalidTypesException typeException
```
- Class org.apache.flink.api.java.typeutils.MultisetTypeInfo extends MapTypeInfo<T,Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.ObjectArrayTypeInfo extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - arrayType
```
Class<T> arrayType
```
    - componentInfo
```
TypeInformation<T> componentInfo
```
- Class org.apache.flink.api.java.typeutils.PojoField extends Object implements Serializable
  
  serialVersionUID:
  
  1975295846436559363L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException,
                         ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - type
```
TypeInformation<T> type
```
- Class org.apache.flink.api.java.typeutils.PojoTypeInfo extends CompositeType<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fields
```
PojoField[] fields
```
    - totalFields
```
int totalFields
```
- Class org.apache.flink.api.java.typeutils.RowTypeInfo extends TupleTypeInfoBase<Row> implements Serializable
  
  serialVersionUID:
  
  9158518989896601963L
  - Serialized Fields
    - fieldNames
```
String[] fieldNames
```
    - comparatorOrders
```
boolean[] comparatorOrders
```
      Temporary variable for directly passing orders to comparators.
- Class org.apache.flink.api.java.typeutils.TupleTypeInfo extends TupleTypeInfoBase<T extends Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldNames
```
String[] fieldNames
```
- Class org.apache.flink.api.java.typeutils.TupleTypeInfoBase extends CompositeType<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - types
```
TypeInformation<T>[] types
```
    - totalFields
```
int totalFields
```
- Class org.apache.flink.api.java.typeutils.TypeExtractionException extends Exception implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.ValueTypeInfo extends TypeInformation<T extends Value> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
- Class org.apache.flink.api.java.typeutils.WritableTypeInfo extends TypeInformation<T extends org.apache.hadoop.io.Writable> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
Package org.apache.flink.api.java.typeutils.runtime
- Class org.apache.flink.api.java.typeutils.runtime.CopyableValueComparator extends TypeComparator<T extends CopyableValue<T> & Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream s)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - type
```
Class<T> type
```
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.java.typeutils.runtime.CopyableValueSerializer extends TypeSerializer<T extends CopyableValue<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - valueClass
```
Class<T> valueClass
```
- Class org.apache.flink.api.java.typeutils.runtime.EitherSerializer extends TypeSerializer<Either<L,R>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - leftSerializer
```
TypeSerializer<T> leftSerializer
```
    - rightSerializer
```
TypeSerializer<T> rightSerializer
```
- Class org.apache.flink.api.java.typeutils.runtime.GenericTypeComparator extends TypeComparator<T extends Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascending
```
boolean ascending
```
    - type
```
Class<T> type
```
    - serializer
```
TypeSerializer<T> serializer
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.java.typeutils.runtime.KryoRegistration extends Object implements Serializable
  
  serialVersionUID:
  
  5375110512910892655L
  - Serialized Fields
    - registeredClass
```
Class<T> registeredClass
```
      The registered class.
      This can be a dummy class KryoRegistrationSerializerConfigSnapshot.DummyRegisteredClass if the class no longer exists when this registration instance was restored.
    - serializerClass
```
Class<T> serializerClass
```
      Class of the serializer to use for the registered class. Exists only if the serializer definition type is KryoRegistration.SerializerDefinitionType.CLASS.
      This can be a dummy serializer KryoRegistrationSerializerConfigSnapshot.DummyKryoSerializerClass if the serializer class no longer exists when this registration instance was restored.
    - serializableSerializerInstance
```
ExecutionConfig.SerializableSerializer<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable> serializableSerializerInstance
```
      A serializable instance of the serializer to use for the registered class. Exists only if the serializer definition type is KryoRegistration.SerializerDefinitionType.INSTANCE.
      This can be a dummy serializer KryoRegistrationSerializerConfigSnapshot.DummyKryoSerializerClass if the serializer class no longer exists or is no longer valid when this registration instance was restored.
    - serializerDefinitionType
```
KryoRegistration.SerializerDefinitionType serializerDefinitionType
```
- Class org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot.DummyKryoSerializerClass extends com.esotericsoftware.kryo.Serializer<RC> implements Serializable
  
  serialVersionUID:
  
  -6172780797425739308L
- Class org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot.DummyRegisteredClass extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.runtime.NullableSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  3335569358214720033L
  - Serialized Fields
    - originalSerializer
```
TypeSerializer<T> originalSerializer
```
    - padding
```
byte[] padding
```
- Class org.apache.flink.api.java.typeutils.runtime.NullAwareComparator extends TypeComparator<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - wrappedComparator
```
TypeComparator<T> wrappedComparator
```
    - order
```
boolean order
```
    - flatFields
```
int flatFields
```
    - nullReference
```
boolean nullReference
```
- Class org.apache.flink.api.java.typeutils.runtime.PojoComparator extends CompositeTypeComparator<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException,
                         ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - comparators
```
TypeComparator<T>[] comparators
```
    - normalizedKeyLengths
```
int[] normalizedKeyLengths
```
    - numLeadingNormalizableKeys
```
int numLeadingNormalizableKeys
```
    - normalizableKeyPrefixLen
```
int normalizableKeyPrefixLen
```
    - invertNormKey
```
boolean invertNormKey
```
    - serializer
```
TypeSerializer<T> serializer
```
    - type
```
Class<T> type
```
- Class org.apache.flink.api.java.typeutils.runtime.PojoSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException,
                         ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
      The POJO type class.
    - fieldSerializers
```
TypeSerializer<T>[] fieldSerializers
```
    - numFields
```
int numFields
```
    - registeredClasses
```
LinkedHashMap<K,V> registeredClasses
```
      Registered subclasses and their serializers. Each subclass to their registered class tag is maintained as a separate map ordered by the class tag.
    - registeredSerializers
```
TypeSerializer<T>[] registeredSerializers
```
    - executionConfig
```
ExecutionConfig executionConfig
```
      Configuration of the current execution.
- Class org.apache.flink.api.java.typeutils.runtime.RowComparator extends CompositeTypeComparator<Row> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - arity
```
int arity
```
      The number of fields of the Row
    - keyPositions
```
int[] keyPositions
```
      key positions describe which fields are keys in what order
    - comparators
```
NullAwareComparator<T>[] comparators
```
      null-aware comparators for the key fields, in the same order as the key fields
    - serializers
```
TypeSerializer<T>[] serializers
```
      serializers to deserialize the first n fields for comparison
    - normalizedKeyLengths
```
int[] normalizedKeyLengths
```
      auxiliary fields for normalized key support
    - numLeadingNormalizableKeys
```
int numLeadingNormalizableKeys
```
    - normalizableKeyPrefixLen
```
int normalizableKeyPrefixLen
```
    - invertNormKey
```
boolean invertNormKey
```
    - nullMask1
```
boolean[] nullMask1
```
    - nullMask2
```
boolean[] nullMask2
```
- Class org.apache.flink.api.java.typeutils.runtime.RowSerializer extends TypeSerializer<Row> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - fieldSerializers
```
TypeSerializer<T>[] fieldSerializers
```
    - arity
```
int arity
```
- Class org.apache.flink.api.java.typeutils.runtime.RuntimeComparatorFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - comparator
```
TypeComparator<T> comparator
```
- Class org.apache.flink.api.java.typeutils.runtime.RuntimePairComparatorFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.RuntimeSerializerFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - serializer
```
TypeSerializer<T> serializer
```
    - firstSerializer
```
boolean firstSerializer
```
    - clazz
```
Class<T> clazz
```
- Class org.apache.flink.api.java.typeutils.runtime.Tuple0Serializer extends TupleSerializer<Tuple0> implements Serializable
  
  serialVersionUID:
  
  1278813169022975971L
- Class org.apache.flink.api.java.typeutils.runtime.TupleComparator extends TupleComparatorBase<T extends Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.TupleComparatorBase extends CompositeTypeComparator<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - keyPositions
```
int[] keyPositions
```
      key positions describe which fields are keys in what order
    - comparators
```
TypeComparator<T>[] comparators
```
      comparators for the key fields, in the same order as the key fields
    - normalizedKeyLengths
```
int[] normalizedKeyLengths
```
    - numLeadingNormalizableKeys
```
int numLeadingNormalizableKeys
```
    - normalizableKeyPrefixLen
```
int normalizableKeyPrefixLen
```
    - invertNormKey
```
boolean invertNormKey
```
    - serializers
```
TypeSerializer<T>[] serializers
```
      serializers to deserialize the first n fields for comparison
- Class org.apache.flink.api.java.typeutils.runtime.TupleSerializer extends TupleSerializerBase<T extends Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.TupleSerializerBase extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tupleClass
```
Class<T> tupleClass
```
    - fieldSerializers
```
TypeSerializer<T>[] fieldSerializers
```
    - arity
```
int arity
```
    - length
```
int length
```
- Class org.apache.flink.api.java.typeutils.runtime.ValueComparator extends TypeComparator<T extends Value & Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.java.typeutils.runtime.ValueSerializer extends TypeSerializer<T extends Value> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - type
```
Class<T> type
```
    - kryoRegistrations
```
LinkedHashMap<K,V> kryoRegistrations
```
      Map of class tag (using classname as tag) to their Kryo registration.
      This map serves as a preview of the final registration result of the Kryo instance, taking into account registration overwrites.
      Currently, we only have one single registration for the value type. Nevertheless, we keep this information here for future compatibility.
- Class org.apache.flink.api.java.typeutils.runtime.WritableComparator extends TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.java.typeutils.runtime.WritableSerializer extends TypeSerializer<T extends org.apache.hadoop.io.Writable> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
Package org.apache.flink.api.java.typeutils.runtime.kryo
- Class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  3L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - defaultSerializers
```
LinkedHashMap<K,V> defaultSerializers
```
    - defaultSerializerClasses
```
LinkedHashMap<K,V> defaultSerializerClasses
```
    - kryoRegistrations
```
LinkedHashMap<K,V> kryoRegistrations
```
      Map of class tag (using classname as tag) to their Kryo registration.
      This map serves as a preview of the final registration result of the Kryo instance, taking into account registration overwrites.
    - type
```
Class<T> type
```
    - registeredTypesWithSerializers
```
LinkedHashMap<K,V> registeredTypesWithSerializers
```
    - registeredTypesWithSerializerClasses
```
LinkedHashMap<K,V> registeredTypesWithSerializerClasses
```
    - registeredTypes
```
LinkedHashSet<E> registeredTypes
```
- Class org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.SpecificInstanceCollectionSerializer extends com.esotericsoftware.kryo.serializers.CollectionSerializer implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
- Class org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.SpecificInstanceCollectionSerializerForArrayList extends Serializers.SpecificInstanceCollectionSerializer<ArrayList> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.java.utils
- Class org.apache.flink.api.java.utils.ParameterTool extends ExecutionConfig.GlobalJobParameters implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - data
```
Map<K,V> data
```
- Class org.apache.flink.api.java.utils.RequiredParametersException extends Exception implements Serializable
  - Serialized Fields
    - missingArguments
```
List<E> missingArguments
```
Package org.apache.flink.api.scala.operators
- Class org.apache.flink.api.scala.operators.ScalaCsvOutputFormat extends FileOutputFormat<T extends scala.Product> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldDelimiter
```
String fieldDelimiter
```
    - recordDelimiter
```
String recordDelimiter
```
    - charsetName
```
String charsetName
```
    - allowNullValues
```
boolean allowNullValues
```
    - quoteStrings
```
boolean quoteStrings
```
Package org.apache.flink.api.scala.typeutils
- Class org.apache.flink.api.scala.typeutils.CaseClassComparator extends TupleComparatorBase<T extends scala.Product> implements Serializable
  - Serialized Fields
    - extractedKeys
```
Object[] extractedKeys
```
- Class org.apache.flink.api.scala.typeutils.CaseClassSerializer extends TupleSerializerBase<T extends scala.Product> implements Serializable
  
  serialVersionUID:
  
  7341356073446263475L
- Class org.apache.flink.api.scala.typeutils.CaseClassTypeInfo extends TupleTypeInfoBase<T extends scala.Product> implements Serializable
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
    - typeParamTypeInfos
```
TypeInformation<T>[] typeParamTypeInfos
```
    - org$apache$flink$api$scala$typeutils$CaseClassTypeInfo$$fieldTypes
```
scala.collection.Seq<A> org$apache$flink$api$scala$typeutils$CaseClassTypeInfo$$fieldTypes
```
    - fieldNames
```
scala.collection.Seq<A> fieldNames
```
    - REGEX_INT_FIELD
```
String REGEX_INT_FIELD
```
    - REGEX_STR_FIELD
```
String REGEX_STR_FIELD
```
    - REGEX_FIELD
```
String REGEX_FIELD
```
    - REGEX_NESTED_FIELDS
```
String REGEX_NESTED_FIELDS
```
    - REGEX_NESTED_FIELDS_WILDCARD
```
String REGEX_NESTED_FIELDS_WILDCARD
```
    - PATTERN_NESTED_FIELDS
```
Pattern PATTERN_NESTED_FIELDS
```
    - PATTERN_NESTED_FIELDS_WILDCARD
```
Pattern PATTERN_NESTED_FIELDS_WILDCARD
```
    - PATTERN_INT_FIELD
```
Pattern PATTERN_INT_FIELD
```
- Class org.apache.flink.api.scala.typeutils.EitherSerializer extends TypeSerializer<scala.util.Either<A,B>> implements Serializable
  
  serialVersionUID:
  
  9219995873023657525L
  - Serialized Fields
    - leftSerializer
```
TypeSerializer<T> leftSerializer
```
    - rightSerializer
```
TypeSerializer<T> rightSerializer
```
- Class org.apache.flink.api.scala.typeutils.EitherTypeInfo extends TypeInformation<T extends scala.util.Either<A,B>> implements Serializable
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
    - leftTypeInfo
```
TypeInformation<T> leftTypeInfo
```
    - rightTypeInfo
```
TypeInformation<T> rightTypeInfo
```
- Class org.apache.flink.api.scala.typeutils.EnumValueComparator extends TypeComparator<scala.Enumeration.Value> implements Serializable
  
  serialVersionUID:
  
  1000L
  - Serialized Fields
    - ascComp
```
boolean ascComp
```
    - intComparator
```
IntComparator intComparator
```
    - getFlatComparators
```
TypeComparator<T>[] getFlatComparators
```
    - bitmap$0
```
boolean bitmap$0
```
- Class org.apache.flink.api.scala.typeutils.EnumValueSerializer extends TypeSerializer<scala.Enumeration.Value> implements Serializable
  
  serialVersionUID:
  
  -2403076635594572920L
  - Serialized Fields
    - enum
```
scala.Enumeration enum
```
- Class org.apache.flink.api.scala.typeutils.EnumValueSerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.EnumValueTypeInfo extends TypeInformation<scala.Enumeration.Value> implements Serializable
  - Serialized Fields
    - enum
```
scala.Enumeration enum
```
    - clazz
```
Class<T> clazz
```
- Class org.apache.flink.api.scala.typeutils.NothingSerializer extends TypeSerializer<Object> implements Serializable
- Class org.apache.flink.api.scala.typeutils.OptionSerializer extends TypeSerializer<scala.Option<A>> implements Serializable
  
  serialVersionUID:
  
  -8635243274072627338L
  - Serialized Fields
    - elemSerializer
```
TypeSerializer<T> elemSerializer
```
- Class org.apache.flink.api.scala.typeutils.OptionSerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.OptionTypeComparator extends TypeComparator<scala.Option<A>> implements Serializable
  - Serialized Fields
    - ascending
```
boolean ascending
```
    - typeComparator
```
TypeComparator<T> typeComparator
```
    - reference
```
scala.Option<A> reference
```
    - getFlatComparators
```
TypeComparator<T>[] getFlatComparators
```
    - bitmap$0
```
boolean bitmap$0
```
- Class org.apache.flink.api.scala.typeutils.OptionTypeComparator$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
  - Serialized Fields
    - ZeroInByte
```
byte ZeroInByte
```
    - OneInByte
```
byte OneInByte
```
- Class org.apache.flink.api.scala.typeutils.OptionTypeInfo extends TypeInformation<T extends scala.Option<A>> implements Serializable
  - Serialized Fields
    - elemTypeInfo
```
TypeInformation<T> elemTypeInfo
```
- Class org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer extends org.apache.flink.api.scala.typeutils.CaseClassSerializer<T extends scala.Product> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream arg0)
```
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
- Class org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.ScalaNothingTypeInfo extends TypeInformation<scala.runtime.Nothing$> implements Serializable
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer extends TypeSerializer<T extends scala.collection.TraversableOnce<E>> implements Serializable
  
  serialVersionUID:
  
  7522917416391312410L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream arg0)
```
  - Serialized Fields
    - elementSerializer
```
TypeSerializer<T> elementSerializer
```
    - cbfCode
```
String cbfCode
```
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer.Key extends Object implements Serializable
  - Serialized Fields
    - classLoaderHash
```
int classLoaderHash
```
    - classLoaderRef
```
scala.ref.WeakReference<T> classLoaderRef
```
    - cbfCode
```
String cbfCode
```
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer.Key$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer.LazyRuntimeCompiler extends Object implements Serializable
  - Serialized Fields
    - classLoader
```
ClassLoader classLoader
```
    - code
```
String code
```
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer.LazyRuntimeCompiler$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
  - Serialized Fields
    - CACHE
```
org.apache.flink.shaded.guava18.com.google.common.cache.Cache<K,V> CACHE
```
- Class org.apache.flink.api.scala.typeutils.TraversableTypeInfo extends TypeInformation<T extends scala.collection.TraversableOnce<E>> implements Serializable
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
    - elementTypeInfo
```
TypeInformation<T> elementTypeInfo
```
- Class org.apache.flink.api.scala.typeutils.TrySerializer extends TypeSerializer<scala.util.Try<A>> implements Serializable
  
  serialVersionUID:
  
  -3052182891252564491L
  - Serialized Fields
    - elemSerializer
```
TypeSerializer<T> elemSerializer
```
    - throwableSerializer
```
TypeSerializer<T> throwableSerializer
```
- Class org.apache.flink.api.scala.typeutils.TrySerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.TryTypeInfo extends TypeInformation<T extends scala.util.Try<A>> implements Serializable
  - Serialized Fields
    - elemTypeInfo
```
TypeInformation<T> elemTypeInfo
```
- Class org.apache.flink.api.scala.typeutils.UnitSerializer extends TypeSerializerSingleton<scala.runtime.BoxedUnit> implements Serializable
  
  serialVersionUID:
  
  5413377487955047394L
- Class org.apache.flink.api.scala.typeutils.UnitSerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.UnitTypeInfo extends TypeInformation<scala.runtime.BoxedUnit> implements Serializable
Package org.apache.flink.avro.generated
- Class org.apache.flink.avro.generated.Address extends org.apache.avro.specific.SpecificRecordBase implements Serializable
  
  serialVersionUID:
  
  6397222640020965888L
  - Serialization Methods
    - readExternal
```
public void readExternal(ObjectInput in)
                  throws IOException
```
      Throws:
      
      IOException
    - writeExternal
```
public void writeExternal(ObjectOutput out)
                   throws IOException
```
      Throws:
      
      IOException
Package org.apache.flink.batch.connectors.cassandra
- Class org.apache.flink.batch.connectors.cassandra.CassandraInputFormat extends CassandraInputFormatBase<OUT extends Tuple> implements Serializable
  
  serialVersionUID:
  
  3642323148032444264L
- Class org.apache.flink.batch.connectors.cassandra.CassandraInputFormatBase extends RichInputFormat<OUT,InputSplit> implements Serializable
  
  serialVersionUID:
  
  -1519372881115104601L
  - Serialized Fields
    - logger
```
org.slf4j.Logger logger
```
    - query
```
String query
```
    - builder
```
ClusterBuilder builder
```
- Class org.apache.flink.batch.connectors.cassandra.CassandraOutputFormat extends CassandraTupleOutputFormat<OUT extends Tuple> implements Serializable
- Class org.apache.flink.batch.connectors.cassandra.CassandraOutputFormatBase extends RichOutputFormat<OUT> implements Serializable
  - Serialized Fields
    - insertQuery
```
String insertQuery
```
    - builder
```
ClusterBuilder builder
```
- Class org.apache.flink.batch.connectors.cassandra.CassandraPojoInputFormat extends CassandraInputFormatBase<OUT> implements Serializable
  
  serialVersionUID:
  
  1992091320180905115L
  - Serialized Fields
    - mapperOptions
```
MapperOptions mapperOptions
```
    - inputClass
```
Class<T> inputClass
```
- Class org.apache.flink.batch.connectors.cassandra.CassandraPojoOutputFormat extends RichOutputFormat<OUT> implements Serializable
  
  serialVersionUID:
  
  -1701885135103942460L
  - Serialized Fields
    - builder
```
ClusterBuilder builder
```
    - mapperOptions
```
MapperOptions mapperOptions
```
    - outputClass
```
Class<T> outputClass
```
- Class org.apache.flink.batch.connectors.cassandra.CassandraRowOutputFormat extends CassandraOutputFormatBase<Row> implements Serializable
- Class org.apache.flink.batch.connectors.cassandra.CassandraTupleOutputFormat extends CassandraOutputFormatBase<OUT extends Tuple> implements Serializable
Package org.apache.flink.batch.tests
- Class org.apache.flink.batch.tests.Generator extends Object implements Serializable
  - Serialized Fields
    - numRecords
```
long numRecords
```
    - numKeys
```
long numKeys
```
    - recordsPerPartition
```
long recordsPerPartition
```
    - keysPerPartition
```
long keysPerPartition
```
    - recordCnt
```
long recordCnt
```
    - partitionId
```
int partitionId
```
    - infinite
```
boolean infinite
```
Package org.apache.flink.cep
- Class org.apache.flink.cep.PatternStream.CoMapTimeout extends Object implements Serializable
  
  serialVersionUID:
  
  2059391566945212552L
- Class org.apache.flink.cep.RichPatternFlatSelectFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cep.RichPatternSelectFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cep.functions
- Class org.apache.flink.cep.functions.PatternProcessFunction extends AbstractRichFunction implements Serializable
Package org.apache.flink.cep.functions.adaptors
- Class org.apache.flink.cep.functions.adaptors.PatternFlatSelectAdapter extends PatternProcessFunction<IN,OUT> implements Serializable
  - Serialized Fields
    - flatSelectFunction
```
PatternFlatSelectFunction<IN,OUT> flatSelectFunction
```
- Class org.apache.flink.cep.functions.adaptors.PatternSelectAdapter extends PatternProcessFunction<IN,OUT> implements Serializable
  - Serialized Fields
    - selectFunction
```
PatternSelectFunction<IN,OUT> selectFunction
```
- Class org.apache.flink.cep.functions.adaptors.PatternTimeoutFlatSelectAdapter extends PatternFlatSelectAdapter<IN,OUT> implements Serializable
  - Serialized Fields
    - flatTimeoutFunction
```
PatternFlatTimeoutFunction<IN,OUT> flatTimeoutFunction
```
    - timedOutPartialMatchesTag
```
OutputTag<T> timedOutPartialMatchesTag
```
- Class org.apache.flink.cep.functions.adaptors.PatternTimeoutSelectAdapter extends PatternSelectAdapter<IN,OUT> implements Serializable
  - Serialized Fields
    - timeoutFunction
```
PatternTimeoutFunction<IN,OUT> timeoutFunction
```
    - timedOutPartialMatchesTag
```
OutputTag<T> timedOutPartialMatchesTag
```
Package org.apache.flink.cep.nfa
- Class org.apache.flink.cep.nfa.DeweyNumber extends Object implements Serializable
  
  serialVersionUID:
  
  6170434818252267825L
  - Serialized Fields
    - deweyNumber
```
int[] deweyNumber
```
- Class org.apache.flink.cep.nfa.DeweyNumber.DeweyNumberSerializer extends TypeSerializerSingleton<DeweyNumber> implements Serializable
  
  serialVersionUID:
  
  -5086792497034943656L
- Class org.apache.flink.cep.nfa.NFA.NFASerializer extends TypeSerializer<NFA.MigratedNFA<T>> implements Serializable
  
  serialVersionUID:
  
  2098282423980597010L
  - Serialized Fields
    - sharedBufferSerializer
```
TypeSerializer<T> sharedBufferSerializer
```
      Deprecated.
    - eventSerializer
```
TypeSerializer<T> eventSerializer
```
      Deprecated.
- Class org.apache.flink.cep.nfa.NFAStateSerializer extends TypeSerializerSingleton<NFAState> implements Serializable
  
  serialVersionUID:
  
  2098282423980597010L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - versionSerializer
```
TypeSerializer<T> versionSerializer
```
      NOTE: this field should actually be final. The reason that it isn't final is due to backward compatible deserialization paths. See NFAStateSerializer.readObject(ObjectInputStream).
    - nodeIdSerializer
```
TypeSerializer<T> nodeIdSerializer
```
    - eventIdSerializer
```
TypeSerializer<T> eventIdSerializer
```
- Class org.apache.flink.cep.nfa.SharedBuffer.SharedBufferSerializer extends TypeSerializer<SharedBuffer<V>> implements Serializable
  
  serialVersionUID:
  
  -3254176794680331560L
  - Serialized Fields
    - keySerializer
```
TypeSerializer<T> keySerializer
```
    - valueSerializer
```
TypeSerializer<T> valueSerializer
```
    - versionSerializer
```
TypeSerializer<T> versionSerializer
```
- Class org.apache.flink.cep.nfa.State extends Object implements Serializable
  
  serialVersionUID:
  
  6658700025989097781L
  - Serialized Fields
    - name
```
String name
```
    - stateType
```
State.StateType stateType
```
    - stateTransitions
```
Collection<E> stateTransitions
```
- Class org.apache.flink.cep.nfa.StateTransition extends Object implements Serializable
  
  serialVersionUID:
  
  -4825345749997891838L
  - Serialized Fields
    - action
```
StateTransitionAction action
```
    - sourceState
```
State<T> sourceState
```
    - targetState
```
State<T> targetState
```
    - condition
```
IterativeCondition<T> condition
```
Package org.apache.flink.cep.nfa.aftermatch
- Class org.apache.flink.cep.nfa.aftermatch.AfterMatchSkipStrategy extends Object implements Serializable
  
  serialVersionUID:
  
  -4048930333619068531L
- Class org.apache.flink.cep.nfa.aftermatch.NoSkipStrategy extends AfterMatchSkipStrategy implements Serializable
  
  serialVersionUID:
  
  -5843740153729531775L
- Class org.apache.flink.cep.nfa.aftermatch.SkipPastLastStrategy extends org.apache.flink.cep.nfa.aftermatch.SkipRelativeToWholeMatchStrategy implements Serializable
  
  serialVersionUID:
  
  -8450320065949093169L
- Class org.apache.flink.cep.nfa.aftermatch.SkipToFirstStrategy extends org.apache.flink.cep.nfa.aftermatch.SkipToElementStrategy implements Serializable
  
  serialVersionUID:
  
  7127107527654629026L
- Class org.apache.flink.cep.nfa.aftermatch.SkipToLastStrategy extends org.apache.flink.cep.nfa.aftermatch.SkipToElementStrategy implements Serializable
  
  serialVersionUID:
  
  7585116990619594531L
- Class org.apache.flink.cep.nfa.aftermatch.SkipToNextStrategy extends org.apache.flink.cep.nfa.aftermatch.SkipRelativeToWholeMatchStrategy implements Serializable
  
  serialVersionUID:
  
  -6490314998588752621L
Package org.apache.flink.cep.nfa.compiler
Package org.apache.flink.cep.nfa.sharedbuffer
- Class org.apache.flink.cep.nfa.sharedbuffer.EventId.EventIdSerializer extends TypeSerializerSingleton<EventId> implements Serializable
  
  serialVersionUID:
  
  -5685733582601394497L
- Class org.apache.flink.cep.nfa.sharedbuffer.Lockable.LockableTypeSerializer extends TypeSerializer<Lockable<E>> implements Serializable
  
  serialVersionUID:
  
  3298801058463337340L
  - Serialized Fields
    - elementSerializer
```
TypeSerializer<T> elementSerializer
```
- Class org.apache.flink.cep.nfa.sharedbuffer.NodeId.NodeIdSerializer extends TypeSerializerSingleton<NodeId> implements Serializable
  
  serialVersionUID:
  
  9209498028181378582L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - eventIdSerializer
```
TypeSerializer<T> eventIdSerializer
```
      NOTE: this field should actually be final. The reason that it isn't final is due to backward compatible deserialization paths. See NodeId.NodeIdSerializer.readObject(ObjectInputStream).
- Class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferEdge.SharedBufferEdgeSerializer extends TypeSerializerSingleton<SharedBufferEdge> implements Serializable
  
  serialVersionUID:
  
  -5122474955050663979L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - nodeIdSerializer
```
TypeSerializer<T> nodeIdSerializer
```
      NOTE: these serializer fields should actually be final. The reason that it isn't final is due to backward compatible deserialization paths. See SharedBufferEdge.SharedBufferEdgeSerializer.readObject(ObjectInputStream).
    - deweyNumberSerializer
```
TypeSerializer<T> deweyNumberSerializer
```
- Class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferNode.SharedBufferNodeSerializer extends TypeSerializerSingleton<SharedBufferNode> implements Serializable
  
  serialVersionUID:
  
  -6687780732295439832L
  - Serialized Fields
    - edgesSerializer
```
ListSerializer<T> edgesSerializer
```
Package org.apache.flink.cep.operator
- Class org.apache.flink.cep.operator.CepOperator extends AbstractUdfStreamOperator<OUT,PatternProcessFunction<IN,OUT>> implements Serializable
  
  serialVersionUID:
  
  -4166778210774160757L
  - Serialized Fields
    - isProcessingTime
```
boolean isProcessingTime
```
    - inputSerializer
```
TypeSerializer<T> inputSerializer
```
    - nfaFactory
```
NFACompiler.NFAFactory<T> nfaFactory
```
    - lastWatermark
```
long lastWatermark
```
      The last seen watermark. This will be used to decide if an incoming element is late or not.
    - comparator
```
EventComparator<T> comparator
```
      Comparator for secondary sorting. Primary sorting is always done on time.
    - lateDataOutputTag
```
OutputTag<T> lateDataOutputTag
```
      OutputTag to use for late arriving events. Elements with timestamp smaller than the current watermark will be emitted to this.
    - afterMatchSkipStrategy
```
AfterMatchSkipStrategy afterMatchSkipStrategy
```
      Strategy which element to skip after a match was found.
- Class org.apache.flink.cep.operator.StreamRecordComparator extends Object implements Serializable
  
  serialVersionUID:
  
  1581054988433915305L
Package org.apache.flink.cep.pattern
- Class org.apache.flink.cep.pattern.MalformedPatternException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  7751134834983361543L
Package org.apache.flink.cep.pattern.conditions
- Class org.apache.flink.cep.pattern.conditions.AndCondition extends IterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  -2471892317390197319L
  - Serialized Fields
    - left
```
IterativeCondition<T> left
```
      Deprecated.
    - right
```
IterativeCondition<T> right
```
      Deprecated.
- Class org.apache.flink.cep.pattern.conditions.IterativeCondition extends Object implements Serializable
  
  serialVersionUID:
  
  7067817235759351255L
- Class org.apache.flink.cep.pattern.conditions.NotCondition extends IterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  -2109562093871155005L
  - Serialized Fields
    - original
```
IterativeCondition<T> original
```
      Deprecated.
- Class org.apache.flink.cep.pattern.conditions.OrCondition extends IterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  2554610954278485106L
  - Serialized Fields
    - left
```
IterativeCondition<T> left
```
      Deprecated.
    - right
```
IterativeCondition<T> right
```
      Deprecated.
- Class org.apache.flink.cep.pattern.conditions.RichAndCondition extends RichCompositeIterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cep.pattern.conditions.RichCompositeIterativeCondition extends RichIterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nestedConditions
```
IterativeCondition<T>[] nestedConditions
```
- Class org.apache.flink.cep.pattern.conditions.RichIterativeCondition extends IterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cep.pattern.conditions.RichNotCondition extends RichCompositeIterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cep.pattern.conditions.RichOrCondition extends RichCompositeIterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cep.pattern.conditions.SimpleCondition extends IterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  4942618239408140245L
- Class org.apache.flink.cep.pattern.conditions.SubtypeCondition extends SimpleCondition<T> implements Serializable
  
  serialVersionUID:
  
  -2990017519957561355L
  - Serialized Fields
    - subtype
```
Class<T> subtype
```
      The subtype to filter for.
Package org.apache.flink.client.cli
- Class org.apache.flink.client.cli.CliArgsException extends Exception implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.client.deployment
- Class org.apache.flink.client.deployment.ClusterDeploymentException extends FlinkException implements Serializable
  
  serialVersionUID:
  
  -4327724979766139208L
- Class org.apache.flink.client.deployment.ClusterRetrieveException extends FlinkException implements Serializable
  
  serialVersionUID:
  
  7718062507419172318L
Package org.apache.flink.client.program
- Class org.apache.flink.client.program.OptimizerPlanEnvironment.ProgramAbortException extends Error implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.client.program.ProgramInvocationException extends Exception implements Serializable
  
  serialVersionUID:
  
  -2417524218857151612L
- Class org.apache.flink.client.program.ProgramMissingJobException extends FlinkException implements Serializable
  
  serialVersionUID:
  
  -1964276369605091101L
- Class org.apache.flink.client.program.ProgramParametrizationException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  909054589029890262L
Package org.apache.flink.configuration
- Class org.apache.flink.configuration.Configuration extends ExecutionConfig.GlobalJobParameters implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - confData
```
HashMap<K,V> confData
```
      Stores the concrete key/value pairs of this configuration object.
- Class org.apache.flink.configuration.DelegatingConfiguration extends Configuration implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - backingConfig
```
Configuration backingConfig
```
    - prefix
```
String prefix
```
- Class org.apache.flink.configuration.IllegalConfigurationException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  695506964810499989L
- Class org.apache.flink.configuration.MemorySize extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - bytes
```
long bytes
```
      The memory size, in bytes.
- Class org.apache.flink.configuration.UnmodifiableConfiguration extends Configuration implements Serializable
  
  serialVersionUID:
  
  -8151292629158972280L
Package org.apache.flink.contrib.streaming.state
- Class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory extends Object implements Serializable
  - Serialized Fields
    - configuredOptions
```
Map<K,V> configuredOptions
```
- Class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions extends Object implements Serializable
- Class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions extends Object implements Serializable
  - Serialized Fields
    - properties
```
Set<E> properties
```
- Class org.apache.flink.contrib.streaming.state.RocksDBStateBackend extends AbstractStateBackend implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - checkpointStreamBackend
```
StateBackend checkpointStreamBackend
```
      The state backend that we use for creating checkpoint streams.
    - localRocksDbDirectories
```
File[] localRocksDbDirectories
```
      Base paths for RocksDB directory, as configured. Null if not yet set, in which case the configuration values will be used. The configuration defaults to the TaskManager's temp directories.
    - predefinedOptions
```
PredefinedOptions predefinedOptions
```
      The pre-configured option settings.
    - optionsFactory
```
OptionsFactory optionsFactory
```
      The options factory to create the RocksDB options in the cluster.
    - enableIncrementalCheckpointing
```
TernaryBoolean enableIncrementalCheckpointing
```
      This determines if incremental checkpointing is enabled.
    - numberOfTransferingThreads
```
int numberOfTransferingThreads
```
      Thread number used to transfer (download and upload) state, default value: 1.
    - enableTtlCompactionFilter
```
TernaryBoolean enableTtlCompactionFilter
```
      This determines if compaction filter to cleanup state with TTL is enabled.
      Note: User can still decide in state TTL configuration in state descriptor whether the filter is active for particular state or not.
    - priorityQueueStateType
```
RocksDBStateBackend.PriorityQueueStateType priorityQueueStateType
```
      This determines the type of priority queue state.
    - defaultMetricOptions
```
RocksDBNativeMetricOptions defaultMetricOptions
```
      The default rocksdb metrics options.
Package org.apache.flink.core.fs
- Class org.apache.flink.core.fs.FileInputSplit extends LocatableInputSplit implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - file
```
Path file
```
      The path of the file this file split refers to.
    - start
```
long start
```
      The position of the first byte in the file to process.
    - length
```
long length
```
      The number of bytes in the file to process.
- Class org.apache.flink.core.fs.LimitedConnectionsFileSystem.StreamTimeoutException extends IOException implements Serializable
  
  serialVersionUID:
  
  -8790922066795901928L
- Class org.apache.flink.core.fs.Path extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - uri
```
URI uri
```
      The internal representation of the path, a hierarchical URI.
- Class org.apache.flink.core.fs.UnsupportedFileSystemSchemeException extends IOException implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.core.io
- Class org.apache.flink.core.io.GenericInputSplit extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partitionNumber
```
int partitionNumber
```
      The number of this split.
    - totalNumberOfPartitions
```
int totalNumberOfPartitions
```
      The total number of partitions
- Class org.apache.flink.core.io.LocatableInputSplit extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - splitNumber
```
int splitNumber
```
      The number of the split.
    - hostnames
```
String[] hostnames
```
      The names of the hosts storing the data this input split refers to.
- Class org.apache.flink.core.io.VersionMismatchException extends IOException implements Serializable
  
  serialVersionUID:
  
  7024258967585372438L
Package org.apache.flink.core.memory
- Class org.apache.flink.core.memory.DataInputDeserializer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - buffer
```
byte[] buffer
```
    - end
```
int end
```
    - position
```
int position
```
Package org.apache.flink.examples.java.clustering
- Class org.apache.flink.examples.java.clustering.KMeans.Centroid extends KMeans.Point implements Serializable
  - Serialized Fields
    - id
```
int id
```
- Class org.apache.flink.examples.java.clustering.KMeans.CentroidAccumulator extends Object implements Serializable
- Class org.apache.flink.examples.java.clustering.KMeans.CentroidAverager extends Object implements Serializable
- Class org.apache.flink.examples.java.clustering.KMeans.CountAppender extends Object implements Serializable
- Class org.apache.flink.examples.java.clustering.KMeans.Point extends Object implements Serializable
  - Serialized Fields
    - x
```
double x
```
    - y
```
double y
```
- Class org.apache.flink.examples.java.clustering.KMeans.SelectNearestCenter extends RichMapFunction<KMeans.Point,Tuple2<Integer,KMeans.Point>> implements Serializable
  - Serialized Fields
    - centroids
```
Collection<E> centroids
```
Package org.apache.flink.examples.java.distcp
- Class org.apache.flink.examples.java.distcp.FileCopyTask extends Object implements Serializable
  
  serialVersionUID:
  
  -8760082278978316032L
  - Serialized Fields
    - path
```
Path path
```
    - relativePath
```
String relativePath
```
- Class org.apache.flink.examples.java.distcp.FileCopyTaskInputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  -644394866425221151L
  - Serialized Fields
    - tasks
```
List<E> tasks
```
    - curInputSplit
```
FileCopyTaskInputSplit curInputSplit
```
- Class org.apache.flink.examples.java.distcp.FileCopyTaskInputSplit extends Object implements Serializable
  
  serialVersionUID:
  
  -7621656017747660450L
  - Serialized Fields
    - task
```
FileCopyTask task
```
    - splitNumber
```
int splitNumber
```
Package org.apache.flink.examples.java.graph
- Class org.apache.flink.examples.java.graph.ConnectedComponents.ComponentIdFilter extends Object implements Serializable
- Class org.apache.flink.examples.java.graph.ConnectedComponents.DuplicateValue extends Object implements Serializable
- Class org.apache.flink.examples.java.graph.ConnectedComponents.NeighborWithComponentIDJoin extends Object implements Serializable
- Class org.apache.flink.examples.java.graph.ConnectedComponents.UndirectEdge extends Object implements Serializable
  - Serialized Fields
    - invertedEdge
```
Tuple2<T0,T1> invertedEdge
```
- Class org.apache.flink.examples.java.graph.EnumTriangles.TupleEdgeConverter extends Object implements Serializable
  - Serialized Fields
    - outEdge
```
EnumTrianglesDataTypes.Edge outEdge
```
- Class org.apache.flink.examples.java.graph.PageRank.BuildOutgoingEdgeList extends Object implements Serializable
  - Serialized Fields
    - neighbors
```
ArrayList<E> neighbors
```
- Class org.apache.flink.examples.java.graph.PageRank.Dampener extends Object implements Serializable
  - Serialized Fields
    - dampening
```
double dampening
```
    - randomJump
```
double randomJump
```
- Class org.apache.flink.examples.java.graph.PageRank.EpsilonFilter extends Object implements Serializable
- Class org.apache.flink.examples.java.graph.PageRank.JoinVertexWithEdgesMatch extends Object implements Serializable
- Class org.apache.flink.examples.java.graph.PageRank.RankAssigner extends Object implements Serializable
  - Serialized Fields
    - outPageWithRank
```
Tuple2<T0,T1> outPageWithRank
```
Package org.apache.flink.examples.java.graph.util
- Class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Edge extends Tuple2<Integer,Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees extends Tuple4<Integer,Integer,Integer,Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Triad extends Tuple3<Integer,Integer,Integer> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.examples.java.misc
- Class org.apache.flink.examples.java.misc.PiEstimation extends Object implements Serializable
- Class org.apache.flink.examples.java.misc.PiEstimation.Sampler extends Object implements Serializable
- Class org.apache.flink.examples.java.misc.PiEstimation.SumReducer extends Object implements Serializable
Package org.apache.flink.examples.java.ml
- Class org.apache.flink.examples.java.ml.LinearRegression.Data extends Object implements Serializable
  - Serialized Fields
    - x
```
double x
```
    - y
```
double y
```
- Class org.apache.flink.examples.java.ml.LinearRegression.Params extends Object implements Serializable
  - Serialized Fields
    - theta0
```
double theta0
```
    - theta1
```
double theta1
```
- Class org.apache.flink.examples.java.ml.LinearRegression.SubUpdate extends RichMapFunction<LinearRegression.Data,Tuple2<LinearRegression.Params,Integer>> implements Serializable
  - Serialized Fields
    - parameters
```
Collection<E> parameters
```
    - parameter
```
LinearRegression.Params parameter
```
    - count
```
int count
```
- Class org.apache.flink.examples.java.ml.LinearRegression.Update extends Object implements Serializable
- Class org.apache.flink.examples.java.ml.LinearRegression.UpdateAccumulator extends Object implements Serializable
Package org.apache.flink.examples.java.relational
- Class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.EmptyFieldFilter extends RichFilterFunction<EmptyFieldsCountAccumulator.StringTriple> implements Serializable
  - Serialized Fields
    - emptyFieldCounter
```
EmptyFieldsCountAccumulator.VectorAccumulator emptyFieldCounter
```
- Class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.StringTriple extends Tuple3<String,String,String> implements Serializable
- Class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.VectorAccumulator extends Object implements Serializable
  - Serialized Fields
    - resultVector
```
ArrayList<E> resultVector
```
      Stores the accumulated vector components.
- Class org.apache.flink.examples.java.relational.TPCHQuery3.Customer extends Tuple2<Long,String> implements Serializable
- Class org.apache.flink.examples.java.relational.TPCHQuery3.Lineitem extends Tuple4<Long,Double,Double,String> implements Serializable
- Class org.apache.flink.examples.java.relational.TPCHQuery3.Order extends Tuple4<Long,Long,String,Long> implements Serializable
- Class org.apache.flink.examples.java.relational.TPCHQuery3.ShippingPriorityItem extends Tuple4<Long,Double,String,Long> implements Serializable
- Class org.apache.flink.examples.java.relational.WebLogAnalysis.AntiJoinVisits extends Object implements Serializable
- Class org.apache.flink.examples.java.relational.WebLogAnalysis.FilterByRank extends Object implements Serializable
- Class org.apache.flink.examples.java.relational.WebLogAnalysis.FilterDocByKeyWords extends Object implements Serializable
- Class org.apache.flink.examples.java.relational.WebLogAnalysis.FilterVisitsByDate extends Object implements Serializable
Package org.apache.flink.examples.java.wordcount
- Class org.apache.flink.examples.java.wordcount.WordCount.Tokenizer extends Object implements Serializable
- Class org.apache.flink.examples.java.wordcount.WordCountPojo.Tokenizer extends Object implements Serializable
Package org.apache.flink.formats.avro
- Class org.apache.flink.formats.avro.AvroDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  -6766681879020862312L
  - Serialized Fields
    - recordClazz
```
Class<T> recordClazz
```
      Class to deserialize to.
    - schemaString
```
String schemaString
```
      Schema in case of GenericRecord for serialization purpose.
- Class org.apache.flink.formats.avro.AvroInputFormat extends FileInputFormat<E> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - avroValueType
```
Class<T> avroValueType
```
    - reuseAvroValue
```
boolean reuseAvroValue
```
    - lastSync
```
long lastSync
```
- Class org.apache.flink.formats.avro.AvroOutputFormat extends FileOutputFormat<E> implements Serializable
  
  serialVersionUID:
  
  1L
  - 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
    - avroValueType
```
Class<T> avroValueType
```
- Class org.apache.flink.formats.avro.AvroRowDeserializationSchema extends AbstractDeserializationSchema<Row> implements Serializable
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream inputStream)
                 throws ClassNotFoundException,
                        IOException
```
      Throws:
      
      ClassNotFoundException
      
      IOException
    - writeObject
```
private void writeObject(ObjectOutputStream outputStream)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - recordClazz
```
Class<T> recordClazz
```
      Avro record class for deserialization. Might be null if record class is not available.
    - schemaString
```
String schemaString
```
      Schema string for deserialization.
- Class org.apache.flink.formats.avro.AvroRowSerializationSchema extends Object implements Serializable
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream inputStream)
                 throws ClassNotFoundException,
                        IOException
```
      Throws:
      
      ClassNotFoundException
      
      IOException
    - writeObject
```
private void writeObject(ObjectOutputStream outputStream)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - recordClazz
```
Class<T> recordClazz
```
      Avro record class for serialization. Might be null if record class is not available.
    - schemaString
```
String schemaString
```
      Schema string for deserialization.
- Class org.apache.flink.formats.avro.RegistryAvroDeserializationSchema extends AvroDeserializationSchema<T> implements Serializable
  
  serialVersionUID:
  
  -884738268437806062L
  - Serialized Fields
    - schemaCoderProvider
```
SchemaCoder.SchemaCoderProvider schemaCoderProvider
```
      Provider for schema coder. Used for initializing in each task.
Package org.apache.flink.formats.avro.registry.confluent
- Class org.apache.flink.formats.avro.registry.confluent.ConfluentRegistryAvroDeserializationSchema extends RegistryAvroDeserializationSchema<T> implements Serializable
  
  serialVersionUID:
  
  -1671641202177852775L
Package org.apache.flink.formats.avro.typeutils
- Class org.apache.flink.formats.avro.typeutils.AvroSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - type
```
Class<T> type
```
    - schema
```
org.apache.flink.formats.avro.typeutils.SerializableAvroSchema schema
```
    - previousSchema
```
org.apache.flink.formats.avro.typeutils.SerializableAvroSchema previousSchema
```
- Class org.apache.flink.formats.avro.typeutils.AvroTypeInfo extends PojoTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo extends TypeInformation<org.apache.avro.generic.GenericRecord> implements Serializable
  
  serialVersionUID:
  
  4141977586453820650L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream ois)
                 throws ClassNotFoundException,
                        IOException
```
      Throws:
      
      ClassNotFoundException
      
      IOException
    - writeObject
```
private void writeObject(ObjectOutputStream oos)
                  throws IOException
```
      Throws:
      
      IOException
Package org.apache.flink.formats.avro.utils
- Class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.AvroSchemaSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.avro.Schema> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.formats.csv
- Class org.apache.flink.formats.csv.CsvRowDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  2135553495874539201L
  - Serialized Fields
    - typeInfo
```
TypeInformation<T> typeInfo
```
      Type information describing the result type.
    - runtimeConverter
```
org.apache.flink.formats.csv.CsvRowDeserializationSchema.RuntimeConverter runtimeConverter
```
      Runtime instance that performs the actual work.
    - csvSchema
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema
```
      Schema describing the input CSV data.
    - objectReader
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectReader objectReader
```
      Object reader used to read rows. It is configured by CsvSchema.
    - ignoreParseErrors
```
boolean ignoreParseErrors
```
      Flag indicating whether to ignore invalid fields/rows (default: throw an exception).
- Class org.apache.flink.formats.csv.CsvRowSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  2098447220136965L
  - Serialized Fields
    - typeInfo
```
RowTypeInfo typeInfo
```
      Type information describing the input CSV data.
    - runtimeConverter
```
org.apache.flink.formats.csv.CsvRowSerializationSchema.RuntimeConverter runtimeConverter
```
      Runtime instance that performs the actual work.
    - csvMapper
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvMapper csvMapper
```
      CsvMapper used to write JsonNode into bytes.
    - csvSchema
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema
```
      Schema describing the input CSV data.
    - objectWriter
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectWriter objectWriter
```
      Object writer used to write rows. It is configured by CsvSchema.
Package org.apache.flink.formats.json
- Class org.apache.flink.formats.json.JsonNodeDeserializationSchema extends AbstractDeserializationSchema<org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode> implements Serializable
  
  serialVersionUID:
  
  -1699854177598621044L
  - Serialized Fields
    - mapper
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper mapper
```
- Class org.apache.flink.formats.json.JsonRowDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  -228294330688809195L
  - Serialized Fields
    - typeInfo
```
TypeInformation<T> typeInfo
```
      Type information describing the result type.
    - objectMapper
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper objectMapper
```
      Object mapper for parsing the JSON.
    - failOnMissingField
```
boolean failOnMissingField
```
      Flag indicating whether to fail on a missing field.
- Class org.apache.flink.formats.json.JsonRowSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  -2885556750743978636L
  - Serialized Fields
    - typeInfo
```
TypeInformation<T> typeInfo
```
      Type information describing the input type.
    - mapper
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper mapper
```
      Object mapper that is used to create output JSON objects.
    - timeFormat
```
SimpleDateFormat timeFormat
```
      Formatter for RFC 3339-compliant string representation of a time value (with UTC timezone, without milliseconds).
    - timeFormatWithMillis
```
SimpleDateFormat timeFormatWithMillis
```
      Formatter for RFC 3339-compliant string representation of a time value (with UTC timezone).
    - timestampFormat
```
SimpleDateFormat timestampFormat
```
      Formatter for RFC 3339-compliant string representation of a timestamp value (with UTC timezone).
Package org.apache.flink.formats.parquet
- Class org.apache.flink.formats.parquet.ParquetWriterFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - writerBuilder
```
ParquetBuilder<T> writerBuilder
```
      The builder to construct the ParquetWriter.
Package org.apache.flink.formats.sequencefile
- Class org.apache.flink.formats.sequencefile.SequenceFileWriterFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - serializableHadoopConfig
```
org.apache.flink.formats.sequencefile.SerializableHadoopConfiguration serializableHadoopConfig
```
    - keyClass
```
Class<T> keyClass
```
    - valueClass
```
Class<T> valueClass
```
    - compressionCodecName
```
String compressionCodecName
```
    - compressionType
```
org.apache.hadoop.io.SequenceFile.CompressionType compressionType
```
Package org.apache.flink.graph
- Class org.apache.flink.graph.AnalyticHelper extends RichOutputFormat<T> implements Serializable
  - Serialized Fields
    - id
```
String id
```
- Class org.apache.flink.graph.Edge extends Tuple3<K,K,V> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.Triplet extends Tuple5<K,K,VV,VV,EV> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.Vertex extends Tuple2<K,V> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.graph.asm.dataset
- Class org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum extends Object implements Serializable
  - Serialized Fields
    - count
```
long count
```
    - checksum
```
long checksum
```
Package org.apache.flink.graph.asm.degree.annotate
- Class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.DegreeCount extends Object implements Serializable
- Class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.JoinEdgeDegreeWithVertexDegree extends Object implements Serializable
  - Serialized Fields
    - valueAndDegrees
```
Tuple3<T0,T1,T2> valueAndDegrees
```
    - output
```
Edge<K,V> output
```
- Class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.JoinEdgeWithVertexDegree extends Object implements Serializable
  - Serialized Fields
    - valueAndDegree
```
Tuple2<T0,T1> valueAndDegree
```
    - output
```
Edge<K,V> output
```
- Class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.JoinVertexWithVertexDegree extends Object implements Serializable
  - Serialized Fields
    - zero
```
LongValue zero
```
    - output
```
Vertex<K,V> output
```
- Class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.MapEdgeToSourceId extends Object implements Serializable
  - Serialized Fields
    - output
```
Vertex<K,V> output
```
- Class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.MapEdgeToTargetId extends Object implements Serializable
  - Serialized Fields
    - output
```
Vertex<K,V> output
```
Package org.apache.flink.graph.asm.degree.annotate.directed
- Class org.apache.flink.graph.asm.degree.annotate.directed.VertexDegrees.Degrees extends Tuple3<LongValue,LongValue,LongValue> implements Serializable
  - Serialized Fields
    - hasher
```
MurmurHash hasher
```
Package org.apache.flink.graph.asm.result
- Class org.apache.flink.graph.asm.result.BinaryResult.MirrorResult extends Object implements Serializable
- Class org.apache.flink.graph.asm.result.BinaryResultBase extends ResultBase implements Serializable
  - Serialized Fields
    - vertexId0
```
Object vertexId0
```
    - vertexId1
```
Object vertexId1
```
- Class org.apache.flink.graph.asm.result.TertiaryResultBase extends ResultBase implements Serializable
  - Serialized Fields
    - vertexId0
```
Object vertexId0
```
    - vertexId1
```
Object vertexId1
```
    - vertexId2
```
Object vertexId2
```
- Class org.apache.flink.graph.asm.result.UnaryResultBase extends ResultBase implements Serializable
  - Serialized Fields
    - vertexId0
```
Object vertexId0
```
Package org.apache.flink.graph.asm.translate
- Class org.apache.flink.graph.asm.translate.RichTranslateFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.graph.asm.translate.translators
- Class org.apache.flink.graph.asm.translate.translators.LongToLongValue extends Object implements Serializable
- Class org.apache.flink.graph.asm.translate.translators.LongValueAddOffset extends Object implements Serializable
  - Serialized Fields
    - offset
```
long offset
```
- Class org.apache.flink.graph.asm.translate.translators.LongValueToSignedIntValue extends Object implements Serializable
- Class org.apache.flink.graph.asm.translate.translators.LongValueToStringValue extends Object implements Serializable
- Class org.apache.flink.graph.asm.translate.translators.LongValueToUnsignedIntValue extends Object implements Serializable
- Class org.apache.flink.graph.asm.translate.translators.ToNullValue extends Object implements Serializable
Package org.apache.flink.graph.bipartite
- Class org.apache.flink.graph.bipartite.BipartiteEdge extends Tuple3<KT,KB,EV> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.bipartite.Projection extends Tuple6<KC,VVC,VV,VV,EV,EV> implements Serializable
Package org.apache.flink.graph.drivers.transform
- Class org.apache.flink.graph.drivers.transform.LongValueWithProperHashCode extends LongValue implements Serializable
- Class org.apache.flink.graph.drivers.transform.LongValueWithProperHashCode.LongValueWithProperHashCodeSerializer extends TypeSerializerSingleton<LongValueWithProperHashCode> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.drivers.transform.LongValueWithProperHashCode.LongValueWithProperHashCodeTypeInfo extends TypeInformation<LongValueWithProperHashCode> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.graph.examples
- Class org.apache.flink.graph.examples.EuclideanGraphWeighing.Point extends Object implements Serializable
  - Serialized Fields
    - x
```
double x
```
    - y
```
double y
```
- Class org.apache.flink.graph.examples.IncrementalSSSP.InvalidateMessenger extends ScatterFunction<Long,Double,Double,Double> implements Serializable
  - Serialized Fields
    - edgeToBeRemoved
```
Edge<K,V> edgeToBeRemoved
```
- Class org.apache.flink.graph.examples.IncrementalSSSP.VertexDistanceUpdater extends GatherFunction<Long,Double,Double> implements Serializable
- Class org.apache.flink.graph.examples.PageRank.RankMessenger extends ScatterFunction<K,Double,Double,Double> implements Serializable
- Class org.apache.flink.graph.examples.PageRank.VertexRankUpdater extends GatherFunction<K,Double,Double> implements Serializable
  - Serialized Fields
    - beta
```
double beta
```
- Class org.apache.flink.graph.examples.PregelSSSP.SSSPCombiner extends MessageCombiner<Long,Double> implements Serializable
- Class org.apache.flink.graph.examples.PregelSSSP.SSSPComputeFunction extends ComputeFunction<Long,Double,Double,Double> implements Serializable
  - Serialized Fields
    - srcId
```
long srcId
```
Package org.apache.flink.graph.generator
- Class org.apache.flink.graph.generator.CirculantGraph.OffsetRange extends Object implements Serializable
  - Serialized Fields
    - offset
```
long offset
```
    - length
```
long length
```
Package org.apache.flink.graph.gsa
- Class org.apache.flink.graph.gsa.ApplyFunction extends Object implements Serializable
  - Serialized Fields
    - numberOfVertices
```
long numberOfVertices
```
    - runtimeContext
```
IterationRuntimeContext runtimeContext
```
    - out
```
Collector<T> out
```
    - outVal
```
Vertex<K,V> outVal
```
- Class org.apache.flink.graph.gsa.GatherFunction extends Object implements Serializable
  - Serialized Fields
    - numberOfVertices
```
long numberOfVertices
```
    - runtimeContext
```
IterationRuntimeContext runtimeContext
```
- Class org.apache.flink.graph.gsa.Neighbor extends Tuple2<VV,EV> implements Serializable
- Class org.apache.flink.graph.gsa.SumFunction extends Object implements Serializable
  - Serialized Fields
    - numberOfVertices
```
long numberOfVertices
```
    - runtimeContext
```
IterationRuntimeContext runtimeContext
```
Package org.apache.flink.graph.library
- Class org.apache.flink.graph.library.ConnectedComponents.CCMessenger extends ScatterFunction<K,VV extends Comparable<VV>,VV extends Comparable<VV>,NullValue> implements Serializable
  - Serialized Fields
    - typeInformation
```
TypeInformation<T> typeInformation
```
- Class org.apache.flink.graph.library.ConnectedComponents.CCUpdater extends GatherFunction<K,VV extends Comparable<VV>,VV extends Comparable<VV>> implements Serializable
- Class org.apache.flink.graph.library.LabelPropagation.SendNewLabelToNeighbors extends ScatterFunction<K,VV extends Comparable<VV>,VV extends Comparable<VV>,NullValue> implements Serializable
  - Serialized Fields
    - typeInformation
```
TypeInformation<T> typeInformation
```
- Class org.apache.flink.graph.library.LabelPropagation.UpdateVertexLabel extends GatherFunction<K,VV extends Comparable<VV>,VV extends Comparable<VV>> implements Serializable
- Class org.apache.flink.graph.library.SingleSourceShortestPaths.MinDistanceMessenger extends ScatterFunction<K,Double,Double,Double> implements Serializable
- Class org.apache.flink.graph.library.SingleSourceShortestPaths.VertexDistanceUpdater extends GatherFunction<K,Double,Double> implements Serializable
- Class org.apache.flink.graph.library.Summarization.EdgeValue extends Tuple2<EV,Long> implements Serializable
- Class org.apache.flink.graph.library.Summarization.VertexGroupItem extends Tuple4<K,K,Either<VGV,NullValue>,Long> implements Serializable
  - Serialized Fields
    - nullValue
```
Either.Right<L,R> nullValue
```
- Class org.apache.flink.graph.library.Summarization.VertexValue extends Tuple2<VV,Long> implements Serializable
- Class org.apache.flink.graph.library.Summarization.VertexWithRepresentative extends Tuple2<K,K> implements Serializable
- Class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees extends Tuple4<K,K,Integer,Integer> implements Serializable
- Class org.apache.flink.graph.library.TriangleEnumerator.Triad extends Tuple3<K,K,K> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.graph.library.clustering.directed
- Class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient.Result extends UnaryResultBase<T> implements Serializable
  - Serialized Fields
    - degree
```
LongValue degree
```
    - triangleCount
```
LongValue triangleCount
```
- Class org.apache.flink.graph.library.clustering.directed.TriangleListing.Result extends TertiaryResultBase<T> implements Serializable
  - Serialized Fields
    - bitmask
```
ByteValue bitmask
```
Package org.apache.flink.graph.library.clustering.undirected
- Class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient.Result extends UnaryResultBase<T> implements Serializable
  - Serialized Fields
    - degree
```
LongValue degree
```
    - triangleCount
```
LongValue triangleCount
```
- Class org.apache.flink.graph.library.clustering.undirected.TriangleListing.Result extends TertiaryResultBase<T> implements Serializable
Package org.apache.flink.graph.library.linkanalysis
- Class org.apache.flink.graph.library.linkanalysis.Functions.SumScore extends Object implements Serializable
- Class org.apache.flink.graph.library.linkanalysis.HITS.Result extends UnaryResultBase<T> implements Serializable
  - Serialized Fields
    - hubScore
```
DoubleValue hubScore
```
    - authorityScore
```
DoubleValue authorityScore
```
- Class org.apache.flink.graph.library.linkanalysis.PageRank.Result extends UnaryResultBase<T> implements Serializable
  - Serialized Fields
    - pageRankScore
```
DoubleValue pageRankScore
```
Package org.apache.flink.graph.library.similarity
- Class org.apache.flink.graph.library.similarity.AdamicAdar.Result extends BinaryResultBase<T> implements Serializable
  - Serialized Fields
    - adamicAdarScore
```
FloatValue adamicAdarScore
```
- Class org.apache.flink.graph.library.similarity.JaccardIndex.Result extends BinaryResultBase<T> implements Serializable
  - Serialized Fields
    - sharedNeighborCount
```
IntValue sharedNeighborCount
```
    - distinctNeighborCount
```
IntValue distinctNeighborCount
```
Package org.apache.flink.graph.pregel
- Class org.apache.flink.graph.pregel.ComputeFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - outVertex
```
Vertex<K,V> outVertex
```
    - outMsg
```
Tuple2<T0,T1> outMsg
```
    - runtimeContext
```
IterationRuntimeContext runtimeContext
```
    - edges
```
Iterator<E> edges
```
    - out
```
Collector<T> out
```
    - edgeIterator
```
org.apache.flink.graph.pregel.ComputeFunction.EdgesIterator<K,EV> edgeIterator
```
    - edgesUsed
```
boolean edgesUsed
```
    - setNewVertexValueCalled
```
boolean setNewVertexValueCalled
```
- Class org.apache.flink.graph.pregel.MessageCombiner extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - out
```
Collector<T> out
```
    - outValue
```
Tuple2<T0,T1> outValue
```
- Class org.apache.flink.graph.pregel.MessageIterator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - first
```
Object first
```
Package org.apache.flink.graph.spargel
- Class org.apache.flink.graph.spargel.GatherFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - numberOfVertices
```
long numberOfVertices
```
    - optDegrees
```
boolean optDegrees
```
    - runtimeContext
```
IterationRuntimeContext runtimeContext
```
    - out
```
Collector<T> out
```
    - outWithDegrees
```
Collector<T> outWithDegrees
```
    - outVal
```
Vertex<K,V> outVal
```
    - outValWithDegrees
```
Vertex<K,V> outValWithDegrees
```
    - inDegree
```
long inDegree
```
    - outDegree
```
long outDegree
```
    - setNewVertexValueCalled
```
boolean setNewVertexValueCalled
```
- Class org.apache.flink.graph.spargel.MessageIterator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.spargel.ScatterFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - numberOfVertices
```
long numberOfVertices
```
    - direction
```
EdgeDirection direction
```
    - outValue
```
Tuple2<T0,T1> outValue
```
    - runtimeContext
```
IterationRuntimeContext runtimeContext
```
    - edges
```
Iterator<E> edges
```
    - out
```
Collector<T> out
```
    - vertexId
```
Object vertexId
```
    - edgeIterator
```
org.apache.flink.graph.spargel.ScatterFunction.EdgesIterator<K,EV> edgeIterator
```
    - edgesUsed
```
boolean edgesUsed
```
    - inDegree
```
long inDegree
```
    - outDegree
```
long outDegree
```
Package org.apache.flink.graph.types.valuearray
- Class org.apache.flink.graph.types.valuearray.ByteValueArray extends Object implements Serializable
  - Serialized Fields
    - isBounded
```
boolean isBounded
```
    - data
```
byte[] data
```
    - position
```
int position
```
    - hash
```
MurmurHash hash
```
    - hashValue
```
IntValue hashValue
```
    - iterator
```
org.apache.flink.graph.types.valuearray.ByteValueArray.ReadIterator iterator
```
- Class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator extends TypeComparator<ByteValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
ByteValueArray reference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.graph.types.valuearray.ByteValueArraySerializer extends TypeSerializerSingleton<ByteValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.types.valuearray.CharValueArray extends Object implements Serializable
  - Serialized Fields
    - isBounded
```
boolean isBounded
```
    - data
```
char[] data
```
    - position
```
int position
```
    - hash
```
MurmurHash hash
```
    - hashValue
```
IntValue hashValue
```
    - iterator
```
org.apache.flink.graph.types.valuearray.CharValueArray.ReadIterator iterator
```
- Class org.apache.flink.graph.types.valuearray.CharValueArrayComparator extends TypeComparator<CharValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
CharValueArray reference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.graph.types.valuearray.CharValueArraySerializer extends TypeSerializerSingleton<CharValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.types.valuearray.DoubleValueArray extends Object implements Serializable
  - Serialized Fields
    - isBounded
```
boolean isBounded
```
    - data
```
double[] data
```
    - position
```
int position
```
    - hash
```
MurmurHash hash
```
    - hashValue
```
IntValue hashValue
```
    - iterator
```
org.apache.flink.graph.types.valuearray.DoubleValueArray.ReadIterator iterator
```
- Class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator extends TypeComparator<DoubleValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
DoubleValueArray reference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.graph.types.valuearray.DoubleValueArraySerializer extends TypeSerializerSingleton<DoubleValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.types.valuearray.FloatValueArray extends Object implements Serializable
  - Serialized Fields
    - isBounded
```
boolean isBounded
```
    - data
```
float[] data
```
    - position
```
int position
```
    - hash
```
MurmurHash hash
```
    - hashValue
```
IntValue hashValue
```
    - iterator
```
org.apache.flink.graph.types.valuearray.FloatValueArray.ReadIterator iterator
```
- Class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator extends TypeComparator<FloatValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
FloatValueArray reference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.graph.types.valuearray.FloatValueArraySerializer extends TypeSerializerSingleton<FloatValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.types.valuearray.IntValueArray extends Object implements Serializable
  - Serialized Fields
    - isBounded
```
boolean isBounded
```
    - data
```
int[] data
```
    - position
```
int position
```
    - hash
```
MurmurHash hash
```
    - hashValue
```
IntValue hashValue
```
    - iterator
```
org.apache.flink.graph.types.valuearray.IntValueArray.ReadIterator iterator
```
- Class org.apache.flink.graph.types.valuearray.IntValueArrayComparator extends TypeComparator<IntValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
IntValueArray reference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.graph.types.valuearray.IntValueArraySerializer extends TypeSerializerSingleton<IntValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.types.valuearray.LongValueArray extends Object implements Serializable
  - Serialized Fields
    - isBounded
```
boolean isBounded
```
    - data
```
long[] data
```
    - position
```
int position
```
    - hash
```
MurmurHash hash
```
    - hashValue
```
IntValue hashValue
```
    - iterator
```
org.apache.flink.graph.types.valuearray.LongValueArray.ReadIterator iterator
```
- Class org.apache.flink.graph.types.valuearray.LongValueArrayComparator extends TypeComparator<LongValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
LongValueArray reference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.graph.types.valuearray.LongValueArraySerializer extends TypeSerializerSingleton<LongValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.types.valuearray.NullValueArray extends Object implements Serializable
  - Serialized Fields
    - position
```
int position
```
    - hashValue
```
IntValue hashValue
```
    - iterator
```
org.apache.flink.graph.types.valuearray.NullValueArray.ReadIterator iterator
```
- Class org.apache.flink.graph.types.valuearray.NullValueArrayComparator extends TypeComparator<NullValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
NullValueArray reference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.graph.types.valuearray.NullValueArraySerializer extends TypeSerializerSingleton<NullValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.types.valuearray.ShortValueArray extends Object implements Serializable
  - Serialized Fields
    - isBounded
```
boolean isBounded
```
    - data
```
short[] data
```
    - position
```
int position
```
    - hash
```
MurmurHash hash
```
    - hashValue
```
IntValue hashValue
```
    - iterator
```
org.apache.flink.graph.types.valuearray.ShortValueArray.ReadIterator iterator
```
- Class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator extends TypeComparator<ShortValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
ShortValueArray reference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.graph.types.valuearray.ShortValueArraySerializer extends TypeSerializerSingleton<ShortValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.types.valuearray.StringValueArray extends Object implements Serializable
  - Serialized Fields
    - isBounded
```
boolean isBounded
```
    - boundedLength
```
int boundedLength
```
    - data
```
byte[] data
```
    - length
```
int length
```
    - position
```
int position
```
    - hash
```
MurmurHash hash
```
    - hashValue
```
IntValue hashValue
```
    - iterator
```
org.apache.flink.graph.types.valuearray.StringValueArray.ReadIterator iterator
```
- Class org.apache.flink.graph.types.valuearray.StringValueArrayComparator extends TypeComparator<StringValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
StringValueArray reference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.graph.types.valuearray.StringValueArraySerializer extends TypeSerializerSingleton<StringValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo extends TypeInformation<ValueArray<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - valueType
```
TypeInformation<T> valueType
```
    - type
```
Class<T> type
```
Package org.apache.flink.graph.utils
- Class org.apache.flink.graph.utils.EdgeToTuple2Map extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - output
```
Tuple2<T0,T1> output
```
- Class org.apache.flink.graph.utils.EdgeToTuple3Map extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.utils.GraphUtils.AddLongValue extends Object implements Serializable
- Class org.apache.flink.graph.utils.GraphUtils.IdentityMapper extends Object implements Serializable
- Class org.apache.flink.graph.utils.GraphUtils.MapTo extends Object implements Serializable
  - Serialized Fields
    - value
```
Object value
```
- Class org.apache.flink.graph.utils.GraphUtils.NonForwardingIdentityMapper extends Object implements Serializable
- Class org.apache.flink.graph.utils.MurmurHash extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - seed
```
int seed
```
    - count
```
int count
```
    - hash
```
int hash
```
- Class org.apache.flink.graph.utils.Tuple2ToEdgeMap extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - edge
```
Edge<K,V> edge
```
- Class org.apache.flink.graph.utils.Tuple2ToVertexMap extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - vertex
```
Vertex<K,V> vertex
```
- Class org.apache.flink.graph.utils.Tuple3ToEdgeMap extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - edge
```
Edge<K,V> edge
```
- Class org.apache.flink.graph.utils.VertexToTuple2Map extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.graph.validation
- Class org.apache.flink.graph.validation.GraphValidator extends Object implements Serializable
- Class org.apache.flink.graph.validation.InvalidVertexIdsValidator extends GraphValidator<K,VV,EV> implements Serializable
Package org.apache.flink.hadoopcompatibility.mapred
- Class org.apache.flink.hadoopcompatibility.mapred.HadoopMapFunction extends RichFlatMapFunction<Tuple2<KEYIN,VALUEIN>,Tuple2<KEYOUT,VALUEOUT>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Custom serialization methods.
      
      Throws:
      
      IOException
      
      See Also:
      
      http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html
- Class org.apache.flink.hadoopcompatibility.mapred.HadoopReduceCombineFunction extends RichGroupReduceFunction<Tuple2<KEYIN,VALUEIN>,Tuple2<KEYOUT,VALUEOUT>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Custom serialization methods.
      
      Throws:
      
      IOException
      
      See Also:
      
      http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html
- Class org.apache.flink.hadoopcompatibility.mapred.HadoopReduceFunction extends RichGroupReduceFunction<Tuple2<KEYIN,VALUEIN>,Tuple2<KEYOUT,VALUEOUT>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Custom serialization methods.
      
      Throws:
      
      IOException
      
      See Also:
      
      http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html
Package org.apache.flink.hadoopcompatibility.mapred.wrapper
- Class org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopTupleUnwrappingIterator extends TupleUnwrappingIterator<VALUE,KEY> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - keySerializer
```
TypeSerializer<T> keySerializer
```

Package org.apache.flink.hcatalog

Class org.apache.flink.hcatalog.HCatInputFormatBase extends RichInputFormat<T,HadoopInputSplit> implements Serializable

serialVersionUID:: 1L

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

configuration
```
Configuration configuration
```

hCatInputFormat

org.apache.hive.hcatalog.mapreduce.HCatInputFormat hCatInputFormat

recordReader

org.apache.hadoop.mapreduce.RecordReader<KEYIN,VALUEIN> recordReader

fetched
```
boolean fetched
```
hasNext
```
boolean hasNext
```
fieldNames
```
String[] fieldNames
```

outputSchema

org.apache.hive.hcatalog.data.schema.HCatSchema outputSchema

resultType
```
TypeInformation<T> resultType
```

Package org.apache.flink.hcatalog.java
- Class org.apache.flink.hcatalog.java.HCatInputFormat extends HCatInputFormatBase<T> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.mesos.runtime.clusterframework
- Class org.apache.flink.mesos.runtime.clusterframework.RegisteredMesosWorkerNode extends Object implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - worker
```
MesosWorkerStore.Worker worker
```
Package org.apache.flink.mesos.runtime.clusterframework.store
- Class org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.Worker extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - taskID
```
org.apache.mesos.Protos.TaskID taskID
```
    - profile
```
ResourceProfile profile
```
    - slaveID
```
scala.Option<A> slaveID
```
    - hostname
```
scala.Option<A> hostname
```
    - state
```
MesosWorkerStore.WorkerState state
```
Package org.apache.flink.mesos.scheduler
- Class org.apache.flink.mesos.scheduler.ConnectionMonitor.ConnectedState$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ConnectionMonitor.ConnectingState$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ConnectionMonitor.Start extends Object implements Serializable
- Class org.apache.flink.mesos.scheduler.ConnectionMonitor.Start$ extends scala.runtime.AbstractFunction0<org.apache.flink.mesos.scheduler.ConnectionMonitor.Start> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ConnectionMonitor.Stop extends Object implements Serializable
- Class org.apache.flink.mesos.scheduler.ConnectionMonitor.Stop$ extends scala.runtime.AbstractFunction0<org.apache.flink.mesos.scheduler.ConnectionMonitor.Stop> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ConnectionMonitor.StoppedState$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Assign extends Object implements Serializable
  - Serialized Fields
    - tasks
```
List<E> tasks
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Assign$ extends scala.runtime.AbstractFunction1<List<Tuple2<com.netflix.fenzo.TaskRequest,String>>,org.apache.flink.mesos.scheduler.LaunchCoordinator.Assign> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.GatherData extends Object implements Serializable
  - Serialized Fields
    - tasks
```
scala.collection.Seq<A> tasks
```
    - newLeases
```
scala.collection.Seq<A> newLeases
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.GatherData$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<LaunchableTask>,scala.collection.Seq<com.netflix.fenzo.VirtualMachineLease>,org.apache.flink.mesos.scheduler.LaunchCoordinator.GatherData> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.GatheringOffers$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Idle$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Launch extends Object implements Serializable
  - Serialized Fields
    - tasks
```
List<E> tasks
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Launch$ extends scala.runtime.AbstractFunction1<List<LaunchableTask>,org.apache.flink.mesos.scheduler.LaunchCoordinator.Launch> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Suspended$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Unassign extends Object implements Serializable
  - Serialized Fields
    - taskID
```
org.apache.mesos.Protos.TaskID taskID
```
    - hostname
```
String hostname
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Unassign$ extends scala.runtime.AbstractFunction2<org.apache.mesos.Protos.TaskID,String,org.apache.flink.mesos.scheduler.LaunchCoordinator.Unassign> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Idle$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Reconcile extends Object implements Serializable
  - Serialized Fields
    - tasks
```
scala.collection.Seq<A> tasks
```
    - replace
```
boolean replace
```
- Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Reconcile$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<org.apache.mesos.Protos.TaskStatus>,Object,org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Reconcile> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.ReconciliationData extends Object implements Serializable
  - Serialized Fields
    - remaining
```
scala.collection.immutable.Map<A,B> remaining
```
    - retries
```
int retries
```
- Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.ReconciliationData$ extends scala.runtime.AbstractFunction2<scala.collection.immutable.Map<org.apache.mesos.Protos.TaskID,org.apache.mesos.Protos.TaskStatus>,Object,org.apache.flink.mesos.scheduler.ReconciliationCoordinator.ReconciliationData> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Reconciling$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Suspended$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Killing$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Launched extends Object implements Serializable
  - Serialized Fields
    - taskID
```
org.apache.mesos.Protos.TaskID taskID
```
    - slaveID
```
org.apache.mesos.Protos.SlaveID slaveID
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Launched$ extends scala.runtime.AbstractFunction2<org.apache.mesos.Protos.TaskID,org.apache.mesos.Protos.SlaveID,org.apache.flink.mesos.scheduler.TaskMonitor.Launched> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.New extends Object implements Serializable
  - Serialized Fields
    - taskID
```
org.apache.mesos.Protos.TaskID taskID
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.New$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Reconciling$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Released extends Object implements Serializable
  - Serialized Fields
    - taskID
```
org.apache.mesos.Protos.TaskID taskID
```
    - slaveID
```
org.apache.mesos.Protos.SlaveID slaveID
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Released$ extends scala.runtime.AbstractFunction2<org.apache.mesos.Protos.TaskID,org.apache.mesos.Protos.SlaveID,org.apache.flink.mesos.scheduler.TaskMonitor.Released> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Running$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Staging$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.StateData extends Object implements Serializable
  - Serialized Fields
    - goal
```
org.apache.flink.mesos.scheduler.TaskMonitor.TaskGoalState goal
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.StateData$ extends scala.runtime.AbstractFunction1<org.apache.flink.mesos.scheduler.TaskMonitor.TaskGoalState,org.apache.flink.mesos.scheduler.TaskMonitor.StateData> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Suspended$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.TaskGoalStateUpdated extends Object implements Serializable
  - Serialized Fields
    - state
```
org.apache.flink.mesos.scheduler.TaskMonitor.TaskGoalState state
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.TaskGoalStateUpdated$ extends scala.runtime.AbstractFunction1<org.apache.flink.mesos.scheduler.TaskMonitor.TaskGoalState,org.apache.flink.mesos.scheduler.TaskMonitor.TaskGoalStateUpdated> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.TaskTerminated extends Object implements Serializable
  - Serialized Fields
    - taskID
```
org.apache.mesos.Protos.TaskID taskID
```
    - status
```
org.apache.mesos.Protos.TaskStatus status
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.TaskTerminated$ extends scala.runtime.AbstractFunction2<org.apache.mesos.Protos.TaskID,org.apache.mesos.Protos.TaskStatus,org.apache.flink.mesos.scheduler.TaskMonitor.TaskTerminated> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
Package org.apache.flink.mesos.scheduler.messages
- Class org.apache.flink.mesos.scheduler.messages.AcceptOffers extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hostname
```
String hostname
```
    - offerIds
```
Collection<E> offerIds
```
    - operations
```
Collection<E> operations
```
    - filters
```
org.apache.mesos.Protos.Filters filters
```
- Class org.apache.flink.mesos.scheduler.messages.Connected extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.mesos.scheduler.messages.Disconnected extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.mesos.scheduler.messages.Error extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - message
```
String message
```
- Class org.apache.flink.mesos.scheduler.messages.ExecutorLost extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - executorId
```
org.apache.mesos.Protos.ExecutorID executorId
```
    - slaveId
```
org.apache.mesos.Protos.SlaveID slaveId
```
    - status
```
int status
```
- Class org.apache.flink.mesos.scheduler.messages.FrameworkMessage extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - executorId
```
org.apache.mesos.Protos.ExecutorID executorId
```
    - slaveId
```
org.apache.mesos.Protos.SlaveID slaveId
```
    - data
```
byte[] data
```
- Class org.apache.flink.mesos.scheduler.messages.OfferRescinded extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - offerId
```
org.apache.mesos.Protos.OfferID offerId
```
- Class org.apache.flink.mesos.scheduler.messages.Registered extends Connected implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - frameworkId
```
org.apache.mesos.Protos.FrameworkID frameworkId
```
    - masterInfo
```
org.apache.mesos.Protos.MasterInfo masterInfo
```
- Class org.apache.flink.mesos.scheduler.messages.ReRegistered extends Connected implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - masterInfo
```
org.apache.mesos.Protos.MasterInfo masterInfo
```
- Class org.apache.flink.mesos.scheduler.messages.ResourceOffers extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - offers
```
List<E> offers
```
- Class org.apache.flink.mesos.scheduler.messages.SlaveLost extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - slaveId
```
org.apache.mesos.Protos.SlaveID slaveId
```
- Class org.apache.flink.mesos.scheduler.messages.StatusUpdate extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - status
```
org.apache.mesos.Protos.TaskStatus status
```
Package org.apache.flink.metrics
- Class org.apache.flink.metrics.MetricConfig extends Properties implements Serializable
Package org.apache.flink.optimizer
- Class org.apache.flink.optimizer.CompilerException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  3810067304570563755L
- Class org.apache.flink.optimizer.CompilerPostPassException extends CompilerException implements Serializable
  
  serialVersionUID:
  
  -322650826288034623L
Package org.apache.flink.optimizer.dag
- Class org.apache.flink.optimizer.dag.BinaryUnionNode.UnionSemanticProperties extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.optimizer.postpass
- Class org.apache.flink.optimizer.postpass.ConflictingFieldTypeInfoException extends Exception implements Serializable
  
  serialVersionUID:
  
  3991352502693288321L
  - Serialized Fields
    - fieldNumber
```
int fieldNumber
```
    - previousType
```
Object previousType
```
    - newType
```
Object newType
```
- Class org.apache.flink.optimizer.postpass.MissingFieldTypeInfoException extends Exception implements Serializable
  
  serialVersionUID:
  
  8749941961302509358L
  - Serialized Fields
    - fieldNumber
```
int fieldNumber
```
Package org.apache.flink.orc
- Class org.apache.flink.orc.OrcRowInputFormat extends FileInputFormat<Row> implements Serializable
  - 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
    - batchSize
```
int batchSize
```
    - conf
```
Configuration conf
```
    - schema
```
org.apache.orc.TypeDescription schema
```
    - selectedFields
```
int[] selectedFields
```
    - conjunctPredicates
```
ArrayList<E> conjunctPredicates
```
- Class org.apache.flink.orc.OrcRowInputFormat.Between extends org.apache.flink.orc.OrcRowInputFormat.ColumnPredicate implements Serializable
  - Serialized Fields
    - lowerBound
```
Serializable lowerBound
```
    - upperBound
```
Serializable upperBound
```
- Class org.apache.flink.orc.OrcRowInputFormat.Equals extends org.apache.flink.orc.OrcRowInputFormat.BinaryPredicate implements Serializable
- Class org.apache.flink.orc.OrcRowInputFormat.In extends org.apache.flink.orc.OrcRowInputFormat.ColumnPredicate implements Serializable
  - Serialized Fields
    - literals
```
Serializable[] literals
```
- Class org.apache.flink.orc.OrcRowInputFormat.IsNull extends org.apache.flink.orc.OrcRowInputFormat.ColumnPredicate implements Serializable
- Class org.apache.flink.orc.OrcRowInputFormat.LessThan extends org.apache.flink.orc.OrcRowInputFormat.BinaryPredicate implements Serializable
- Class org.apache.flink.orc.OrcRowInputFormat.LessThanEquals extends org.apache.flink.orc.OrcRowInputFormat.BinaryPredicate implements Serializable
- Class org.apache.flink.orc.OrcRowInputFormat.Not extends OrcRowInputFormat.Predicate implements Serializable
  - Serialized Fields
    - pred
```
OrcRowInputFormat.Predicate pred
```
- Class org.apache.flink.orc.OrcRowInputFormat.NullSafeEquals extends org.apache.flink.orc.OrcRowInputFormat.BinaryPredicate implements Serializable
- Class org.apache.flink.orc.OrcRowInputFormat.Or extends OrcRowInputFormat.Predicate implements Serializable
  - Serialized Fields
    - preds
```
OrcRowInputFormat.Predicate[] preds
```
- Class org.apache.flink.orc.OrcRowInputFormat.Predicate extends Object implements Serializable
Package org.apache.flink.python.api.functions
- Class org.apache.flink.python.api.functions.PythonCoGroup extends RichCoGroupFunction<IN1,IN2,OUT> implements Serializable
  
  serialVersionUID:
  
  -3997396583317513873L
  - Serialized Fields
    - streamer
```
PythonDualInputStreamer<IN1,IN2,OUT> streamer
```
- Class org.apache.flink.python.api.functions.PythonMapPartition extends RichMapPartitionFunction<IN,OUT> implements Serializable
  
  serialVersionUID:
  
  3866306483023916413L
  - Serialized Fields
    - streamer
```
PythonSingleInputStreamer<IN,OUT> streamer
```
Package org.apache.flink.python.api.functions.util
- Class org.apache.flink.python.api.functions.util.IdentityGroupReduce extends Object implements Serializable
- Class org.apache.flink.python.api.functions.util.KeyDiscarder extends Object implements Serializable
- Class org.apache.flink.python.api.functions.util.NestedKeyDiscarder extends Object implements Serializable
- Class org.apache.flink.python.api.functions.util.SerializerMap extends Object implements Serializable
- Class org.apache.flink.python.api.functions.util.StringDeserializerMap extends Object implements Serializable
- Class org.apache.flink.python.api.functions.util.StringTupleDeserializerMap extends Object implements Serializable
Package org.apache.flink.python.api.streaming.data
- Class org.apache.flink.python.api.streaming.data.PythonDualInputSender extends PythonSender implements Serializable
  
  serialVersionUID:
  
  614115041181108878L
- Class org.apache.flink.python.api.streaming.data.PythonDualInputStreamer extends PythonStreamer<PythonDualInputSender<IN1,IN2>,OUT> implements Serializable
  
  serialVersionUID:
  
  -607175070491761873L
- Class org.apache.flink.python.api.streaming.data.PythonReceiver extends Object implements Serializable
  
  serialVersionUID:
  
  -2474088929850009968L
  - Serialized Fields
    - mappedFileSizeBytes
```
long mappedFileSizeBytes
```
    - readAsByteArray
```
boolean readAsByteArray
```
- Class org.apache.flink.python.api.streaming.data.PythonSender extends Object implements Serializable
  
  serialVersionUID:
  
  -2004095650353962110L
  - Serialized Fields
    - mappedFileSizeBytes
```
long mappedFileSizeBytes
```
    - config
```
Configuration config
```
- Class org.apache.flink.python.api.streaming.data.PythonSingleInputSender extends PythonSender implements Serializable
  
  serialVersionUID:
  
  614115041181108878L
- Class org.apache.flink.python.api.streaming.data.PythonSingleInputStreamer extends PythonStreamer<PythonSingleInputSender<IN>,OUT> implements Serializable
  
  serialVersionUID:
  
  -5149905918522069034L
- Class org.apache.flink.python.api.streaming.data.PythonStreamer extends Object implements Serializable
  
  serialVersionUID:
  
  -2342256613658373170L
  - Serialized Fields
    - config
```
Configuration config
```
    - envID
```
int envID
```
    - setID
```
int setID
```
    - port
```
int port
```
    - sender
```
PythonSender sender
```
    - receiver
```
PythonReceiver<OUT> receiver
```
    - msg
```
AtomicReference<V> msg
```
    - function
```
AbstractRichFunction function
```
Package org.apache.flink.queryablestate
- Class org.apache.flink.queryablestate.KvStateID extends AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.queryablestate.client
- Class org.apache.flink.queryablestate.client.VoidNamespaceSerializer extends TypeSerializerSingleton<VoidNamespace> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.queryablestate.client.VoidNamespaceTypeInfo extends TypeInformation<VoidNamespace> implements Serializable
  
  serialVersionUID:
  
  5453679706408610586L
Package org.apache.flink.queryablestate.exceptions
- Class org.apache.flink.queryablestate.exceptions.UnknownKeyOrNamespaceException extends BadRequestException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.queryablestate.exceptions.UnknownKvStateIdException extends BadRequestException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.queryablestate.exceptions.UnknownKvStateKeyGroupLocationException extends BadRequestException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.queryablestate.exceptions.UnknownLocationException extends FlinkException implements Serializable
  
  serialVersionUID:
  
  9092442511708951209L
Package org.apache.flink.queryablestate.network
- Class org.apache.flink.queryablestate.network.BadRequestException extends Exception implements Serializable
  
  serialVersionUID:
  
  3458743952407632903L
Package org.apache.flink.runtime
- Class org.apache.flink.runtime.JobException extends FlinkException implements Serializable
  
  serialVersionUID:
  
  1275864691743020176L
- Class org.apache.flink.runtime.StoppingException extends FlinkException implements Serializable
  
  serialVersionUID:
  
  -721315728140810694L
Package org.apache.flink.runtime.accumulators
- Class org.apache.flink.runtime.accumulators.AccumulatorSnapshot extends Object implements Serializable
  
  serialVersionUID:
  
  42L
  - Serialized Fields
    - jobID
```
JobID jobID
```
    - executionAttemptID
```
ExecutionAttemptID executionAttemptID
```
    - userAccumulators
```
SerializedValue<T> userAccumulators
```
      Serialized user accumulators which may require the custom user class loader.
- Class org.apache.flink.runtime.accumulators.StringifiedAccumulatorResult extends Object implements Serializable
  
  serialVersionUID:
  
  -4642311296836822611L
  - Serialized Fields
    - name
```
String name
```
    - type
```
String type
```
    - value
```
String value
```
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.
    - type
```
org.apache.flink.runtime.blob.BlobKey.BlobType type
```
      (Internal) BLOB type - to be reflected by the inheriting sub-class.
    - random
```
AbstractID random
```
      Random component of the key.
- Class org.apache.flink.runtime.blob.PermanentBlobKey extends BlobKey implements Serializable
- Class org.apache.flink.runtime.blob.TransientBlobKey extends BlobKey implements Serializable
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.checkpoint
- Class org.apache.flink.runtime.checkpoint.AbstractCheckpointStats extends Object implements Serializable
  
  serialVersionUID:
  
  1041218202028265151L
  - Serialized Fields
    - checkpointId
```
long checkpointId
```
      ID of this checkpoint.
    - triggerTimestamp
```
long triggerTimestamp
```
      Timestamp when the checkpoint was triggered at the coordinator.
    - taskStats
```
Map<K,V> taskStats
```
      TaskStateStats accessible by their ID.
    - numberOfSubtasks
```
int numberOfSubtasks
```
      Total number of subtasks over all tasks.
    - props
```
CheckpointProperties props
```
      Properties of the checkpoint.
- Class org.apache.flink.runtime.checkpoint.CheckpointException extends Exception implements Serializable
  
  serialVersionUID:
  
  -4341865597039002540L
- Class org.apache.flink.runtime.checkpoint.CheckpointMetaData extends Object implements Serializable
  
  serialVersionUID:
  
  -2387652345781312442L
  - Serialized Fields
    - checkpointId
```
long checkpointId
```
      The ID of the checkpoint
    - timestamp
```
long timestamp
```
      The timestamp of the checkpoint
- Class org.apache.flink.runtime.checkpoint.CheckpointMetrics extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - bytesBufferedInAlignment
```
long bytesBufferedInAlignment
```
      The number of bytes that were buffered during the checkpoint alignment phase
    - alignmentDurationNanos
```
long alignmentDurationNanos
```
      The duration (in nanoseconds) that the stream alignment for the checkpoint took
    - syncDurationMillis
```
long syncDurationMillis
```
    - asyncDurationMillis
```
long asyncDurationMillis
```
- Class org.apache.flink.runtime.checkpoint.CheckpointOptions extends Object implements Serializable
  
  serialVersionUID:
  
  5010126558083292915L
  - Serialized Fields
    - checkpointType
```
CheckpointType checkpointType
```
      Type of the checkpoint.
    - targetLocation
```
CheckpointStorageLocationReference targetLocation
```
      Target location for the checkpoint.
- Class org.apache.flink.runtime.checkpoint.CheckpointProperties extends Object implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - checkpointType
```
CheckpointType checkpointType
```
      Type - checkpoint / savepoint.
    - forced
```
boolean forced
```
      This has a misleading name and actually means whether the snapshot must be triggered, or whether it may be rejected by the checkpoint coordinator if too many checkpoints are currently in progress.
    - discardSubsumed
```
boolean discardSubsumed
```
    - discardFinished
```
boolean discardFinished
```
    - discardCancelled
```
boolean discardCancelled
```
    - discardFailed
```
boolean discardFailed
```
    - discardSuspended
```
boolean discardSuspended
```
- Class org.apache.flink.runtime.checkpoint.CheckpointStatsCounts extends Object implements Serializable
  
  serialVersionUID:
  
  -5229425063269482528L
  - Serialized Fields
    - numRestoredCheckpoints
```
long numRestoredCheckpoints
```
      Number of restored checkpoints.
    - numTotalCheckpoints
```
long numTotalCheckpoints
```
      Number of total checkpoints (in progress, completed, failed).
    - numInProgressCheckpoints
```
int numInProgressCheckpoints
```
      Number of in progress checkpoints.
    - numCompletedCheckpoints
```
long numCompletedCheckpoints
```
      Number of successfully completed checkpoints.
    - numFailedCheckpoints
```
long numFailedCheckpoints
```
      Number of failed checkpoints.
- Class org.apache.flink.runtime.checkpoint.CheckpointStatsHistory extends Object implements Serializable
  
  serialVersionUID:
  
  7090320677606528415L
  - Serialized Fields
    - checkpointsHistory
```
List<E> checkpointsHistory
```
      List over all available stats. Only updated on CheckpointStatsHistory.createSnapshot().
    - checkpointsById
```
Map<K,V> checkpointsById
```
      Map of all available stats keyed by their ID. Only updated on CheckpointStatsHistory.createSnapshot().
    - maxSize
```
int maxSize
```
      Maximum array size.
    - readOnly
```
boolean readOnly
```
      Flag indicating whether this the history is read-only.
    - latestCompletedCheckpoint
```
CompletedCheckpointStats latestCompletedCheckpoint
```
      The latest successfully completed checkpoint.
    - latestFailedCheckpoint
```
FailedCheckpointStats latestFailedCheckpoint
```
      The latest failed checkpoint.
    - latestSavepoint
```
CompletedCheckpointStats latestSavepoint
```
      The latest successfully completed savepoint.
- Class org.apache.flink.runtime.checkpoint.CheckpointStatsSnapshot extends Object implements Serializable
  
  serialVersionUID:
  
  8914278419087217964L
  - Serialized Fields
    - counts
```
CheckpointStatsCounts counts
```
      Snapshot of the checkpoint counts.
    - summary
```
CompletedCheckpointStatsSummary summary
```
      Snapshot of the completed checkpoints summary stats.
    - history
```
CheckpointStatsHistory history
```
      Snapshot of the checkpoint history.
    - latestRestoredCheckpoint
```
RestoredCheckpointStats latestRestoredCheckpoint
```
      The latest restored checkpoint operation.
- Class org.apache.flink.runtime.checkpoint.CheckpointTriggerException extends FlinkException implements Serializable
  
  serialVersionUID:
  
  -3330160816161901752L
  - Serialized Fields
    - checkpointDeclineReason
```
CheckpointDeclineReason checkpointDeclineReason
```
- Class org.apache.flink.runtime.checkpoint.CompletedCheckpoint extends Object implements Serializable
  
  serialVersionUID:
  
  -8360248179615702014L
  - Serialized Fields
    - job
```
JobID job
```
      The ID of the job that the checkpoint belongs to.
    - checkpointID
```
long checkpointID
```
      The ID (logical timestamp) of the checkpoint.
    - timestamp
```
long timestamp
```
      The timestamp when the checkpoint was triggered.
    - duration
```
long duration
```
      The duration of the checkpoint (completion timestamp - trigger timestamp).
    - operatorStates
```
Map<K,V> operatorStates
```
      States of the different operator groups belonging to this checkpoint.
    - props
```
CheckpointProperties props
```
      Properties for this checkpoint.
    - masterHookStates
```
Collection<E> masterHookStates
```
      States that were created by a hook on the master (in the checkpoint coordinator).
    - storageLocation
```
CompletedCheckpointStorageLocation storageLocation
```
      The location where the checkpoint is stored.
    - metadataHandle
```
StreamStateHandle metadataHandle
```
      The state handle to the externalized meta data.
    - externalPointer
```
String externalPointer
```
      External pointer to the completed checkpoint (for example file path).
- Class org.apache.flink.runtime.checkpoint.CompletedCheckpointStats extends AbstractCheckpointStats implements Serializable
  
  serialVersionUID:
  
  138833868551861344L
  - Serialized Fields
    - stateSize
```
long stateSize
```
      Total checkpoint state size over all subtasks.
    - alignmentBuffered
```
long alignmentBuffered
```
      Buffered bytes during alignment over all subtasks.
    - latestAcknowledgedSubtask
```
SubtaskStateStats latestAcknowledgedSubtask
```
      The latest acknowledged subtask stats.
    - externalPointer
```
String externalPointer
```
      The external pointer of the checkpoint.
    - discarded
```
boolean discarded
```
      Flag indicating whether the checkpoint was discarded.
- Class org.apache.flink.runtime.checkpoint.CompletedCheckpointStatsSummary extends Object implements Serializable
  
  serialVersionUID:
  
  5784360461635814038L
  - Serialized Fields
    - stateSize
```
MinMaxAvgStats stateSize
```
      State size statistics for all completed checkpoints.
    - duration
```
MinMaxAvgStats duration
```
      Duration statistics for all completed checkpoints.
    - alignmentBuffered
```
MinMaxAvgStats alignmentBuffered
```
      Byte buffered during alignment for all completed checkpoints.
- Class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest.TestCompletedCheckpoint extends CompletedCheckpoint implements Serializable
  
  serialVersionUID:
  
  4211419809665983026L
  - Serialized Fields
    - isDiscarded
```
boolean isDiscarded
```
- Class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest.TestOperatorSubtaskState extends OperatorSubtaskState implements Serializable
  
  serialVersionUID:
  
  522580433699164230L
  - Serialized Fields
    - registered
```
boolean registered
```
    - discarded
```
boolean discarded
```
- Class org.apache.flink.runtime.checkpoint.FailedCheckpointStats extends AbstractCheckpointStats implements Serializable
  
  serialVersionUID:
  
  8000748529515900106L
  - Serialized Fields
    - numAcknowledgedSubtasks
```
int numAcknowledgedSubtasks
```
      Number of acknowledged tasks.
    - stateSize
```
long stateSize
```
      Total checkpoint state size over all subtasks.
    - alignmentBuffered
```
long alignmentBuffered
```
      Buffered bytes during alignment over all subtasks.
    - failureTimestamp
```
long failureTimestamp
```
      Timestamp when the checkpoint was failed at the coordinator.
    - latestAcknowledgedSubtask
```
SubtaskStateStats latestAcknowledgedSubtask
```
      The latest acknowledged subtask stats if any subtask was acknowledged before failing the checkpoint.
    - failureMsg
```
String failureMsg
```
      Optional failure message.
- Class org.apache.flink.runtime.checkpoint.JobManagerTaskRestore extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - restoreCheckpointId
```
long restoreCheckpointId
```
      The id of the checkpoint from which we restore.
    - taskStateSnapshot
```
TaskStateSnapshot taskStateSnapshot
```
      The state for this task to restore.
- Class org.apache.flink.runtime.checkpoint.MasterState extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - name
```
String name
```
    - bytes
```
byte[] bytes
```
    - version
```
int version
```
- Class org.apache.flink.runtime.checkpoint.MinMaxAvgStats extends Object implements Serializable
  
  serialVersionUID:
  
  1769601903483446707L
  - Serialized Fields
    - min
```
long min
```
      Current min value.
    - max
```
long max
```
      Current max value.
    - sum
```
long sum
```
      Sum of all added values.
    - count
```
long count
```
      Count of added values.
- Class org.apache.flink.runtime.checkpoint.OperatorState extends Object implements Serializable
  
  serialVersionUID:
  
  -4845578005863201810L
  - Serialized Fields
    - operatorID
```
OperatorID operatorID
```
      id of the operator
    - operatorSubtaskStates
```
Map<K,V> operatorSubtaskStates
```
      handles to non-partitioned states, subtaskindex -> subtaskstate
    - parallelism
```
int parallelism
```
      parallelism of the operator when it was checkpointed
    - maxParallelism
```
int maxParallelism
```
      maximum parallelism of the operator when the job was first created
- Class org.apache.flink.runtime.checkpoint.OperatorSubtaskState extends Object implements Serializable
  
  serialVersionUID:
  
  -2394696997971923995L
  - Serialized Fields
    - managedOperatorState
```
StateObjectCollection<T extends StateObject> managedOperatorState
```
      Snapshot from the OperatorStateBackend.
    - rawOperatorState
```
StateObjectCollection<T extends StateObject> rawOperatorState
```
      Snapshot written using OperatorStateCheckpointOutputStream.
    - managedKeyedState
```
StateObjectCollection<T extends StateObject> managedKeyedState
```
      Snapshot from KeyedStateBackend.
    - rawKeyedState
```
StateObjectCollection<T extends StateObject> rawKeyedState
```
      Snapshot written using KeyedStateCheckpointOutputStream.
    - stateSize
```
long stateSize
```
      The state size. This is also part of the deserialized state handle. We store it here in order to not deserialize the state handle when gathering stats.
- Class org.apache.flink.runtime.checkpoint.PendingCheckpointStats extends AbstractCheckpointStats implements Serializable
  
  serialVersionUID:
  
  -973959257699390327L
  - Serialized Fields
    - currentNumAcknowledgedSubtasks
```
int currentNumAcknowledgedSubtasks
```
      The current number of acknowledged subtasks.
    - currentStateSize
```
long currentStateSize
```
      Current checkpoint state size over all collected subtasks.
    - currentAlignmentBuffered
```
long currentAlignmentBuffered
```
      Current buffered bytes during alignment over all collected subtasks.
    - latestAcknowledgedSubtask
```
SubtaskStateStats latestAcknowledgedSubtask
```
      Stats of the latest acknowledged subtask.
- Class org.apache.flink.runtime.checkpoint.RestoredCheckpointStats extends Object implements Serializable
  
  serialVersionUID:
  
  2305815319666360821L
  - Serialized Fields
    - checkpointId
```
long checkpointId
```
      ID of the restored checkpoint.
    - props
```
CheckpointProperties props
```
      Properties of the restored checkpoint.
    - restoreTimestamp
```
long restoreTimestamp
```
      Timestamp when the checkpoint was restored at the coordinator.
    - externalPath
```
String externalPath
```
      Optional external path.
- Class org.apache.flink.runtime.checkpoint.StateObjectCollection extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - stateObjects
```
Collection<E> stateObjects
```
      Wrapped collection that contains the state objects.
- Class org.apache.flink.runtime.checkpoint.SubtaskState extends Object implements Serializable
  
  serialVersionUID:
  
  -2394696997971923995L
  - Serialized Fields
    - managedOperatorState
```
ChainedStateHandle<T extends StateObject> managedOperatorState
```
      Snapshot from the OperatorStateBackend.
    - rawOperatorState
```
ChainedStateHandle<T extends StateObject> rawOperatorState
```
      Snapshot written using OperatorStateCheckpointOutputStream.
    - managedKeyedState
```
KeyedStateHandle managedKeyedState
```
      Snapshot from KeyedStateBackend.
    - rawKeyedState
```
KeyedStateHandle rawKeyedState
```
      Snapshot written using KeyedStateCheckpointOutputStream.
    - stateSize
```
long stateSize
```
      The state size. This is also part of the deserialized state handle. We store it here in order to not deserialize the state handle when gathering stats.
- Class org.apache.flink.runtime.checkpoint.SubtaskStateStats extends Object implements Serializable
  
  serialVersionUID:
  
  8928594531621862214L
  - Serialized Fields
    - subtaskIndex
```
int subtaskIndex
```
      Index of this sub task.
    - ackTimestamp
```
long ackTimestamp
```
      Timestamp when the ack from this sub task was received at the coordinator.
    - stateSize
```
long stateSize
```
      Size of the checkpointed state at this subtask.
    - syncCheckpointDuration
```
long syncCheckpointDuration
```
      Checkpoint duration at the operator (sync part) in milliseconds.
    - asyncCheckpointDuration
```
long asyncCheckpointDuration
```
      Checkpoint duration at the operator (async part) in milliseconds.
    - alignmentBuffered
```
long alignmentBuffered
```
      Number of buffered bytes during alignment.
    - alignmentDuration
```
long alignmentDuration
```
      Alignment duration in .
- Class org.apache.flink.runtime.checkpoint.TaskState extends Object implements Serializable
  
  serialVersionUID:
  
  -4845578005863201810L
  - Serialized Fields
    - jobVertexID
```
JobVertexID jobVertexID
```
      Deprecated.
    - subtaskStates
```
Map<K,V> subtaskStates
```
      Deprecated.
      
      handles to non-partitioned states, subtaskindex -> subtaskstate
    - parallelism
```
int parallelism
```
      Deprecated.
      
      parallelism of the operator when it was checkpointed
    - maxParallelism
```
int maxParallelism
```
      Deprecated.
      
      maximum parallelism of the operator when the job was first created
    - chainLength
```
int chainLength
```
      Deprecated.
      
      length of the operator chain
- Class org.apache.flink.runtime.checkpoint.TaskStateSnapshot extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - subtaskStatesByOperatorID
```
Map<K,V> subtaskStatesByOperatorID
```
      Mapping from an operator id to the state of one subtask of this operator.
- Class org.apache.flink.runtime.checkpoint.TaskStateStats extends Object implements Serializable
  
  serialVersionUID:
  
  531803101206574444L
  - Serialized Fields
    - jobVertexId
```
JobVertexID jobVertexId
```
      ID of the task the stats belong to.
    - subtaskStats
```
SubtaskStateStats[] subtaskStats
```
      Stats for each subtask
    - summaryStats
```
TaskStateStats.TaskStateStatsSummary summaryStats
```
      A summary of the subtask stats.
    - numAcknowledgedSubtasks
```
int numAcknowledgedSubtasks
```
      Number of acknowledged subtasks.
    - latestAckedSubtaskStats
```
SubtaskStateStats latestAckedSubtaskStats
```
      The latest acknowledged subtask stats.
- Class org.apache.flink.runtime.checkpoint.TaskStateStats.TaskStateStatsSummary extends Object implements Serializable
  
  serialVersionUID:
  
  1009476026522091909L
  - Serialized Fields
    - stateSize
```
MinMaxAvgStats stateSize
```
    - ackTimestamp
```
MinMaxAvgStats ackTimestamp
```
    - syncCheckpointDuration
```
MinMaxAvgStats syncCheckpointDuration
```
    - asyncCheckpointDuration
```
MinMaxAvgStats asyncCheckpointDuration
```
    - alignmentBuffered
```
MinMaxAvgStats alignmentBuffered
```
    - alignmentDuration
```
MinMaxAvgStats alignmentDuration
```
Package org.apache.flink.runtime.checkpoint.decline
- Class org.apache.flink.runtime.checkpoint.decline.AlignmentLimitExceededException extends CheckpointDeclineException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.checkpoint.decline.CheckpointDeclineException extends Exception implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.checkpoint.decline.CheckpointDeclineOnCancellationBarrierException extends CheckpointDeclineException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.checkpoint.decline.CheckpointDeclineSubsumedException extends CheckpointDeclineException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.checkpoint.decline.CheckpointDeclineTaskNotCheckpointingException extends CheckpointDeclineException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.checkpoint.decline.CheckpointDeclineTaskNotReadyException extends CheckpointDeclineException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.checkpoint.decline.InputEndOfStreamException extends CheckpointDeclineException implements Serializable
  
  serialVersionUID:
  
  1L
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 FlinkException implements Serializable
  
  serialVersionUID:
  
  2818087325120827525L
  - Serialized Fields
    - jobID
```
JobID jobID
```
- Class org.apache.flink.runtime.client.JobRetrievalException extends JobExecutionException implements Serializable
  
  serialVersionUID:
  
  -42L
- 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
- Class org.apache.flink.runtime.client.SerializedJobExecutionResult extends Object implements Serializable
  
  serialVersionUID:
  
  -6301865617099921789L
  - Serialized Fields
    - jobId
```
JobID jobId
```
    - accumulatorResults
```
Map<K,V> accumulatorResults
```
    - netRuntime
```
long netRuntime
```
Package org.apache.flink.runtime.clusterframework
- Class org.apache.flink.runtime.clusterframework.ContaineredTaskManagerParameters extends Object implements Serializable
  
  serialVersionUID:
  
  -3096987654278064670L
  - Serialized Fields
    - totalContainerMemoryMB
```
long totalContainerMemoryMB
```
      Total container memory, in bytes.
    - taskManagerHeapSizeMB
```
long taskManagerHeapSizeMB
```
      Heap size to be used for the Java process.
    - taskManagerDirectMemoryLimitMB
```
long taskManagerDirectMemoryLimitMB
```
      Direct memory limit for the Java process.
    - numSlots
```
int numSlots
```
      The number of slots per TaskManager.
    - taskManagerEnv
```
HashMap<K,V> taskManagerEnv
```
      Environment variables to add to the Java process.
- Class org.apache.flink.runtime.clusterframework.ContainerSpecification extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - systemProperties
```
Configuration systemProperties
```
    - artifacts
```
List<E> artifacts
```
    - environmentVariables
```
Map<K,V> environmentVariables
```
    - dynamicConfiguration
```
Configuration dynamicConfiguration
```
Package org.apache.flink.runtime.clusterframework.messages
- Class org.apache.flink.runtime.clusterframework.messages.CheckAndAllocateContainers extends Object implements Serializable
  
  serialVersionUID:
  
  7808628311617273755L
  - Serialization Methods
    - readResolve
```
private Object readResolve()
                    throws ObjectStreamException
```
      Read resolve to preserve the singleton object property.
      
      Throws:
      
      ObjectStreamException
- Class org.apache.flink.runtime.clusterframework.messages.FatalErrorOccurred extends Object implements Serializable
  
  serialVersionUID:
  
  -2246792138413563536L
  - Serialized Fields
    - message
```
String message
```
    - error
```
SerializedThrowable error
```
- Class org.apache.flink.runtime.clusterframework.messages.GetClusterStatus extends Object implements Serializable
  
  serialVersionUID:
  
  7808628311617273755L
  - Serialization Methods
    - readResolve
```
private Object readResolve()
                    throws ObjectStreamException
```
      Read resolve to preserve the singleton object property.
      
      Throws:
      
      ObjectStreamException
- Class org.apache.flink.runtime.clusterframework.messages.GetClusterStatusResponse extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - numRegisteredTaskManagers
```
int numRegisteredTaskManagers
```
    - totalNumberOfSlots
```
int totalNumberOfSlots
```
- Class org.apache.flink.runtime.clusterframework.messages.InfoMessage extends Object implements Serializable
  
  serialVersionUID:
  
  5534993035539629765L
  - Serialized Fields
    - message
```
String message
```
    - date
```
Date date
```
- Class org.apache.flink.runtime.clusterframework.messages.NewLeaderAvailable extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - leaderAddress
```
String leaderAddress
```
      The leader Akka URL
    - leaderSessionId
```
UUID leaderSessionId
```
      The session ID for the leadership status
- Class org.apache.flink.runtime.clusterframework.messages.NotifyResourceStarted extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - resourceID
```
ResourceID resourceID
```
- Class org.apache.flink.runtime.clusterframework.messages.ReconnectResourceManager extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - resourceManager
```
akka.actor.ActorRef resourceManager
```
    - connectionId
```
long connectionId
```
- Class org.apache.flink.runtime.clusterframework.messages.RegisterInfoMessageListener extends Object implements Serializable
  
  serialVersionUID:
  
  7808628311617273755L
  - Serialization Methods
    - readResolve
```
private Object readResolve()
                    throws ObjectStreamException
```
      Read resolve to preserve the singleton object property.
      
      Throws:
      
      ObjectStreamException
- Class org.apache.flink.runtime.clusterframework.messages.RegisterInfoMessageListenerSuccessful extends Object implements Serializable
  
  serialVersionUID:
  
  7808628311617273755L
  - Serialization Methods
    - readResolve
```
private Object readResolve()
                    throws ObjectStreamException
```
      Read resolve to preserve the singleton object property.
      
      Throws:
      
      ObjectStreamException
- Class org.apache.flink.runtime.clusterframework.messages.RegisterResourceManager extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - resourceManager
```
akka.actor.ActorRef resourceManager
```
- Class org.apache.flink.runtime.clusterframework.messages.RegisterResourceManagerSuccessful extends Object implements Serializable
  
  serialVersionUID:
  
  817011779310941753L
  - Serialized Fields
    - jobManager
```
akka.actor.ActorRef jobManager
```
      The JobManager which we registered with.
    - currentlyRegisteredTaskManagers
```
Collection<E> currentlyRegisteredTaskManagers
```
      The list of registered TaskManagers that the JobManager currently knows
- Class org.apache.flink.runtime.clusterframework.messages.RemoveResource extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - resourceId
```
ResourceID resourceId
```
      The ID under which the resource is registered (for example container ID)
- Class org.apache.flink.runtime.clusterframework.messages.ResourceRemoved extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - resourceId
```
ResourceID resourceId
```
      The ID under which the resource is registered (for example container ID)
    - message
```
String message
```
      Optional message with details, for logging and debugging
- Class org.apache.flink.runtime.clusterframework.messages.SetWorkerPoolSize extends Object implements Serializable
  
  serialVersionUID:
  
  -335911350781207609L
  - Serialized Fields
    - numberOfWorkers
```
int numberOfWorkers
```
- Class org.apache.flink.runtime.clusterframework.messages.ShutdownClusterAfterJob extends Object implements Serializable
  
  serialVersionUID:
  
  -2723662264779569704L
  - Serialized Fields
    - jobId
```
JobID jobId
```
- Class org.apache.flink.runtime.clusterframework.messages.StopCluster extends Object implements Serializable
  
  serialVersionUID:
  
  -8957259342982181684L
  - Serialized Fields
    - finalStatus
```
ApplicationStatus finalStatus
```
    - message
```
String message
```
- Class org.apache.flink.runtime.clusterframework.messages.StopClusterSuccessful extends Object implements Serializable
  
  serialVersionUID:
  
  42L
- Class org.apache.flink.runtime.clusterframework.messages.TriggerRegistrationAtJobManager extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jobManagerAddress
```
String jobManagerAddress
```
- Class org.apache.flink.runtime.clusterframework.messages.UnRegisterInfoMessageListener extends Object implements Serializable
  
  serialVersionUID:
  
  7808628311617273755L
  - Serialization Methods
    - readResolve
```
private Object readResolve()
                    throws ObjectStreamException
```
      Read resolve to preserve the singleton object property.
      
      Throws:
      
      ObjectStreamException
Package org.apache.flink.runtime.clusterframework.types
- Class org.apache.flink.runtime.clusterframework.types.AllocationID extends AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.clusterframework.types.ResourceID extends Object implements Serializable
  
  serialVersionUID:
  
  42L
  - Serialized Fields
    - resourceId
```
String resourceId
```
- Class org.apache.flink.runtime.clusterframework.types.ResourceProfile extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - cpuCores
```
double cpuCores
```
      How many cpu cores are needed, use double so we can specify cpu like 0.1.
    - heapMemoryInMB
```
int heapMemoryInMB
```
      How many heap memory in mb are needed.
    - directMemoryInMB
```
int directMemoryInMB
```
      How many direct memory in mb are needed.
    - nativeMemoryInMB
```
int nativeMemoryInMB
```
      How many native memory in mb are needed.
    - networkMemoryInMB
```
int networkMemoryInMB
```
      Memory used for the task in the slot to communicate with its upstreams. Set by job master.
    - extendedResources
```
Map<K,V> extendedResources
```
      A extensible field for user specified resources from ResourceSpec.
- Class org.apache.flink.runtime.clusterframework.types.SlotID extends Object implements Serializable
  
  serialVersionUID:
  
  -6399206032549807771L
  - Serialized Fields
    - resourceId
```
ResourceID resourceId
```
      The resource id which this slot located
    - slotNumber
```
int slotNumber
```
      The numeric id for single slot
Package org.apache.flink.runtime.concurrent
- Class org.apache.flink.runtime.concurrent.FutureUtils.RetryException extends Exception implements Serializable
  
  serialVersionUID:
  
  3613470781274141862L
Package org.apache.flink.runtime.deployment
- Class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptor extends Object implements Serializable
  
  serialVersionUID:
  
  373711381640454080L
  - 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
  
  serialVersionUID:
  
  -7143441863165366704L
  - 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.
    - consumedPartitionType
```
ResultPartitionType consumedPartitionType
```
      The type of the partition the input gate is going to consume.
    - 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
  
  serialVersionUID:
  
  6343547936086963705L
  - 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.
    - maxParallelism
```
int maxParallelism
```
      The maximum parallelism.
    - sendScheduleOrUpdateConsumersMessage
```
boolean sendScheduleOrUpdateConsumersMessage
```
      Flag whether the result partition should send scheduleOrUpdateConsumer messages.
- Class org.apache.flink.runtime.deployment.ResultPartitionLocation extends Object implements Serializable
  
  serialVersionUID:
  
  -6354238166937194463L
  - 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
    - serializedJobInformation
```
TaskDeploymentDescriptor.MaybeOffloaded<T> serializedJobInformation
```
      Serialized job information or null if offloaded.
    - serializedTaskInformation
```
TaskDeploymentDescriptor.MaybeOffloaded<T> serializedTaskInformation
```
      Serialized task information or null if offloaded.
    - jobId
```
JobID jobId
```
      The ID referencing the job this task belongs to.
      NOTE: this is redundant to the information stored in TaskDeploymentDescriptor.serializedJobInformation but needed in order to restore offloaded data.
    - executionId
```
ExecutionAttemptID executionId
```
      The ID referencing the attempt to execute the task.
    - allocationId
```
AllocationID allocationId
```
      The allocation ID of the slot in which the task shall be run.
    - subtaskIndex
```
int subtaskIndex
```
      The task's index in the subtask group.
    - attemptNumber
```
int attemptNumber
```
      Attempt number the task.
    - producedPartitions
```
Collection<E> producedPartitions
```
      The list of produced intermediate result partition deployment descriptors.
    - inputGates
```
Collection<E> inputGates
```
      The list of consumed intermediate result partitions.
    - targetSlotNumber
```
int targetSlotNumber
```
      Slot number to run the sub task in on the target machine.
    - taskRestore
```
JobManagerTaskRestore taskRestore
```
      Information to restore the task. This can be null if there is no state to restore.
- Class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor.MaybeOffloaded extends Object implements Serializable
  
  serialVersionUID:
  
  5977104446396536907L
- Class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor.NonOffloaded extends TaskDeploymentDescriptor.MaybeOffloaded<T> implements Serializable
  
  serialVersionUID:
  
  4246628617754862463L
  - Serialized Fields
    - serializedValue
```
SerializedValue<T> serializedValue
```
      The serialized value.
- Class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor.Offloaded extends TaskDeploymentDescriptor.MaybeOffloaded<T> implements Serializable
  
  serialVersionUID:
  
  4544135485379071679L
  - Serialized Fields
    - serializedValueKey
```
PermanentBlobKey serializedValueKey
```
      The key of the offloaded value BLOB.
Package org.apache.flink.runtime.dispatcher
- Class org.apache.flink.runtime.dispatcher.DispatcherException extends FlinkException implements Serializable
  
  serialVersionUID:
  
  3781733042984381286L
- Class org.apache.flink.runtime.dispatcher.DispatcherId extends AbstractID implements Serializable
  
  serialVersionUID:
  
  -1654056277003743966L
Package org.apache.flink.runtime.entrypoint
- Class org.apache.flink.runtime.entrypoint.ClusterEntrypointException extends FlinkException implements Serializable
  
  serialVersionUID:
  
  -3855286807063809945L
- Class org.apache.flink.runtime.entrypoint.ClusterInformation extends Object implements Serializable
  
  serialVersionUID:
  
  316958921518479205L
  - Serialized Fields

Back to Flink Website

Serialized Form

Package <Unnamed>

Class StreamingFileSinkProgram.Generator extends Object implements Serializable

Serialized Fields

numKeys

idlenessMs

recordsToEmit

numRecordsEmitted

canceled

Class StreamingFileSinkProgram.KeyBucketAssigner extends Object implements Serializable

Package example.avro

Class example.avro.User extends org.apache.avro.specific.SpecificRecordBase implements Serializable

Serialization Methods

readExternal

writeExternal

Package org.apache.calcite.avatica.util

Class org.apache.calcite.avatica.util.ByteString extends Object implements Serializable

Serialized Fields

bytes

Package org.apache.calcite.sql.validate

Class org.apache.calcite.sql.validate.CyclicDefinitionException extends RuntimeException implements Serializable

Serialized Fields

depth

path

Class org.apache.calcite.sql.validate.SqlValidatorException extends Exception implements Serializable

Package org.apache.calcite.sql2rel

Class org.apache.calcite.sql2rel.RelFieldTrimmer.TrimResult extends org.apache.calcite.util.Pair<org.apache.calcite.rel.RelNode,org.apache.calcite.util.mapping.Mapping> implements Serializable

Package org.apache.flink.addons.hbase

Class org.apache.flink.addons.hbase.AbstractTableInputFormat extends RichInputFormat<T,TableInputSplit> implements Serializable

Serialized Fields

endReached

resultScanner

currentRow

scannedRows

Class org.apache.flink.addons.hbase.HBaseRowInputFormat extends AbstractTableInputFormat<Row> implements Serializable

Serialized Fields

tableName

schema

families

qualifiers

types

resultRow

familyRows

Class org.apache.flink.addons.hbase.HBaseTableSchema extends Object implements Serializable

Serialized Fields

familyMap

charset

Class org.apache.flink.addons.hbase.TableInputFormat extends AbstractTableInputFormat<T extends Tuple> implements Serializable

Class org.apache.flink.addons.hbase.TableInputSplit extends LocatableInputSplit implements Serializable

Serialized Fields

tableName

startRow

endRow

Package org.apache.flink.api.common

Class org.apache.flink.api.common.ArchivedExecutionConfig extends Object implements Serializable

Serialized Fields

executionMode

restartStrategyDescription

parallelism

objectReuseEnabled

globalJobParameters

Class org.apache.flink.api.common.ExecutionConfig extends Object implements Serializable

Serialized Fields

executionMode

closureCleanerLevel

parallelism

maxParallelism

numberOfExecutionRetries

forceKryo

disableGenericTypes

objectReuse

autoTypeRegistrationEnabled

forceAvro

codeAnalysisMode

printProgressDuringExecution

autoWatermarkInterval

latencyTrackingInterval

isLatencyTrackingConfigured

executionRetryDelay