Serialized Form (Flink : 1.15-SNAPSHOT API)

Package <Unnamed>
- Class FileSinkProgram.Generator extends Object implements Serializable
  
  serialVersionUID:
  
  -2819385275681175792L
  - Serialized Fields
    - numKeys
```
int numKeys
```
    - idlenessMs
```
int idlenessMs
```
    - recordsToEmit
```
int recordsToEmit
```
    - numRecordsEmitted
```
int numRecordsEmitted
```
    - canceled
```
boolean canceled
```
    - state
```
ListState<T> state
```
- Class FileSinkProgram.KeyBucketAssigner extends Object implements Serializable
  
  serialVersionUID:
  
  987325769970523326L
- Class JavaLexer extends Object implements Serializable
- Class JavaParser extends Object implements Serializable
- Class JavaParserBaseListener extends Object implements Serializable
- Class JavaParserBaseVisitor extends Object implements Serializable
- Class JavaParserListener extends Object implements Serializable
- Class JavaParserVisitor extends Object implements Serializable
Package org.apache.calcite.jdbc
- Class org.apache.calcite.jdbc.JavaCollation extends org.apache.calcite.sql.SqlCollation implements Serializable
  - Serialized Fields
    - collator
```
Collator collator
```
- Class org.apache.calcite.jdbc.JavaRecordType extends org.apache.calcite.rel.type.RelRecordType implements Serializable
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
- Class org.apache.calcite.jdbc.SqlTimeoutException extends SQLException implements Serializable
Package org.apache.calcite.rex
- Class org.apache.calcite.rex.RexFieldCollation extends org.apache.calcite.util.Pair<org.apache.calcite.rex.RexNode,com.google.common.collect.ImmutableSet<org.apache.calcite.sql.SqlKind>> implements Serializable
- Class org.apache.calcite.rex.RexSlot.SelfPopulatingList extends CopyOnWriteArrayList<String> implements Serializable
  - Serialized Fields
    - prefix
```
String prefix
```
Package org.apache.calcite.sql
- Class org.apache.calcite.sql.SqlCollation extends Object implements Serializable
  - Serialized Fields
    - collationName
```
String collationName
```
    - wrappedCharset
```
org.apache.calcite.util.SerializableCharset wrappedCharset
```
    - locale
```
Locale locale
```
    - strength
```
String strength
```
    - coercibility
```
org.apache.calcite.sql.SqlCollation.Coercibility coercibility
```
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.api.common
- Class org.apache.flink.api.common.ArchivedExecutionConfig extends Object implements Serializable
  
  serialVersionUID:
  
  2907040336948181163L
  - Serialized Fields
    - executionMode
```
String executionMode
```
    - restartStrategyDescription
```
String restartStrategyDescription
```
    - parallelism
```
int parallelism
```
    - maxParallelism
```
int maxParallelism
```
    - 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
    - enableAutoGeneratedUids
```
boolean enableAutoGeneratedUids
```
    - objectReuse
```
boolean objectReuse
```
    - autoTypeRegistrationEnabled
```
boolean autoTypeRegistrationEnabled
```
    - forceAvro
```
boolean forceAvro
```
    - autoWatermarkInterval
```
long autoWatermarkInterval
```
    - latencyTrackingInterval
```
long latencyTrackingInterval
```
      Interval in milliseconds for sending latency tracking marks from the sources to the sinks.
    - isLatencyTrackingConfigured
```
boolean isLatencyTrackingConfigured
```
    - periodicMaterializeIntervalMillis
```
long periodicMaterializeIntervalMillis
```
      Interval in milliseconds to perform periodic changelog materialization.
    - materializationMaxAllowedFailures
```
int materializationMaxAllowedFailures
```
      Max allowed number of consecutive failures for changelog materialization
    - executionRetryDelay
```
long executionRetryDelay
```
      Deprecated. Should no longer be used because it is subsumed by RestartStrategyConfiguration
    - restartStrategyConfiguration
```
RestartStrategies.RestartStrategyConfiguration restartStrategyConfiguration
```
    - isDynamicGraph
```
boolean isDynamicGraph
```
    - 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
    - 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.eventtime
- Class org.apache.flink.api.common.eventtime.TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - assigner
```
SerializableTimestampAssigner<T> assigner
```
- Class org.apache.flink.api.common.eventtime.Watermark extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - timestamp
```
long timestamp
```
      The timestamp of the watermark in milliseconds.
- Class org.apache.flink.api.common.eventtime.WatermarkAlignmentParams extends Object implements Serializable
  - Serialized Fields
    - maxAllowedWatermarkDrift
```
long maxAllowedWatermarkDrift
```
    - updateInterval
```
long updateInterval
```
    - watermarkGroup
```
String watermarkGroup
```
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.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.DelimitedInputFormatTest.MyTextInputFormat extends DelimitedInputFormat<String> implements Serializable
  
  serialVersionUID:
  
  1L
- 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 (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.FileOutputFormatTest.DummyFileOutputFormat extends FileOutputFormat<IntValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - testFileName
```
boolean testFileName
```
- 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.guava30.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.GenericDataSinkBaseTest extends Object implements Serializable
  - Serialized Fields
    - source
```
GenericDataSourceBase<OUT,T extends InputFormat<OUT,?>> source
```
- Class org.apache.flink.api.common.operators.GenericDataSourceBaseTest extends Object implements Serializable
- 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
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
  - Serialized Fields
    - cpuCores
```
CPUResource cpuCores
```
      How many cpu cores are needed. Can be null only if it is unknown.
    - taskHeapMemory
```
MemorySize taskHeapMemory
```
      How much task heap memory is needed.
    - taskOffHeapMemory
```
MemorySize taskOffHeapMemory
```
      How much task off-heap memory is needed.
    - managedMemory
```
MemorySize managedMemory
```
      How much managed memory is needed.
    - extendedResources
```
Map<K,V> extendedResources
```
- Class org.apache.flink.api.common.operators.SelectorFunctionKeysTest.KeySelector1 extends Object implements Serializable
- Class org.apache.flink.api.common.operators.SelectorFunctionKeysTest.KeySelector2 extends Object implements Serializable
- Class org.apache.flink.api.common.operators.SelectorFunctionKeysTest.KeySelector3 extends Object implements Serializable
- Class org.apache.flink.api.common.operators.SelectorFunctionKeysTest.KeySelector4 extends Object implements Serializable
- 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
- Class org.apache.flink.api.common.operators.SlotSharingGroup extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - name
```
String name
```
    - cpuCores
```
CPUResource cpuCores
```
      How many cpu cores are needed. Can be null only if it is unknown.
    - taskHeapMemory
```
MemorySize taskHeapMemory
```
      How much task heap memory is needed.
    - taskOffHeapMemory
```
MemorySize taskOffHeapMemory
```
      How much task off-heap memory is needed.
    - managedMemory
```
MemorySize managedMemory
```
      How much managed memory is needed.
    - externalResources
```
Map<K,V> externalResources
```
      A extensible field for user specified resources from SlotSharingGroup.
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
```
- Class org.apache.flink.api.common.operators.base.FlatMapOperatorCollectionTest extends Object implements Serializable
- Class org.apache.flink.api.common.operators.base.FlatMapOperatorCollectionTest.IdRichFlatMap extends RichFlatMapFunction<IN,IN> implements Serializable
  - Serialized Fields
    - isOpened
```
boolean isOpened
```
    - isClosed
```
boolean isClosed
```
- Class org.apache.flink.api.common.operators.base.InnerJoinOperatorBaseTest extends Object implements Serializable
- Class org.apache.flink.api.common.operators.base.MapOperatorTest extends Object implements Serializable
- Class org.apache.flink.api.common.operators.base.OuterJoinOperatorBaseTest extends Object implements Serializable
  - Serialized Fields
    - joiner
```
org.apache.flink.api.common.operators.base.OuterJoinOperatorBaseTest.MockRichFlatJoinFunction joiner
```
    - baseOperator
```
OuterJoinOperatorBase<IN1,IN2,OUT,FT extends FlatJoinFunction<IN1,IN2,OUT>> baseOperator
```
    - executionConfig
```
ExecutionConfig executionConfig
```
    - runtimeContext
```
RuntimeContext runtimeContext
```
- Class org.apache.flink.api.common.operators.base.PartitionMapOperatorTest extends Object implements Serializable
Package org.apache.flink.api.common.operators.util
- Class org.apache.flink.api.common.operators.util.NonRichGenericInputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partitionNumber
```
int partitionNumber
```
- Class org.apache.flink.api.common.operators.util.TestNonRichInputFormat extends org.apache.flink.api.common.operators.util.NonRichGenericInputFormat<String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - count
```
int count
```
- Class org.apache.flink.api.common.operators.util.TestNonRichOutputFormat extends Object implements Serializable
  - Serialized Fields
    - output
```
List<E> output
```
- Class org.apache.flink.api.common.operators.util.TestRichInputFormat extends GenericInputFormat<String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - count
```
int count
```
    - openCalled
```
boolean openCalled
```
    - closeCalled
```
boolean closeCalled
```
- Class org.apache.flink.api.common.operators.util.TestRichOutputFormat extends RichOutputFormat<String> implements Serializable
  - Serialized Fields
    - output
```
List<E> output
```
- 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.CPUResource extends Resource<CPUResource> implements Serializable
  
  serialVersionUID:
  
  7228645888210984393L
- Class org.apache.flink.api.common.resources.ExternalResource extends Resource<ExternalResource> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.resources.Resource extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - name
```
String name
```
    - value
```
BigDecimal value
```
- Class org.apache.flink.api.common.resources.TestResource extends Resource<org.apache.flink.api.common.resources.TestResource> implements Serializable
Package org.apache.flink.api.common.restartstrategy
- Class org.apache.flink.api.common.restartstrategy.RestartStrategies.ExponentialDelayRestartStrategyConfiguration extends RestartStrategies.RestartStrategyConfiguration implements Serializable
  
  serialVersionUID:
  
  1467941615941965194L
  - Serialized Fields
    - initialBackoff
```
Time initialBackoff
```
    - maxBackoff
```
Time maxBackoff
```
    - backoffMultiplier
```
double backoffMultiplier
```
    - resetBackoffThreshold
```
Time resetBackoffThreshold
```
    - jitterFactor
```
double jitterFactor
```
- 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.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
```
      The configuration of state time-to-live(TTL), it is disabled by default.
- Class org.apache.flink.api.common.state.StateTtlConfig extends Object implements Serializable
  
  serialVersionUID:
  
  -7592693245044289793L
  - Serialized Fields
    - updateType
```
StateTtlConfig.UpdateType updateType
```
    - stateVisibility
```
StateTtlConfig.StateVisibility stateVisibility
```
    - ttlTimeCharacteristic
```
StateTtlConfig.TtlTimeCharacteristic ttlTimeCharacteristic
```
    - 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.LocalTimeTypeInfo extends TypeInformation<T extends java.time.temporal.Temporal> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
    - serializer
```
TypeSerializer<T> serializer
```
    - comparatorClass
```
Class<T> comparatorClass
```
- 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.CompositeTypeSerializerSnapshotTest.NestedSerializer extends TypeSerializer<String> implements Serializable
  
  serialVersionUID:
  
  -6175000932620623446L
  - Serialized Fields
    - targetCompatibility
```
org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshotTest.TargetCompatibility targetCompatibility
```
- Class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshotTest.TestCompositeTypeSerializer extends TypeSerializer<String> implements Serializable
  
  serialVersionUID:
  
  -545688468997398105L
  - Serialized Fields
    - mockOuterSchemaCompatibility
```
CompositeTypeSerializerSnapshot.OuterSchemaCompatibility mockOuterSchemaCompatibility
```
    - nestedSerializers
```
TypeSerializer<T>[] nestedSerializers
```
- 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.TypeSerializerSerializationUtilTest extends Object implements Serializable
- Class org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtilTest.AbstractIntSerializer extends TypeSerializer<Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtilTest.TestIntSerializer extends org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtilTest.AbstractIntSerializer implements Serializable
  
  serialVersionUID:
  
  -3684467698271707216L
- 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.LocalDateComparator extends TypeComparator<java.time.LocalDate> implements Serializable
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
LocalDateComparator[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.LocalDateSerializer extends TypeSerializerSingleton<java.time.LocalDate> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.LocalDateTimeComparator extends TypeComparator<java.time.LocalDateTime> implements Serializable
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - dateComparator
```
LocalDateComparator dateComparator
```
    - timeComparator
```
LocalTimeComparator timeComparator
```
    - comparators
```
LocalDateTimeComparator[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.LocalDateTimeSerializer extends TypeSerializerSingleton<java.time.LocalDateTime> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.LocalTimeComparator extends BasicTypeComparator<java.time.LocalTime> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.LocalTimeSerializer extends TypeSerializerSingleton<java.time.LocalTime> implements Serializable
  
  serialVersionUID:
  
  1L
- 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.connector.sink
Package org.apache.flink.api.connector.sink2
Package org.apache.flink.api.connector.source
- Class org.apache.flink.api.connector.source.ReaderInfo extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - subtaskId
```
int subtaskId
```
    - location
```
String location
```
Package org.apache.flink.api.connector.source.lib
- Class org.apache.flink.api.connector.source.lib.NumberSequenceSource extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - from
```
long from
```
      The starting number in the sequence, inclusive.
    - to
```
long to
```
      The end number in the sequence, inclusive.
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.BlockingShuffleOutputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - intermediateDataSetId
```
AbstractID intermediateDataSetId
```
- 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.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.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.PojoParametrizedTypeExtractionTest.ConcreteMapFunction extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.DuplicateMapper extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.FancyCollectionSubtype extends HashSet<T> implements Serializable
  
  serialVersionUID:
  
  -3494469602638179921L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.FromTuple extends Tuple3<String,String,Long> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - special
```
int special
```
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyMapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyMapper2 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyMapper3 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyMapper4 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyMapper5 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyMapper6 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyMapper7 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyValue extends Object implements Serializable
  
  serialVersionUID:
  
  8607223484689147046L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.PojoTuple extends Tuple3<B,C,Long> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - extraField
```
Object extraField
```
- 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.TypeExtractorInputFormatsTest.DerivedInputFormat extends GenericInputFormat<Short> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorInputFormatsTest.DerivedTupleInputFormat extends GenericInputFormat<Tuple3<String,Short,Double>> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorInputFormatsTest.DummyFloatInputFormat extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorInputFormatsTest.FinalRelativeInputFormat extends org.apache.flink.api.java.typeutils.TypeExtractorInputFormatsTest.RelativeInputFormat<Integer> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorInputFormatsTest.QueryableInputFormat extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorInputFormatsTest.RelativeInputFormat extends GenericInputFormat<Tuple3<String,T,Double>> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.ChainedFour extends org.apache.flink.api.java.typeutils.TypeExtractorTest.ChainedThree implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.ChainedOne extends Tuple3<X,Long,Y> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.ChainedThree extends org.apache.flink.api.java.typeutils.TypeExtractorTest.ChainedTwo<String> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.ChainedTwo extends org.apache.flink.api.java.typeutils.TypeExtractorTest.ChainedOne<String,V> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.CustomArrayObject2 extends Tuple1<F> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.CustomTuple extends Tuple2<String,Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.CustomTuple2WithArray extends Tuple2<K[],K> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.DummyFlatMapFunction extends RichFlatMapFunction<Tuple2<A,B>,Tuple2<C,D>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.DuplicateValue extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.DuplicateValueNested extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.Edge extends Tuple3<K,K,V> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.EdgeMapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.EdgeMapper2 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.EdgeMapper3 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.EdgeMapper4 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.EitherMapper extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.EitherMapper2 extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.EitherMapper3 extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.FieldDuplicator extends RichMapFunction<T,Tuple2<T,T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.GenericArrayClass extends RichMapFunction<T[],T[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper extends RichMapFunction<T,T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper2 extends RichMapFunction<Tuple2<T,String>,T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper3 extends RichMapFunction<T,V> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper4 extends org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper<D> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper5 extends org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper<Tuple2<D,D>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.JoinWithCustomTuple2WithArray extends RichJoinFunction<org.apache.flink.api.java.typeutils.TypeExtractorTest.CustomTuple2WithArray<T>,org.apache.flink.api.java.typeutils.TypeExtractorTest.CustomTuple2WithArray<T>,org.apache.flink.api.java.typeutils.TypeExtractorTest.CustomTuple2WithArray<T>> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.LongKeyValue extends Tuple2<Long,V> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.Mapper extends org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper<String> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.Mapper2 extends org.apache.flink.api.java.typeutils.TypeExtractorTest.Mapper implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.MapperWithMultiDimGenericArray extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.MapWithResultTypeQueryable extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.MyQueryableMapper extends RichMapFunction<String,A> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.Nested extends Tuple2<V,Tuple2<T,T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.Nested2 extends org.apache.flink.api.java.typeutils.TypeExtractorTest.Nested<T,org.apache.flink.api.java.typeutils.TypeExtractorTest.Nested<Integer,T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.OneAppender extends RichMapFunction<T,Tuple2<T,Integer>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.SameTypeVariable extends Tuple2<X,X> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyEitherMapper extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyFaultyMapper extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyFaultyMapper2 extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyFaultyTypeInfo extends TypeInformation<org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyFaulty> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyOptionMapper extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyOptionTypeInfo extends TypeInformation<org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyOption<T>> implements Serializable
  - Serialized Fields
    - innerType
```
TypeInformation<T> innerType
```
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyTuple3Mapper extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyTupleMapperL1 extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyTupleMapperL2 extends org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyTupleMapperL1<C,Boolean> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyTupleTypeInfo extends TypeInformation<org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyTuple<T0,T1>> implements Serializable
  - Serialized Fields
    - field0
```
TypeInformation<T> field0
```
    - field1
```
TypeInformation<T> field1
```
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.WithFieldTypeInfoAnnotationMapper extends Object implements Serializable
- 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.ValueTypeInfoTest.AlternativeClass extends Object implements Serializable
  
  serialVersionUID:
  
  -163437084575260172L
- Class org.apache.flink.api.java.typeutils.ValueTypeInfoTest.TestClass extends Object implements Serializable
  
  serialVersionUID:
  
  -492760806806568285L
- 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.CopyableSerializerUpgradeTest.SimpleCopyable extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - value
```
long value
```
- 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.LegacyRowSerializerTest.MyPojo extends Object implements Serializable
  - Serialized Fields
    - name
```
String name
```
- 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:
  
  2L
  - 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
```
    - mask1
```
boolean[] mask1
```
    - mask2
```
boolean[] mask2
```
- Class org.apache.flink.api.java.typeutils.runtime.RowComparatorTest.MyPojo extends Object implements Serializable
  - Serialized Fields
    - name
```
String name
```
- 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
    - supportsRowKind
```
boolean supportsRowKind
```
    - rowKindOffset
```
int rowKindOffset
```
    - fieldSerializers
```
TypeSerializer<T>[] fieldSerializers
```
    - arity
```
int arity
```
    - positionByName
```
LinkedHashMap<K,V> positionByName
```
- Class org.apache.flink.api.java.typeutils.runtime.RowSerializerTest.MyPojo extends Object implements Serializable
  - Serialized Fields
    - name
```
String name
```
- 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
```
    - 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.ValueID extends Object implements Serializable
  
  serialVersionUID:
  
  -562791433077971752L
  - Serialized Fields
    - id
```
UUID id
```
- 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.ValueSerializerUpgradeTest.NameValue extends Object implements Serializable
  
  serialVersionUID:
  
  2277251654485371327L
  - Serialized Fields
    - name
```
String name
```
- 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.KryoClearedBufferTest.TestRecordSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.flink.api.java.typeutils.runtime.kryo.KryoClearedBufferTest.TestRecord> implements Serializable
  
  serialVersionUID:
  
  6971996565421454985L
- Class org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.DogKryoSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.Dog> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.DogV2KryoSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.Dog> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.ParrotKryoSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.Parrot> implements Serializable
  
  serialVersionUID:
  
  1L
- 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.KryoSerializerConcurrencyTest.TestSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializerConcurrencyTest.WrappedString> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.kryo.KryoWithCustomSerializersTest.LocalDateSerializer extends com.esotericsoftware.kryo.Serializer<org.joda.time.LocalDate> implements Serializable
  
  serialVersionUID:
  
  1L
- 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.AbstractParameterTool extends ExecutionConfig.GlobalJobParameters implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.utils.MultipleParameterTool extends AbstractParameterTool 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.ParameterTool extends AbstractParameterTool 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
```
      Deprecated.
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
```
    - fieldTypes
```
scala.collection.Seq<A> 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
    - getFlatComparators
```
TypeComparator<T>[] getFlatComparators
```
    - ascComp
```
boolean ascComp
```
    - intComparator
```
IntComparator intComparator
```
    - 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
    - getFlatComparators
```
TypeComparator<T>[] getFlatComparators
```
    - ascending
```
boolean ascending
```
    - typeComparator
```
TypeComparator<T> typeComparator
```
    - reference
```
scala.Option<A> reference
```
    - 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.guava30.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.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.BlockingIncrementingMapFunction extends RichMapFunction<Long,Long> implements Serializable
  - Serialized Fields
    - latchFilePath
```
String latchFilePath
```
- 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.configuration
- Class org.apache.flink.cep.configuration.SharedBufferCacheConfig extends Object implements Serializable
  - Serialized Fields
    - eventsBufferCacheSlots
```
int eventsBufferCacheSlots
```
    - entryCacheSlots
```
int entryCacheSlots
```
    - cacheStatisticsInterval
```
java.time.Duration cacheStatisticsInterval
```
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
```
      Deprecated.
- Class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferNodeSerializer extends TypeSerializerSingleton<SharedBufferNode> implements Serializable
  
  serialVersionUID:
  
  -6687780732295439832L
  - Serialized Fields
    - edgeSerializer
```
TypeSerializer<T> edgeSerializer
```
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
```
    - 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.deployment.application
- Class org.apache.flink.client.deployment.application.ApplicationExecutionException extends FlinkException implements Serializable
- Class org.apache.flink.client.deployment.application.UnsuccessfulExecutionException extends JobExecutionException implements Serializable
  - Serialized Fields
    - status
```
ApplicationStatus status
```
Package org.apache.flink.client.program
- Class org.apache.flink.client.program.MutatedConfigurationException extends Exception implements Serializable
  
  serialVersionUID:
  
  -2417524218857151612L
- Class org.apache.flink.client.program.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.connector.aws.util
- Class org.apache.flink.connector.aws.util.AWSAuthenticationException extends RuntimeException implements Serializable
Package org.apache.flink.connector.base.sink
- Class org.apache.flink.connector.base.sink.AsyncSinkBase extends Object implements Serializable
  - Serialized Fields
    - elementConverter
```
ElementConverter<InputT,RequestEntryT> elementConverter
```
    - maxBatchSize
```
int maxBatchSize
```
    - maxInFlightRequests
```
int maxInFlightRequests
```
    - maxBufferedRequests
```
int maxBufferedRequests
```
    - maxBatchSizeInBytes
```
long maxBatchSizeInBytes
```
    - maxTimeInBufferMS
```
long maxTimeInBufferMS
```
    - maxRecordSizeInBytes
```
long maxRecordSizeInBytes
```
Package org.apache.flink.connector.base.sink.writer
- Class org.apache.flink.connector.base.sink.writer.BufferedRequestState extends Object implements Serializable
  - Serialized Fields
    - bufferedRequestEntries
```
List<E> bufferedRequestEntries
```
    - stateSize
```
long stateSize
```
Package org.apache.flink.connector.base.source.hybrid
- Class org.apache.flink.connector.base.source.hybrid.HybridSource extends Object implements Serializable
  - Serialized Fields
    - sources
```
List<E> sources
```
- Class org.apache.flink.connector.base.source.hybrid.HybridSource.HybridSourceBuilder extends Object implements Serializable
  - Serialized Fields
    - sources
```
List<E> sources
```
- Class org.apache.flink.connector.base.source.hybrid.SourceReaderFinishedEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - sourceIndex
```
int sourceIndex
```
- Class org.apache.flink.connector.base.source.hybrid.SwitchSourceEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - sourceIndex
```
int sourceIndex
```
    - source
```
Source<T,SplitT extends SourceSplit,EnumChkT> source
```
    - finalSource
```
boolean finalSource
```
Package org.apache.flink.connector.datagen.table.types
- Class org.apache.flink.connector.datagen.table.types.DataGeneratorMapper extends Object implements Serializable
  - Serialized Fields
    - generator
```
DataGenerator<T> generator
```
    - mapper
```
SerializableFunction<T,R> mapper
```
- Class org.apache.flink.connector.datagen.table.types.DecimalDataRandomGenerator extends Object implements Serializable
  - Serialized Fields
    - precision
```
int precision
```
    - scale
```
int scale
```
    - min
```
double min
```
    - max
```
double max
```
- Class org.apache.flink.connector.datagen.table.types.RowDataGenerator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldGenerators
```
DataGenerator<T>[] fieldGenerators
```
    - fieldNames
```
List<E> fieldNames
```

Package org.apache.flink.connector.elasticsearch.sink

Class org.apache.flink.connector.elasticsearch.sink.ElasticsearchSink extends Object implements Serializable

Serialized Fields

hosts
```
List<E> hosts
```
emitter
```
ElasticsearchEmitter<T> emitter
```

buildBulkProcessorConfig

org.apache.flink.connector.elasticsearch.sink.BulkProcessorConfig buildBulkProcessorConfig

bulkProcessorBuilderFactory

org.apache.flink.connector.elasticsearch.sink.BulkProcessorBuilderFactory bulkProcessorBuilderFactory

networkClientConfig

org.apache.flink.connector.elasticsearch.sink.NetworkClientConfig networkClientConfig

deliveryGuarantee
```
DeliveryGuarantee deliveryGuarantee
```

Package org.apache.flink.connector.elasticsearch.table
- Class org.apache.flink.connector.elasticsearch.table.IndexGeneratorBase extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - index
```
String index
```
Package org.apache.flink.connector.file.sink
- Class org.apache.flink.connector.file.sink.FileSink extends Object implements Serializable
  - Serialized Fields
    - bucketsBuilder
```
org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,T extends org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,T>> bucketsBuilder
```
- Class org.apache.flink.connector.file.sink.FileSink.BulkFormatBuilder extends org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,T extends FileSink.BulkFormatBuilder<IN,T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - basePath
```
Path basePath
```
    - bucketCheckInterval
```
long bucketCheckInterval
```
    - writerFactory
```
BulkWriter.Factory<T> writerFactory
```
    - bucketFactory
```
FileWriterBucketFactory<IN> bucketFactory
```
    - bucketAssigner
```
BucketAssigner<IN,BucketID> bucketAssigner
```
    - rollingPolicy
```
CheckpointRollingPolicy<IN,BucketID> rollingPolicy
```
    - outputFileConfig
```
OutputFileConfig outputFileConfig
```
    - isCompactDisabledExplicitly
```
boolean isCompactDisabledExplicitly
```
    - compactStrategy
```
FileCompactStrategy compactStrategy
```
    - fileCompactor
```
FileCompactor fileCompactor
```
- Class org.apache.flink.connector.file.sink.FileSink.DefaultBulkFormatBuilder extends FileSink.BulkFormatBuilder<IN,FileSink.DefaultBulkFormatBuilder<IN>> implements Serializable
  
  serialVersionUID:
  
  7493169281036370228L
- Class org.apache.flink.connector.file.sink.FileSink.DefaultRowFormatBuilder extends FileSink.RowFormatBuilder<IN,FileSink.DefaultRowFormatBuilder<IN>> implements Serializable
  
  serialVersionUID:
  
  -8503344257202146718L
- Class org.apache.flink.connector.file.sink.FileSink.RowFormatBuilder extends org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,T extends FileSink.RowFormatBuilder<IN,T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - basePath
```
Path basePath
```
    - bucketCheckInterval
```
long bucketCheckInterval
```
    - encoder
```
Encoder<IN> encoder
```
    - bucketFactory
```
FileWriterBucketFactory<IN> bucketFactory
```
    - bucketAssigner
```
BucketAssigner<IN,BucketID> bucketAssigner
```
    - rollingPolicy
```
RollingPolicy<IN,BucketID> rollingPolicy
```
    - outputFileConfig
```
OutputFileConfig outputFileConfig
```
    - isCompactDisabledExplicitly
```
boolean isCompactDisabledExplicitly
```
    - compactStrategy
```
FileCompactStrategy compactStrategy
```
    - fileCompactor
```
FileCompactor fileCompactor
```
- Class org.apache.flink.connector.file.sink.FileSinkCommittable extends Object implements Serializable
  - Serialized Fields
    - bucketId
```
String bucketId
```
    - pendingFile
```
InProgressFileWriter.PendingFileRecoverable pendingFile
```
    - inProgressFileToCleanup
```
InProgressFileWriter.InProgressFileRecoverable inProgressFileToCleanup
```
    - compactedFileToCleanup
```
Path compactedFileToCleanup
```
Package org.apache.flink.connector.file.sink.compactor
- Class org.apache.flink.connector.file.sink.compactor.ConcatFileCompactor extends OutputStreamBasedFileCompactor implements Serializable
  - Serialized Fields
    - fileDelimiter
```
byte[] fileDelimiter
```
- Class org.apache.flink.connector.file.sink.compactor.DecoderBasedReader.Factory extends Object implements Serializable
  - Serialized Fields
    - decoderFactory
```
DecoderBasedReader.Decoder.Factory<T> decoderFactory
```
- Class org.apache.flink.connector.file.sink.compactor.FileCompactStrategy extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - sizeThreshold
```
long sizeThreshold
```
    - numCheckpointsBeforeCompaction
```
int numCheckpointsBeforeCompaction
```
    - numCompactThreads
```
int numCompactThreads
```
- Class org.apache.flink.connector.file.sink.compactor.IdenticalFileCompactor extends ConcatFileCompactor implements Serializable
- Class org.apache.flink.connector.file.sink.compactor.InputFormatBasedReader.Factory extends Object implements Serializable
  - Serialized Fields
    - inputFormatFactory
```
SerializableSupplierWithException<T,E extends Throwable> inputFormatFactory
```
- Class org.apache.flink.connector.file.sink.compactor.OutputStreamBasedFileCompactor extends Object implements Serializable
- Class org.apache.flink.connector.file.sink.compactor.RecordWiseFileCompactor extends Object implements Serializable
  - Serialized Fields
    - readerFactory
```
RecordWiseFileCompactor.Reader.Factory<T> readerFactory
```
- Class org.apache.flink.connector.file.sink.compactor.SimpleStringDecoder extends Object implements Serializable
  - Serialized Fields
    - reader
```
BufferedReader reader
```
Package org.apache.flink.connector.file.sink.compactor.operator
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinator extends AbstractStreamOperator<CompactorRequest> implements Serializable
  - Serialized Fields
    - strategy
```
FileCompactStrategy strategy
```
    - committableSerializer
```
SimpleVersionedSerializer<E> committableSerializer
```
    - packingRequests
```
Map<K,V> packingRequests
```
    - triggers
```
Map<K,V> triggers
```
    - remainingCommittableState
```
ListState<T> remainingCommittableState
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinatorFactory extends AbstractStreamOperatorFactory<CompactorRequest> implements Serializable
  - Serialized Fields
    - strategy
```
FileCompactStrategy strategy
```
    - committableSerializerSupplier
```
SerializableSupplierWithException<T,E extends Throwable> committableSerializerSupplier
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinatorStateHandler extends AbstractStreamOperator<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>> implements Serializable
  - Serialized Fields
    - committableSerializer
```
SimpleVersionedSerializer<E> committableSerializer
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinatorStateHandlerFactory extends AbstractStreamOperatorFactory<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>> implements Serializable
  - Serialized Fields
    - committableSerializerSupplier
```
SerializableSupplierWithException<T,E extends Throwable> committableSerializerSupplier
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorOperator extends AbstractStreamOperator<CommittableMessage<FileSinkCommittable>> implements Serializable
  - Serialized Fields
    - strategy
```
FileCompactStrategy strategy
```
    - committableSerializer
```
SimpleVersionedSerializer<E> committableSerializer
```
    - fileCompactor
```
FileCompactor fileCompactor
```
    - bucketWriter
```
BucketWriter<IN,BucketID> bucketWriter
```
    - collectingRequests
```
List<E> collectingRequests
```
    - checkpointRequests
```
TreeMap<K,V> checkpointRequests
```
    - compactingRequests
```
List<E> compactingRequests
```
    - remainingRequestsState
```
ListState<T> remainingRequestsState
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorFactory extends AbstractStreamOperatorFactory<CommittableMessage<FileSinkCommittable>> implements Serializable
  - Serialized Fields
    - strategy
```
FileCompactStrategy strategy
```
    - fileCompactor
```
FileCompactor fileCompactor
```
    - committableSerializerSupplier
```
SerializableSupplierWithException<T,E extends Throwable> committableSerializerSupplier
```
    - bucketWriterProvider
```
SerializableSupplierWithException<T,E extends Throwable> bucketWriterProvider
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandler extends AbstractStreamOperator<CommittableMessage<FileSinkCommittable>> implements Serializable
  - Serialized Fields
    - committableSerializer
```
SimpleVersionedSerializer<E> committableSerializer
```
    - bucketWriter
```
BucketWriter<IN,BucketID> bucketWriter
```
    - compactingRequests
```
List<E> compactingRequests
```
    - remainingRequestsState
```
SimpleVersionedListState<T> remainingRequestsState
```
    - stateRemaining
```
Iterable<T> stateRemaining
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandlerFactory extends AbstractStreamOperatorFactory<CommittableMessage<FileSinkCommittable>> implements Serializable
  - Serialized Fields
    - committableSerializerSupplier
```
SerializableSupplierWithException<T,E extends Throwable> committableSerializerSupplier
```
    - bucketWriterProvider
```
SerializableSupplierWithException<T,E extends Throwable> bucketWriterProvider
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest extends Object implements Serializable
  - Serialized Fields
    - bucketId
```
String bucketId
```
    - committableToCompact
```
List<E> committableToCompact
```
    - committableToPassthrough
```
List<E> committableToPassthrough
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorRequestTypeInfo extends TypeInformation<CompactorRequest> implements Serializable
  - Serialized Fields
    - committableSerializerSupplier
```
SerializableSupplierWithException<T,E extends Throwable> committableSerializerSupplier
```
Package org.apache.flink.connector.file.sink.writer
- Class org.apache.flink.connector.file.sink.writer.DefaultFileWriterBucketFactory extends Object implements Serializable
Package org.apache.flink.connector.file.src
- Class org.apache.flink.connector.file.src.AbstractFileSource extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - inputPaths
```
Path[] inputPaths
```
    - enumeratorFactory
```
FileEnumerator.Provider enumeratorFactory
```
    - assignerFactory
```
FileSplitAssigner.Provider assignerFactory
```
    - readerFormat
```
BulkFormat<T,SplitT extends FileSourceSplit> readerFormat
```
    - continuousEnumerationSettings
```
ContinuousEnumerationSettings continuousEnumerationSettings
```
- Class org.apache.flink.connector.file.src.ContinuousEnumerationSettings extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - discoveryInterval
```
java.time.Duration discoveryInterval
```
- Class org.apache.flink.connector.file.src.FileSource extends AbstractFileSource<T,FileSourceSplit> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.file.src.FileSourceSplit extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - id
```
String id
```
      The unique ID of the split. Unique within the scope of this source.
    - filePath
```
Path filePath
```
      The path of the file referenced by this split.
    - offset
```
long offset
```
      The position of the first byte in the file to process.
    - length
```
long length
```
      The number of bytes in the file to process.
    - fileModificationTime
```
long fileModificationTime
```
      The modification time of the file, from FileStatus.getModificationTime().
    - fileSize
```
long fileSize
```
      The file size in bytes, from FileStatus.getLen().
    - hostnames
```
String[] hostnames
```
      The names of the hosts storing this range of the file. Empty, if no host information is available.
    - readerPosition
```
CheckpointedPosition readerPosition
```
      The precise reader position in the split, to resume from.
Package org.apache.flink.connector.file.src.assigners
Package org.apache.flink.connector.file.src.enumerate
Package org.apache.flink.connector.file.src.impl
- Class org.apache.flink.connector.file.src.impl.FileRecordFormatAdapter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fileFormat
```
FileRecordFormat<T> fileFormat
```
      Deprecated.
- Class org.apache.flink.connector.file.src.impl.StreamFormatAdapter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - streamFormat
```
StreamFormat<T> streamFormat
```
Package org.apache.flink.connector.file.src.reader
- Class org.apache.flink.connector.file.src.reader.SimpleStreamFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.file.src.reader.TextLineFormat extends TextLineInputFormat implements Serializable
- Class org.apache.flink.connector.file.src.reader.TextLineInputFormat extends SimpleStreamFormat<String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - charsetName
```
String charsetName
```
Package org.apache.flink.connector.file.src.util
- Class org.apache.flink.connector.file.src.util.CheckpointedPosition extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - offset
```
long offset
```
    - recordsAfterOffset
```
long recordsAfterOffset
```
Package org.apache.flink.connector.file.table
- Class org.apache.flink.connector.file.table.DefaultPartTimeExtractor extends Object implements Serializable
  - Serialized Fields
    - extractorPattern
```
String extractorPattern
```
    - formatterPattern
```
String formatterPattern
```
- Class org.apache.flink.connector.file.table.DeserializationSchemaAdapter extends Object implements Serializable
  - Serialized Fields
    - deserializationSchema
```
DeserializationSchema<T> deserializationSchema
```
- Class org.apache.flink.connector.file.table.EmptyMetaStoreFactory extends Object implements Serializable
  - Serialized Fields
    - path
```
Path path
```
- Class org.apache.flink.connector.file.table.FileSystemOutputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fsFactory
```
FileSystemFactory fsFactory
```
    - msFactory
```
TableMetaStoreFactory msFactory
```
    - overwrite
```
boolean overwrite
```
    - tmpPath
```
Path tmpPath
```
    - partitionColumns
```
String[] partitionColumns
```
    - dynamicGrouped
```
boolean dynamicGrouped
```
    - staticPartitions
```
LinkedHashMap<K,V> staticPartitions
```
    - computer
```
PartitionComputer<T> computer
```
    - formatFactory
```
OutputFormatFactory<T> formatFactory
```
    - outputFileConfig
```
OutputFileConfig outputFileConfig
```
- Class org.apache.flink.connector.file.table.FileSystemTableSink.ProjectionBulkFactory extends Object implements Serializable
  - Serialized Fields
    - factory
```
BulkWriter.Factory<T> factory
```
    - computer
```
RowDataPartitionComputer computer
```
- Class org.apache.flink.connector.file.table.FileSystemTableSink.TableBucketAssigner extends Object implements Serializable
  - Serialized Fields
    - computer
```
PartitionComputer<T> computer
```
- Class org.apache.flink.connector.file.table.FileSystemTableSink.TableRollingPolicy extends CheckpointRollingPolicy<RowData,String> implements Serializable
  - Serialized Fields
    - rollOnCheckpoint
```
boolean rollOnCheckpoint
```
    - rollingFileSize
```
long rollingFileSize
```
    - rollingTimeInterval
```
long rollingTimeInterval
```
    - inactivityInterval
```
long inactivityInterval
```
- Class org.apache.flink.connector.file.table.LimitableBulkFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - format
```
BulkFormat<T,SplitT extends FileSourceSplit> format
```
    - limit
```
long limit
```
- Class org.apache.flink.connector.file.table.RowDataPartitionComputer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - defaultPartValue
```
String defaultPartValue
```
    - partitionColumns
```
String[] partitionColumns
```
    - partitionIndexes
```
int[] partitionIndexes
```
    - partitionTypes
```
LogicalType[] partitionTypes
```
    - partitionFieldGetters
```
RowData.FieldGetter[] partitionFieldGetters
```
    - nonPartitionIndexes
```
int[] nonPartitionIndexes
```
    - nonPartitionTypes
```
LogicalType[] nonPartitionTypes
```
    - nonPartitionFieldGetters
```
RowData.FieldGetter[] nonPartitionFieldGetters
```
- Class org.apache.flink.connector.file.table.RowPartitionComputer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - defaultPartValue
```
String defaultPartValue
```
    - partitionColumns
```
String[] partitionColumns
```
    - nonPartitionIndexes
```
int[] nonPartitionIndexes
```
    - partitionIndexes
```
int[] partitionIndexes
```
- Class org.apache.flink.connector.file.table.SerializationSchemaAdapter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - serializationSchema
```
SerializationSchema<T> serializationSchema
```
Package org.apache.flink.connector.file.table.stream
- Class org.apache.flink.connector.file.table.stream.AbstractStreamingWriter extends AbstractStreamOperator<OUT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - bucketCheckInterval
```
long bucketCheckInterval
```
    - bucketsBuilder
```
StreamingFileSink.BucketsBuilder<IN,BucketID,T extends StreamingFileSink.BucketsBuilder<IN,BucketID,T>> bucketsBuilder
```
- Class org.apache.flink.connector.file.table.stream.PartitionCommitInfo extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - checkpointId
```
long checkpointId
```
    - taskId
```
int taskId
```
    - numberOfTasks
```
int numberOfTasks
```
    - partitions
```
List<E> partitions
```
- Class org.apache.flink.connector.file.table.stream.PartitionCommitter extends AbstractStreamOperator<Void> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - conf
```
Configuration conf
```
    - locationPath
```
Path locationPath
```
    - tableIdentifier
```
ObjectIdentifier tableIdentifier
```
    - partitionKeys
```
List<E> partitionKeys
```
    - metaStoreFactory
```
TableMetaStoreFactory metaStoreFactory
```
    - fsFactory
```
FileSystemFactory fsFactory
```
- Class org.apache.flink.connector.file.table.stream.StreamingFileWriter extends AbstractStreamingWriter<IN,PartitionCommitInfo> implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - partitionKeys
```
List<E> partitionKeys
```
    - conf
```
Configuration conf
```
Package org.apache.flink.connector.file.table.stream.compact
- Class org.apache.flink.connector.file.table.stream.compact.CompactCoordinator extends AbstractStreamOperator<CompactMessages.CoordinatorOutput> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fsFactory
```
SupplierWithException<R,E extends Throwable> fsFactory
```
    - targetFileSize
```
long targetFileSize
```
- Class org.apache.flink.connector.file.table.stream.compact.CompactFileWriter extends AbstractStreamingWriter<T,CompactMessages.CoordinatorInput> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.file.table.stream.compact.CompactMessages.CompactionUnit extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - unitId
```
int unitId
```
    - partition
```
String partition
```
    - pathStrings
```
String[] pathStrings
```
- Class org.apache.flink.connector.file.table.stream.compact.CompactMessages.EndCheckpoint extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - checkpointId
```
long checkpointId
```
    - taskId
```
int taskId
```
    - numberOfTasks
```
int numberOfTasks
```
- Class org.apache.flink.connector.file.table.stream.compact.CompactMessages.EndCompaction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - checkpointId
```
long checkpointId
```
- Class org.apache.flink.connector.file.table.stream.compact.CompactMessages.InputFile extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partition
```
String partition
```
    - file
```
Path file
```
- Class org.apache.flink.connector.file.table.stream.compact.CompactOperator extends AbstractStreamOperator<PartitionCommitInfo> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fsFactory
```
SupplierWithException<R,E extends Throwable> fsFactory
```
    - readerFactory
```
CompactReader.Factory<T> readerFactory
```
    - writerFactory
```
CompactWriter.Factory<T> writerFactory
```
Package org.apache.flink.connector.firehose.sink
- Class org.apache.flink.connector.firehose.sink.KinesisFirehoseSink extends AsyncSinkBase<InputT,software.amazon.awssdk.services.firehose.model.Record> implements Serializable
  - Serialized Fields
    - failOnError
```
boolean failOnError
```
    - deliveryStreamName
```
String deliveryStreamName
```
    - firehoseClientProperties
```
Properties firehoseClientProperties
```
- Class org.apache.flink.connector.firehose.sink.KinesisFirehoseSinkElementConverter extends Object implements Serializable
  - Serialized Fields
    - serializationSchema
```
SerializationSchema<T> serializationSchema
```
      A serialization schema to specify how the input element should be serialized.
Package org.apache.flink.connector.hbase.options
- Class org.apache.flink.connector.hbase.options.HBaseLookupOptions extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - cacheMaxSize
```
long cacheMaxSize
```
    - cacheExpireMs
```
long cacheExpireMs
```
    - maxRetryTimes
```
int maxRetryTimes
```
    - lookupAsync
```
boolean lookupAsync
```
- Class org.apache.flink.connector.hbase.options.HBaseWriteOptions extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - bufferFlushMaxSizeInBytes
```
long bufferFlushMaxSizeInBytes
```
    - bufferFlushMaxRows
```
long bufferFlushMaxRows
```
    - bufferFlushIntervalMillis
```
long bufferFlushIntervalMillis
```
    - parallelism
```
Integer parallelism
```
Package org.apache.flink.connector.hbase.sink
- Class org.apache.flink.connector.hbase.sink.HBaseSinkFunction extends RichSinkFunction<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hTableName
```
String hTableName
```
    - serializedConfig
```
byte[] serializedConfig
```
    - bufferFlushMaxSizeInBytes
```
long bufferFlushMaxSizeInBytes
```
    - bufferFlushMaxMutations
```
long bufferFlushMaxMutations
```
    - bufferFlushIntervalMillis
```
long bufferFlushIntervalMillis
```
    - mutationConverter
```
HBaseMutationConverter<T> mutationConverter
```
    - failureThrowable
```
AtomicReference<V> failureThrowable
```
      This is set from inside the BufferedMutator.ExceptionListener if a Throwable was thrown.
      Errors will be checked and rethrown before processing each input element, and when the sink is closed.
- Class org.apache.flink.connector.hbase.sink.RowDataToMutationConverter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - schema
```
HBaseTableSchema schema
```
    - nullStringLiteral
```
String nullStringLiteral
```
Package org.apache.flink.connector.hbase.source
- Class org.apache.flink.connector.hbase.source.HBaseRowDataLookupFunction extends TableFunction<RowData> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hTableName
```
String hTableName
```
    - serializedConfig
```
byte[] serializedConfig
```
    - hbaseTableSchema
```
HBaseTableSchema hbaseTableSchema
```
    - nullStringLiteral
```
String nullStringLiteral
```
    - cacheMaxSize
```
long cacheMaxSize
```
    - cacheExpireMs
```
long cacheExpireMs
```
    - maxRetryTimes
```
int maxRetryTimes
```
- Class org.apache.flink.connector.hbase.source.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.connector.hbase.util
- Class org.apache.flink.connector.hbase.util.HBaseTableSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - familyMap
```
Map<K,V> familyMap
```
    - rowKeyInfo
```
org.apache.flink.connector.hbase.util.HBaseTableSchema.RowKeyInfo rowKeyInfo
```
    - charset
```
String charset
```
Package org.apache.flink.connector.hbase1.source
- Class org.apache.flink.connector.hbase1.source.AbstractTableInputFormat extends RichInputFormat<T,TableInputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - endReached
```
boolean endReached
```
    - resultScanner
```
org.apache.hadoop.hbase.client.ResultScanner resultScanner
```
      HBase iterator wrapper.
    - currentRow
```
byte[] currentRow
```
    - scannedRows
```
long scannedRows
```
    - serializedConfig
```
byte[] serializedConfig
```
- Class org.apache.flink.connector.hbase1.source.HBaseRowDataInputFormat extends AbstractTableInputFormat<RowData> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableName
```
String tableName
```
    - schema
```
HBaseTableSchema schema
```
    - nullStringLiteral
```
String nullStringLiteral
```
Package org.apache.flink.connector.hbase2.source
- Class org.apache.flink.connector.hbase2.source.AbstractTableInputFormat extends RichInputFormat<T,TableInputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - endReached
```
boolean endReached
```
    - resultScanner
```
org.apache.hadoop.hbase.client.ResultScanner resultScanner
```
      HBase iterator wrapper.
    - currentRow
```
byte[] currentRow
```
    - scannedRows
```
long scannedRows
```
    - serializedConfig
```
byte[] serializedConfig
```
- Class org.apache.flink.connector.hbase2.source.HBaseRowDataAsyncLookupFunction extends AsyncTableFunction<RowData> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hTableName
```
String hTableName
```
    - serializedConfig
```
byte[] serializedConfig
```
    - hbaseTableSchema
```
HBaseTableSchema hbaseTableSchema
```
    - nullStringLiteral
```
String nullStringLiteral
```
    - cacheMaxSize
```
long cacheMaxSize
```
    - cacheExpireMs
```
long cacheExpireMs
```
    - maxRetryTimes
```
int maxRetryTimes
```
- Class org.apache.flink.connector.hbase2.source.HBaseRowDataInputFormat extends AbstractTableInputFormat<RowData> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableName
```
String tableName
```
    - schema
```
HBaseTableSchema schema
```
    - nullStringLiteral
```
String nullStringLiteral
```
Package org.apache.flink.connector.jdbc
- Class org.apache.flink.connector.jdbc.JdbcConnectionOptions extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - url
```
String url
```
    - driverName
```
String driverName
```
    - connectionCheckTimeoutSeconds
```
int connectionCheckTimeoutSeconds
```
    - username
```
String username
```
    - password
```
String password
```
- Class org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions extends Object implements Serializable
  - Serialized Fields
    - discoverAndRollbackOnRecovery
```
boolean discoverAndRollbackOnRecovery
```
    - maxCommitAttempts
```
int maxCommitAttempts
```
    - allowOutOfOrderCommits
```
boolean allowOutOfOrderCommits
```
    - timeoutSec
```
Integer timeoutSec
```
    - transactionPerConnection
```
boolean transactionPerConnection
```
- Class org.apache.flink.connector.jdbc.JdbcExecutionOptions extends Object implements Serializable
  - Serialized Fields
    - batchIntervalMs
```
long batchIntervalMs
```
    - batchSize
```
int batchSize
```
    - maxRetries
```
int maxRetries
```
- Class org.apache.flink.connector.jdbc.JdbcInputFormat extends RichInputFormat<Row,InputSplit> implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - connectionProvider
```
JdbcConnectionProvider connectionProvider
```
    - queryTemplate
```
String queryTemplate
```
    - resultSetType
```
int resultSetType
```
    - resultSetConcurrency
```
int resultSetConcurrency
```
    - rowTypeInfo
```
RowTypeInfo rowTypeInfo
```
    - fetchSize
```
int fetchSize
```
    - autoCommit
```
Boolean autoCommit
```
    - hasNext
```
boolean hasNext
```
    - parameterValues
```
Object[][] parameterValues
```
- Class org.apache.flink.connector.jdbc.JdbcRowOutputFormat extends JdbcOutputFormat<Row,Row,JdbcBatchStatementExecutor<Row>> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.connector.jdbc.converter
- Class org.apache.flink.connector.jdbc.converter.AbstractJdbcRowConverter extends Object implements Serializable
  - Serialized Fields
    - rowType
```
RowType rowType
```
    - toInternalConverters
```
AbstractJdbcRowConverter.JdbcDeserializationConverter[] toInternalConverters
```
    - toExternalConverters
```
AbstractJdbcRowConverter.JdbcSerializationConverter[] toExternalConverters
```
    - fieldTypes
```
LogicalType[] fieldTypes
```
Package org.apache.flink.connector.jdbc.dialect
- Class org.apache.flink.connector.jdbc.dialect.AbstractDialect extends Object implements Serializable
Package org.apache.flink.connector.jdbc.dialect.mysql
- Class org.apache.flink.connector.jdbc.dialect.mysql.MySqlDialect extends AbstractDialect implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.connector.jdbc.dialect.psql
- Class org.apache.flink.connector.jdbc.dialect.psql.PostgresDialect extends AbstractDialect implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.connector.jdbc.internal
- Class org.apache.flink.connector.jdbc.internal.GenericJdbcSinkFunction extends RichSinkFunction<T> implements Serializable
  - Serialized Fields
    - outputFormat
```
JdbcOutputFormat<In,JdbcIn,JdbcExec extends JdbcBatchStatementExecutor<JdbcIn>> outputFormat
```
- Class org.apache.flink.connector.jdbc.internal.JdbcOutputFormat extends RichOutputFormat<In> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - connectionProvider
```
JdbcConnectionProvider connectionProvider
```
    - serializer
```
TypeSerializer<T> serializer
```
    - executionOptions
```
JdbcExecutionOptions executionOptions
```
    - statementExecutorFactory
```
JdbcOutputFormat.StatementExecutorFactory<T extends JdbcBatchStatementExecutor<?>> statementExecutorFactory
```
    - jdbcRecordExtractor
```
JdbcOutputFormat.RecordExtractor<F,T> jdbcRecordExtractor
```
Package org.apache.flink.connector.jdbc.internal.connection
- Class org.apache.flink.connector.jdbc.internal.connection.SimpleJdbcConnectionProvider extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jdbcOptions
```
JdbcConnectionOptions jdbcOptions
```
Package org.apache.flink.connector.jdbc.internal.converter
- Class org.apache.flink.connector.jdbc.internal.converter.DerbyRowConverter extends AbstractJdbcRowConverter implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.jdbc.internal.converter.MySQLRowConverter extends AbstractJdbcRowConverter implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter extends AbstractJdbcRowConverter implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.jdbc.internal.converter.PostgresRowConverter extends AbstractJdbcRowConverter implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.connector.jdbc.internal.options
- Class org.apache.flink.connector.jdbc.internal.options.JdbcConnectorOptions extends JdbcConnectionOptions implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableName
```
String tableName
```
    - dialect
```
JdbcDialect dialect
```
    - parallelism
```
Integer parallelism
```
- Class org.apache.flink.connector.jdbc.internal.options.JdbcDmlOptions extends org.apache.flink.connector.jdbc.internal.options.JdbcTypedQueryOptions implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldNames
```
String[] fieldNames
```
    - keyFields
```
String[] keyFields
```
    - tableName
```
String tableName
```
    - dialect
```
JdbcDialect dialect
```
- Class org.apache.flink.connector.jdbc.internal.options.JdbcInsertOptions extends org.apache.flink.connector.jdbc.internal.options.JdbcTypedQueryOptions implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - query
```
String query
```
- Class org.apache.flink.connector.jdbc.internal.options.JdbcLookupOptions extends Object implements Serializable
  - Serialized Fields
    - cacheMaxSize
```
long cacheMaxSize
```
    - cacheExpireMs
```
long cacheExpireMs
```
    - maxRetryTimes
```
int maxRetryTimes
```
    - cacheMissingKey
```
boolean cacheMissingKey
```
- Class org.apache.flink.connector.jdbc.internal.options.JdbcReadOptions extends Object implements Serializable
  - Serialized Fields
    - query
```
String query
```
    - partitionColumnName
```
String partitionColumnName
```
    - partitionLowerBound
```
Long partitionLowerBound
```
    - partitionUpperBound
```
Long partitionUpperBound
```
    - numPartitions
```
Integer numPartitions
```
    - fetchSize
```
int fetchSize
```
    - autoCommit
```
boolean autoCommit
```
Package org.apache.flink.connector.jdbc.table
- Class org.apache.flink.connector.jdbc.table.JdbcOutputFormatBuilder extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jdbcOptions
```
JdbcConnectorOptions jdbcOptions
```
    - executionOptions
```
JdbcExecutionOptions executionOptions
```
    - dmlOptions
```
JdbcDmlOptions dmlOptions
```
    - rowDataTypeInformation
```
TypeInformation<T> rowDataTypeInformation
```
    - fieldDataTypes
```
DataType[] fieldDataTypes
```
- Class org.apache.flink.connector.jdbc.table.JdbcRowDataInputFormat extends RichInputFormat<RowData,InputSplit> implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - connectionProvider
```
JdbcConnectionProvider connectionProvider
```
    - fetchSize
```
int fetchSize
```
    - autoCommit
```
Boolean autoCommit
```
    - parameterValues
```
Object[][] parameterValues
```
    - queryTemplate
```
String queryTemplate
```
    - resultSetType
```
int resultSetType
```
    - resultSetConcurrency
```
int resultSetConcurrency
```
    - rowConverter
```
JdbcRowConverter rowConverter
```
    - rowDataTypeInfo
```
TypeInformation<T> rowDataTypeInfo
```
- Class org.apache.flink.connector.jdbc.table.JdbcRowDataLookupFunction extends TableFunction<RowData> implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - query
```
String query
```
    - connectionProvider
```
JdbcConnectionProvider connectionProvider
```
    - keyTypes
```
DataType[] keyTypes
```
    - keyNames
```
String[] keyNames
```
    - cacheMaxSize
```
long cacheMaxSize
```
    - cacheExpireMs
```
long cacheExpireMs
```
    - maxRetryTimes
```
int maxRetryTimes
```
    - cacheMissingKey
```
boolean cacheMissingKey
```
    - jdbcDialect
```
JdbcDialect jdbcDialect
```
    - jdbcRowConverter
```
JdbcRowConverter jdbcRowConverter
```
    - lookupKeyRowConverter
```
JdbcRowConverter lookupKeyRowConverter
```
Package org.apache.flink.connector.jdbc.xa
- Class org.apache.flink.connector.jdbc.xa.CheckpointAndXidSerializer extends TypeSerializer<CheckpointAndXid> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - xidSerializer
```
TypeSerializer<T> xidSerializer
```
- Class org.apache.flink.connector.jdbc.xa.JdbcXaSinkFunction extends AbstractRichFunction implements Serializable
  - Serialized Fields
    - xaFacade
```
XaFacade xaFacade
```
    - xaGroupOps
```
org.apache.flink.connector.jdbc.xa.XaGroupOps xaGroupOps
```
    - xidGenerator
```
XidGenerator xidGenerator
```
    - outputFormat
```
JdbcOutputFormat<In,JdbcIn,JdbcExec extends JdbcBatchStatementExecutor<JdbcIn>> outputFormat
```
    - stateHandler
```
org.apache.flink.connector.jdbc.xa.XaSinkStateHandler stateHandler
```
    - options
```
JdbcExactlyOnceOptions options
```
- Class org.apache.flink.connector.jdbc.xa.XaFacade.EmptyXaTransactionException extends FlinkRuntimeException implements Serializable
  - Serialized Fields
    - xid
```
Xid xid
```
- Class org.apache.flink.connector.jdbc.xa.XaFacade.TransientXaException extends FlinkRuntimeException implements Serializable
- Class org.apache.flink.connector.jdbc.xa.XaSinkStateSerializer extends TypeSerializer<org.apache.flink.connector.jdbc.xa.JdbcXaSinkFunctionState> implements Serializable
  - Serialized Fields
    - xidSerializer
```
TypeSerializer<T> xidSerializer
```
    - checkpointAndXidSerializer
```
TypeSerializer<T> checkpointAndXidSerializer
```
- Class org.apache.flink.connector.jdbc.xa.XidSerializer extends TypeSerializer<Xid> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.connector.kafka.sink
- Class org.apache.flink.connector.kafka.sink.KafkaSink extends Object implements Serializable
  - Serialized Fields
    - deliveryGuarantee
```
DeliveryGuarantee deliveryGuarantee
```
    - recordSerializer
```
KafkaRecordSerializationSchema<T> recordSerializer
```
    - kafkaProducerConfig
```
Properties kafkaProducerConfig
```
    - transactionalIdPrefix
```
String transactionalIdPrefix
```
Package org.apache.flink.connector.kafka.source
- Class org.apache.flink.connector.kafka.source.KafkaSource extends Object implements Serializable
  
  serialVersionUID:
  
  -8755372893283732098L
  - Serialized Fields
    - subscriber
```
KafkaSubscriber subscriber
```
    - startingOffsetsInitializer
```
OffsetsInitializer startingOffsetsInitializer
```
    - stoppingOffsetsInitializer
```
OffsetsInitializer stoppingOffsetsInitializer
```
    - boundedness
```
Boundedness boundedness
```
    - deserializationSchema
```
KafkaRecordDeserializationSchema<T> deserializationSchema
```
    - props
```
Properties props
```
Package org.apache.flink.connector.kafka.source.enumerator.initializer
- Class org.apache.flink.connector.kafka.source.enumerator.initializer.NoStoppingOffsetsInitializer extends Object implements Serializable
  
  serialVersionUID:
  
  4186323669290142732L
Package org.apache.flink.connector.kafka.source.enumerator.subscriber
Package org.apache.flink.connector.kafka.source.reader.deserializer
Package org.apache.flink.connector.kinesis.sink
- Class org.apache.flink.connector.kinesis.sink.KinesisStreamsSink extends AsyncSinkBase<InputT,software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry> implements Serializable
  - Serialized Fields
    - failOnError
```
boolean failOnError
```
    - streamName
```
String streamName
```
    - kinesisClientProperties
```
Properties kinesisClientProperties
```
- Class org.apache.flink.connector.kinesis.sink.KinesisStreamsSinkElementConverter extends Object implements Serializable
  - Serialized Fields
    - serializationSchema
```
SerializationSchema<T> serializationSchema
```
      A serialization schema to specify how the input element should be serialized.
    - partitionKeyGenerator
```
PartitionKeyGenerator<InputT> partitionKeyGenerator
```
      A partition key generator functional interface that produces a string from the input element.
Package org.apache.flink.connector.kinesis.table
- Class org.apache.flink.connector.kinesis.table.FixedKinesisPartitionKeyGenerator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - indexOfThisSubtask
```
int indexOfThisSubtask
```
- Class org.apache.flink.connector.kinesis.table.RandomKinesisPartitionKeyGenerator extends Object implements Serializable
- Class org.apache.flink.connector.kinesis.table.RowDataFieldsKinesisPartitionKeyGenerator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - delimiter
```
String delimiter
```
      The character used to delimit field values in the concatenated partition key string.
    - fieldNames
```
List<E> fieldNames
```
      A list of field names used to extract the partition key for a record that will be written to a Kinesis stream.
    - dynamicFieldGetters
```
Map<K,V> dynamicFieldGetters
```
      A map of getter functions to dynamically extract the field values for all RowDataFieldsKinesisPartitionKeyGenerator.fieldNames from an input record.
    - keyBuffer
```
StringBuilder keyBuffer
```
      A buffer used to accumulate the concatenation of all field values that form the partition key.
    - staticFields
```
Map<K,V> staticFields
```
      A prefix of static field values to be used instead of the corresponding RowDataFieldsKinesisPartitionKeyGenerator.dynamicFieldGetters entries.
    - keyBufferStaticPrefixLength
```
int keyBufferStaticPrefixLength
```
      The length of the static prefix of the RowDataFieldsKinesisPartitionKeyGenerator.keyBuffer (derived from the values in RowDataFieldsKinesisPartitionKeyGenerator.staticFields).
    - fieldNamesStaticPrefixLength
```
int fieldNamesStaticPrefixLength
```
      The length of the prefix in RowDataFieldsKinesisPartitionKeyGenerator.fieldNames for which static field values are present in RowDataFieldsKinesisPartitionKeyGenerator.staticFields.
Package org.apache.flink.connector.pulsar.common.config
- Class org.apache.flink.connector.pulsar.common.config.PulsarConfiguration extends UnmodifiableConfiguration implements Serializable
  
  serialVersionUID:
  
  3050894147145572345L
Package org.apache.flink.connector.pulsar.common.schema
- Class org.apache.flink.connector.pulsar.common.schema.PulsarSchema extends Object implements Serializable
  
  serialVersionUID:
  
  -2561088131419607555L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream ois)
                 throws ClassNotFoundException,
                        IOException
```
      Throws:
      
      ClassNotFoundException
      
      IOException
    - writeObject
```
private void writeObject(ObjectOutputStream oos)
                  throws IOException
```
      Throws:
      
      IOException
- Class org.apache.flink.connector.pulsar.common.schema.PulsarSchemaTypeInformation extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  7284667318651333519L
  - Serialized Fields
    - schema
```
PulsarSchema<T> schema
```
- Class org.apache.flink.connector.pulsar.common.schema.PulsarSchemaTypeSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  7771153330969433085L
  - Serialized Fields
    - schema
```
PulsarSchema<T> schema
```
Package org.apache.flink.connector.pulsar.sink
- Class org.apache.flink.connector.pulsar.sink.PulsarSink extends Object implements Serializable
  
  serialVersionUID:
  
  4416714587951282119L
  - Serialized Fields
    - sinkConfiguration
```
SinkConfiguration sinkConfiguration
```
    - serializationSchema
```
PulsarSerializationSchema<IN> serializationSchema
```
    - metadataListener
```
TopicMetadataListener metadataListener
```
    - messageDelayer
```
MessageDelayer<IN> messageDelayer
```
    - topicRouter
```
TopicRouter<IN> topicRouter
```
Package org.apache.flink.connector.pulsar.sink.config
- Class org.apache.flink.connector.pulsar.sink.config.SinkConfiguration extends PulsarConfiguration implements Serializable
  
  serialVersionUID:
  
  4941360605051251153L
  - Serialized Fields
    - deliveryGuarantee
```
DeliveryGuarantee deliveryGuarantee
```
    - transactionTimeoutMillis
```
long transactionTimeoutMillis
```
    - topicMetadataRefreshInterval
```
long topicMetadataRefreshInterval
```
    - partitionSwitchSize
```
int partitionSwitchSize
```
    - messageKeyHash
```
MessageKeyHash messageKeyHash
```
    - enableSchemaEvolution
```
boolean enableSchemaEvolution
```
    - maxPendingMessages
```
int maxPendingMessages
```
    - maxRecommitTimes
```
int maxRecommitTimes
```
Package org.apache.flink.connector.pulsar.sink.writer.delayer
- Class org.apache.flink.connector.pulsar.sink.writer.delayer.FixedMessageDelayer extends Object implements Serializable
  
  serialVersionUID:
  
  -7550834520312097614L
  - Serialized Fields
    - delayDuration
```
long delayDuration
```
Package org.apache.flink.connector.pulsar.sink.writer.router
- Class org.apache.flink.connector.pulsar.sink.writer.router.KeyHashTopicRouter extends Object implements Serializable
  
  serialVersionUID:
  
  2475614648095079804L
  - Serialized Fields
    - messageKeyHash
```
MessageKeyHash messageKeyHash
```
- Class org.apache.flink.connector.pulsar.sink.writer.router.RoundRobinTopicRouter extends Object implements Serializable
  
  serialVersionUID:
  
  -1160533263474038206L
  - Serialized Fields
    - counter
```
AtomicLong counter
```
      The internal counter for counting the messages.
    - partitionSwitchSize
```
int partitionSwitchSize
```
      The size when we switch to another topic.
Package org.apache.flink.connector.pulsar.sink.writer.serializer
- Class org.apache.flink.connector.pulsar.sink.writer.serializer.PulsarSchemaWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  -2567052498398184194L
  - Serialized Fields
    - pulsarSchema
```
PulsarSchema<T> pulsarSchema
```
- Class org.apache.flink.connector.pulsar.sink.writer.serializer.PulsarSerializationSchemaWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  4948155843623161119L
  - Serialized Fields
    - serializationSchema
```
SerializationSchema<T> serializationSchema
```
Package org.apache.flink.connector.pulsar.sink.writer.topic
- Class org.apache.flink.connector.pulsar.sink.writer.topic.TopicMetadataListener extends Object implements Serializable
  
  serialVersionUID:
  
  6186948471557507522L
  - Serialized Fields
    - partitionedTopics
```
org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableList<E> partitionedTopics
```
    - topicMetadata
```
Map<K,V> topicMetadata
```
    - availableTopics
```
org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableList<E> availableTopics
```
Package org.apache.flink.connector.pulsar.source
- Class org.apache.flink.connector.pulsar.source.PulsarSource extends Object implements Serializable
  
  serialVersionUID:
  
  7773108631275567433L
  - Serialized Fields
    - sourceConfiguration
```
SourceConfiguration sourceConfiguration
```
      The configuration for pulsar source, we don't support the pulsar's configuration class directly.
    - subscriber
```
PulsarSubscriber subscriber
```
    - rangeGenerator
```
RangeGenerator rangeGenerator
```
    - startCursor
```
StartCursor startCursor
```
    - stopCursor
```
StopCursor stopCursor
```
    - boundedness
```
Boundedness boundedness
```
    - deserializationSchema
```
PulsarDeserializationSchema<T> deserializationSchema
```
      The pulsar deserialization schema used for deserializing message.
Package org.apache.flink.connector.pulsar.source.config
- Class org.apache.flink.connector.pulsar.source.config.SourceConfiguration extends PulsarConfiguration implements Serializable
  
  serialVersionUID:
  
  8488507275800787580L
  - Serialized Fields
    - messageQueueCapacity
```
int messageQueueCapacity
```
    - partitionDiscoveryIntervalMs
```
long partitionDiscoveryIntervalMs
```
    - enableAutoAcknowledgeMessage
```
boolean enableAutoAcknowledgeMessage
```
    - autoCommitCursorInterval
```
long autoCommitCursorInterval
```
    - transactionTimeoutMillis
```
long transactionTimeoutMillis
```
    - maxFetchTime
```
java.time.Duration maxFetchTime
```
    - maxFetchRecords
```
int maxFetchRecords
```
    - verifyInitialOffsets
```
CursorVerification verifyInitialOffsets
```
    - subscriptionName
```
String subscriptionName
```
    - subscriptionType
```
org.apache.pulsar.client.api.SubscriptionType subscriptionType
```
    - subscriptionMode
```
org.apache.pulsar.client.api.SubscriptionMode subscriptionMode
```
Package org.apache.flink.connector.pulsar.source.enumerator.cursor
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.CursorPosition extends Object implements Serializable
  
  serialVersionUID:
  
  -802405183307684549L
  - Serialized Fields
    - type
```
CursorPosition.Type type
```
    - messageId
```
org.apache.pulsar.client.api.MessageId messageId
```
    - timestamp
```
Long timestamp
```
Package org.apache.flink.connector.pulsar.source.enumerator.cursor.start
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.start.MessageIdStartCursor extends Object implements Serializable
  
  serialVersionUID:
  
  -8057345435887170111L
  - Serialized Fields
    - messageId
```
org.apache.pulsar.client.api.MessageId messageId
```
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.start.TimestampStartCursor extends Object implements Serializable
  
  serialVersionUID:
  
  5170578885838095320L
  - Serialized Fields
    - timestamp
```
long timestamp
```
Package org.apache.flink.connector.pulsar.source.enumerator.cursor.stop
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.stop.EventTimestampStopCursor extends Object implements Serializable
  
  serialVersionUID:
  
  2391576769339369027L
  - Serialized Fields
    - timestamp
```
long timestamp
```
    - inclusive
```
boolean inclusive
```
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.stop.LatestMessageStopCursor extends Object implements Serializable
  
  serialVersionUID:
  
  1702059838323965723L
  - Serialized Fields
    - messageId
```
org.apache.pulsar.client.api.MessageId messageId
```
    - inclusive
```
boolean inclusive
```
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.stop.MessageIdStopCursor extends Object implements Serializable
  
  serialVersionUID:
  
  -3990454110809274542L
  - Serialized Fields
    - messageId
```
org.apache.pulsar.client.api.MessageId messageId
```
    - inclusive
```
boolean inclusive
```
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.stop.NeverStopCursor extends Object implements Serializable
  
  serialVersionUID:
  
  -3113601090292771786L
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.stop.PublishTimestampStopCursor extends Object implements Serializable
  
  serialVersionUID:
  
  4386276745339324527L
  - Serialized Fields
    - timestamp
```
long timestamp
```
    - inclusive
```
boolean inclusive
```
Package org.apache.flink.connector.pulsar.source.enumerator.subscriber
Package org.apache.flink.connector.pulsar.source.enumerator.subscriber.impl
- Class org.apache.flink.connector.pulsar.source.enumerator.subscriber.impl.BasePulsarSubscriber extends Object implements Serializable
  
  serialVersionUID:
  
  2053021503331058888L
- Class org.apache.flink.connector.pulsar.source.enumerator.subscriber.impl.TopicListSubscriber extends BasePulsarSubscriber implements Serializable
  
  serialVersionUID:
  
  6473918213832993116L
  - Serialized Fields
    - partitions
```
List<E> partitions
```
    - fullTopicNames
```
List<E> fullTopicNames
```
- Class org.apache.flink.connector.pulsar.source.enumerator.subscriber.impl.TopicPatternSubscriber extends BasePulsarSubscriber implements Serializable
  
  serialVersionUID:
  
  3307710093243745104L
  - Serialized Fields
    - topicPattern
```
Pattern topicPattern
```
    - subscriptionMode
```
org.apache.pulsar.client.api.RegexSubscriptionMode subscriptionMode
```
    - namespace
```
String namespace
```
Package org.apache.flink.connector.pulsar.source.enumerator.topic
- Class org.apache.flink.connector.pulsar.source.enumerator.topic.TopicPartition extends Object implements Serializable
  
  serialVersionUID:
  
  -1474354741550810953L
  - Serialized Fields
    - topic
```
String topic
```
      The topic name of the pulsar. It would be a full topic name, if your don't provide the tenant and namespace, we would add them automatically.
    - partitionId
```
int partitionId
```
      Index of partition for the topic. It would be natural number for partitioned topic with a non-key_shared subscription.
    - range
```
TopicRange range
```
      The ranges for this topic, used for limiting consume scope. It would be a TopicRange.createFullRange() full range for all the subscription type except SubscriptionType.Key_Shared.
- Class org.apache.flink.connector.pulsar.source.enumerator.topic.TopicRange extends Object implements Serializable
  
  serialVersionUID:
  
  3176938692775594400L
  - Serialized Fields
    - start
```
int start
```
      The start of the range, default is zero.
    - end
```
int end
```
      The end of the range, included.
Package org.apache.flink.connector.pulsar.source.enumerator.topic.range
- Class org.apache.flink.connector.pulsar.source.enumerator.topic.range.FixedRangeGenerator extends Object implements Serializable
  
  serialVersionUID:
  
  -3895203007855538734L
  - Serialized Fields
    - ranges
```
List<E> ranges
```
- Class org.apache.flink.connector.pulsar.source.enumerator.topic.range.FullRangeGenerator extends Object implements Serializable
  
  serialVersionUID:
  
  -4571731955155036216L
- Class org.apache.flink.connector.pulsar.source.enumerator.topic.range.UniformRangeGenerator extends Object implements Serializable
  
  serialVersionUID:
  
  -7292650922683609268L
Package org.apache.flink.connector.pulsar.source.reader.deserializer
- Class org.apache.flink.connector.pulsar.source.reader.deserializer.PulsarTypeInformationWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  6647084180084963022L
  - Serialized Fields
    - information
```
TypeInformation<T> information
```
    - serializer
```
TypeSerializer<T> serializer
```
Package org.apache.flink.connector.pulsar.source.split
- Class org.apache.flink.connector.pulsar.source.split.PulsarPartitionSplit extends Object implements Serializable
  
  serialVersionUID:
  
  -6857317360756062625L
  - Serialized Fields
    - partition
```
TopicPartition partition
```
    - stopCursor
```
StopCursor stopCursor
```
    - latestConsumedId
```
org.apache.pulsar.client.api.MessageId latestConsumedId
```
      Since this field in only used in PulsarOrderedSourceReader.snapshotState(long), it's no need to serialize this field into flink checkpoint state.
    - uncommittedTransactionId
```
org.apache.pulsar.client.api.transaction.TxnID uncommittedTransactionId
```
Package org.apache.flink.connector.testframe.source
- Class org.apache.flink.connector.testframe.source.FromElementsSource extends Object implements Serializable
  - Serialized Fields
    - boundedness
```
Boundedness boundedness
```
    - elements
```
List<E> elements
```
    - emittedElementsNum
```
Integer emittedElementsNum
```
Package org.apache.flink.connectors.hive
- Class org.apache.flink.connectors.hive.CachedSerializedValue extends SerializedValue<T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connectors.hive.FileSystemLookupFunction extends TableFunction<RowData> implements Serializable
  - Serialized Fields
    - partitionFetcher
```
PartitionFetcher<P> partitionFetcher
```
    - fetcherContext
```
PartitionFetcher.Context<P> fetcherContext
```
    - partitionReader
```
PartitionReader<P,OUT> partitionReader
```
    - lookupFieldGetters
```
RowData.FieldGetter[] lookupFieldGetters
```
    - reloadInterval
```
java.time.Duration reloadInterval
```
    - serializer
```
TypeSerializer<T> serializer
```
    - rowType
```
RowType rowType
```
- Class org.apache.flink.connectors.hive.FlinkHiveException extends RuntimeException implements Serializable
- Class org.apache.flink.connectors.hive.HadoopFileSystemFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
- Class org.apache.flink.connectors.hive.HiveRowDataPartitionComputer extends RowDataPartitionComputer implements Serializable
  - Serialized Fields
    - partitionConverters
```
DataFormatConverters.DataFormatConverter<Internal,External>[] partitionConverters
```
    - hiveObjectConversions
```
HiveObjectConversion[] hiveObjectConversions
```
- Class org.apache.flink.connectors.hive.HiveRowPartitionComputer extends RowPartitionComputer implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partColConversions
```
HiveObjectConversion[] partColConversions
```
- Class org.apache.flink.connectors.hive.HiveSource extends AbstractFileSource<T,HiveSourceSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - threadNum
```
int threadNum
```
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
    - partitionKeys
```
List<E> partitionKeys
```
    - fetcher
```
ContinuousPartitionFetcher<P,T extends Comparable<T>> fetcher
```
    - fetcherContext
```
HiveTableSource.HiveContinuousPartitionFetcherContext<T extends Comparable<T>> fetcherContext
```
    - tablePath
```
ObjectPath tablePath
```
- Class org.apache.flink.connectors.hive.HiveSourceFileEnumerator.Provider extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partitions
```
List<E> partitions
```
    - threadNum
```
int threadNum
```
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
- Class org.apache.flink.connectors.hive.HiveTableMetaStoreFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - conf
```
JobConfWrapper conf
```
    - hiveVersion
```
String hiveVersion
```
    - database
```
String database
```
    - tableName
```
String tableName
```
- Class org.apache.flink.connectors.hive.HiveTablePartition extends Object implements Serializable
  
  serialVersionUID:
  
  4145470177119940673L
  - Serialized Fields
    - storageDescriptor
```
CachedSerializedValue<T> storageDescriptor
```
      Partition storage descriptor.
    - partitionSpec
```
Map<K,V> partitionSpec
```
      The map of partition key names and their values.
    - tableProps
```
Properties tableProps
```
- Class org.apache.flink.connectors.hive.HiveTableSource.HiveContinuousPartitionFetcherContext extends HivePartitionFetcherContextBase<org.apache.hadoop.hive.metastore.api.Partition> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - typeSerializer
```
TypeSerializer<T> typeSerializer
```
    - consumeStartOffset
```
Comparable<T> consumeStartOffset
```
- Class org.apache.flink.connectors.hive.JobConfWrapper 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
Package org.apache.flink.connectors.hive.read
- Class org.apache.flink.connectors.hive.read.HiveBulkFormatAdapter extends HiveInputFormat implements Serializable
- Class org.apache.flink.connectors.hive.read.HiveCompactReaderFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - sd
```
CachedSerializedValue<T> sd
```
    - properties
```
Properties properties
```
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
    - partitionKeys
```
List<E> partitionKeys
```
    - fieldNames
```
String[] fieldNames
```
    - fieldTypes
```
DataType[] fieldTypes
```
    - hiveVersion
```
String hiveVersion
```
    - shim
```
HiveShim shim
```
    - producedRowType
```
RowType producedRowType
```
    - useMapRedReader
```
boolean useMapRedReader
```
- Class org.apache.flink.connectors.hive.read.HiveContinuousPartitionFetcher extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connectors.hive.read.HiveInputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
    - partitionKeys
```
List<E> partitionKeys
```
    - fieldNames
```
String[] fieldNames
```
    - fieldTypes
```
DataType[] fieldTypes
```
    - hiveVersion
```
String hiveVersion
```
    - hiveShim
```
HiveShim hiveShim
```
    - producedRowType
```
RowType producedRowType
```
    - useMapRedReader
```
boolean useMapRedReader
```
    - partitionFieldExtractor
```
PartitionFieldExtractor<T extends FileSourceSplit> partitionFieldExtractor
```
- Class org.apache.flink.connectors.hive.read.HiveInputFormatPartitionReader extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - threadNum
```
int threadNum
```
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
    - hiveVersion
```
String hiveVersion
```
    - tablePath
```
ObjectPath tablePath
```
    - fieldTypes
```
DataType[] fieldTypes
```
    - fieldNames
```
String[] fieldNames
```
    - partitionKeys
```
List<E> partitionKeys
```
    - selectedFields
```
int[] selectedFields
```
    - useMapRedReader
```
boolean useMapRedReader
```
- Class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tablePath
```
ObjectPath tablePath
```
    - hiveShim
```
HiveShim hiveShim
```
    - confWrapper
```
JobConfWrapper confWrapper
```
    - partitionKeys
```
List<E> partitionKeys
```
    - fieldTypes
```
DataType[] fieldTypes
```
    - fieldNames
```
String[] fieldNames
```
    - configuration
```
Configuration configuration
```
    - defaultPartitionName
```
String defaultPartitionName
```
    - partitionOrder
```
HiveOptions.PartitionOrder partitionOrder
```
- Class org.apache.flink.connectors.hive.read.HiveSourceSplit extends FileSourceSplit implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hiveTablePartition
```
HiveTablePartition hiveTablePartition
```
- Class org.apache.flink.connectors.hive.read.HiveTableFileInputFormat extends FileInputFormat<RowData> implements Serializable
  - Serialized Fields
    - inputFormat
```
HiveTableInputFormat inputFormat
```
    - hiveTablePartition
```
HiveTablePartition hiveTablePartition
```
- Class org.apache.flink.connectors.hive.read.HiveTableInputFormat extends HadoopInputFormatCommonBase<RowData,HiveTableInputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - threadNum
```
int threadNum
```
    - jobConf
```
JobConfWrapper jobConf
```
    - hiveVersion
```
String hiveVersion
```
    - partitionKeys
```
List<E> partitionKeys
```
    - fieldTypes
```
DataType[] fieldTypes
```
    - fieldNames
```
String[] fieldNames
```
    - partitions
```
List<E> partitions
```
    - selectedFields
```
int[] selectedFields
```
    - limit
```
Long limit
```
    - useMapRedReader
```
boolean useMapRedReader
```
- Class org.apache.flink.connectors.hive.read.HiveTableInputSplit extends HadoopInputSplit implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hiveTablePartition
```
HiveTablePartition hiveTablePartition
```
Package org.apache.flink.connectors.hive.write
- Class org.apache.flink.connectors.hive.write.HiveBulkWriterFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - factory
```
HiveWriterFactory factory
```
- Class org.apache.flink.connectors.hive.write.HiveOutputFormatFactory extends Object implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - factory
```
HiveWriterFactory factory
```
- Class org.apache.flink.connectors.hive.write.HiveWriterFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hiveOutputFormatClz
```
Class<T> hiveOutputFormatClz
```
    - serDeInfo
```
CachedSerializedValue<T> serDeInfo
```
    - allColumns
```
String[] allColumns
```
    - allTypes
```
DataType[] allTypes
```
    - partitionColumns
```
String[] partitionColumns
```
    - tableProperties
```
Properties tableProperties
```
    - confWrapper
```
JobConfWrapper confWrapper
```
    - hiveShim
```
HiveShim hiveShim
```
    - isCompressed
```
boolean isCompressed
```
Package org.apache.flink.contrib.streaming.state
- Class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - configuredOptions
```
Map<K,V> configuredOptions
```
      Deprecated.
- Class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend extends AbstractManagedMemoryStateBackend implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - 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.
    - configurableOptions
```
ReadableConfig configurableOptions
```
      The configurable options.
    - rocksDbOptionsFactory
```
RocksDBOptionsFactory rocksDbOptionsFactory
```
      The options factory to create the RocksDB options in the cluster.
    - enableIncrementalCheckpointing
```
TernaryBoolean enableIncrementalCheckpointing
```
      This determines if incremental checkpointing is enabled.
    - numberOfTransferThreads
```
int numberOfTransferThreads
```
      Thread number used to transfer (download and upload) state, default value: 1.
    - memoryConfiguration
```
RocksDBMemoryConfiguration memoryConfiguration
```
      The configuration for memory settings (pool sizes, etc.).
    - priorityQueueStateType
```
EmbeddedRocksDBStateBackend.PriorityQueueStateType priorityQueueStateType
```
      This determines the type of priority queue state.
    - defaultMetricOptions
```
RocksDBNativeMetricOptions defaultMetricOptions
```
      The default rocksdb metrics options.
    - writeBatchSize
```
long writeBatchSize
```
      Max consumed memory size for one batch in RocksDBWriteBatchWrapper, default value 2mb.
- Class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions extends Object implements Serializable
- Class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - useManagedMemory
```
Boolean useManagedMemory
```
      Flag whether to use the managed memory budget for RocksDB. Null is not set.
    - fixedMemoryPerSlot
```
MemorySize fixedMemoryPerSlot
```
      The total memory for all RocksDB instances at this slot. Null is not set.
    - writeBufferRatio
```
Double writeBufferRatio
```
      The maximum fraction of the total shared memory consumed by the write buffers. Null if not set.
    - highPriorityPoolRatio
```
Double highPriorityPoolRatio
```
      The high priority pool ratio in the shared cache, used for index & filter blocks. Null if not set.
    - usePartitionedIndexFilters
```
Boolean usePartitionedIndexFilters
```
      Flag whether to use partition index/filters. Null if not set.
- Class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - properties
```
Set<E> properties
```
    - columnFamilyAsVariable
```
boolean columnFamilyAsVariable
```
- Class org.apache.flink.contrib.streaming.state.RocksDBStateBackend extends AbstractManagedMemoryStateBackend implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - rocksDBStateBackend
```
EmbeddedRocksDBStateBackend rocksDBStateBackend
```
      Deprecated.
    - checkpointStreamBackend
```
StateBackend checkpointStreamBackend
```
      Deprecated.
      
      The checkpoint storage that we use for creating checkpoint streams.
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.SimpleVersionedSerializerTypeSerializerProxy extends TypeSerializer<T> implements Serializable
  - Serialized Fields
    - serializerSupplier
```
SerializableSupplier<T> serializerSupplier
```
- 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.core.security
- Class org.apache.flink.core.security.UserSystemExitException extends SecurityException implements Serializable
  
  serialVersionUID:
  
  -5732392967744534811L
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.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.fnexecution.v1
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - dataTypeCase_
```
int dataTypeCase_
```
    - dataType_
```
Object dataType_
```
    - mode_
```
int mode_
```
    - separatedWithEndMessage_
```
boolean separatedWithEndMessage_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.ArrowType extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - schema_
```
FlinkFnApi.Schema schema_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.FlattenRowType extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - schema_
```
FlinkFnApi.Schema schema_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - schema_
```
FlinkFnApi.Schema schema_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.RawType extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - typeInfo_
```
FlinkFnApi.TypeInfo typeInfo_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.RowType extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - schema_
```
FlinkFnApi.Schema schema_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - windowType_
```
int windowType_
```
    - isTimeWindow_
```
boolean isTimeWindow_
```
    - windowSlide_
```
long windowSlide_
```
    - windowSize_
```
long windowSize_
```
    - windowGap_
```
long windowGap_
```
    - isRowTime_
```
boolean isRowTime_
```
    - timeFieldIndex_
```
int timeFieldIndex_
```
    - allowedLateness_
```
long allowedLateness_
```
    - namedProperties_
```
List<E> namedProperties_
```
    - namedPropertiesMemoizedSerializedSize
```
int namedPropertiesMemoizedSerializedSize
```
    - shiftTimezone_
```
Object shiftTimezone_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.Input extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - inputCase_
```
int inputCase_
```
    - input_
```
Object input_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.OverWindow extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - windowType_
```
int windowType_
```
    - lowerBoundary_
```
long lowerBoundary_
```
    - upperBoundary_
```
long upperBoundary_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - fields_
```
List<E> fields_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.BinaryInfo extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - length_
```
int length_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.CharInfo extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - length_
```
int length_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.DecimalInfo extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - precision_
```
int precision_
```
    - scale_
```
int scale_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Field extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - name_
```
Object name_
```
    - description_

Back to Flink Website

Serialized Form

Package <Unnamed>

Class FileSinkProgram.Generator extends Object implements Serializable

Serialized Fields

numKeys

idlenessMs

recordsToEmit

numRecordsEmitted

canceled

state

Class FileSinkProgram.KeyBucketAssigner extends Object implements Serializable

Class JavaLexer extends Object implements Serializable

Class JavaParser extends Object implements Serializable

Class JavaParserBaseListener extends Object implements Serializable

Class JavaParserBaseVisitor extends Object implements Serializable

Class JavaParserListener extends Object implements Serializable

Class JavaParserVisitor extends Object implements Serializable

Package org.apache.calcite.jdbc

Class org.apache.calcite.jdbc.JavaCollation extends org.apache.calcite.sql.SqlCollation implements Serializable

Serialized Fields

collator

Class org.apache.calcite.jdbc.JavaRecordType extends org.apache.calcite.rel.type.RelRecordType implements Serializable

Serialized Fields

clazz

Class org.apache.calcite.jdbc.SqlTimeoutException extends SQLException implements Serializable

Package org.apache.calcite.rex

Class org.apache.calcite.rex.RexFieldCollation extends org.apache.calcite.util.Pair<org.apache.calcite.rex.RexNode,com.google.common.collect.ImmutableSet<org.apache.calcite.sql.SqlKind>> implements Serializable

Class org.apache.calcite.rex.RexSlot.SelfPopulatingList extends CopyOnWriteArrayList<String> implements Serializable

Serialized Fields

prefix

Package org.apache.calcite.sql

Class org.apache.calcite.sql.SqlCollation extends Object implements Serializable

Serialized Fields

collationName

wrappedCharset

locale

strength

coercibility

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.api.common

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

Serialized Fields

executionMode

restartStrategyDescription

parallelism

maxParallelism

objectReuseEnabled

globalJobParameters

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

Serialized Fields

executionMode

closureCleanerLevel

parallelism

maxParallelism

numberOfExecutionRetries

forceKryo

disableGenericTypes

enableAutoGeneratedUids

objectReuse

autoTypeRegistrationEnabled

forceAvro

autoWatermarkInterval

latencyTrackingInterval

isLatencyTrackingConfigured

periodicMaterializeIntervalMillis

materializationMaxAllowedFailures

executionRetryDelay

restartStrategyConfiguration

isDynamicGraph

taskCancellationIntervalMillis

taskCancellationTimeoutMillis

useSnapshotCompression