Serialized Form (Flink : 1.13-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
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.addons.hbase1
- Class org.apache.flink.addons.hbase1.TableInputFormat extends HBaseInputFormat<T extends Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
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
```
    - executionRetryDelay
```
long executionRetryDelay
```
      Deprecated. Should no longer be used because it is subsumed by RestartStrategyConfiguration
    - restartStrategyConfiguration
```
RestartStrategies.RestartStrategyConfiguration restartStrategyConfiguration
```
    - taskCancellationIntervalMillis
```
long taskCancellationIntervalMillis
```
    - taskCancellationTimeoutMillis
```
long taskCancellationTimeoutMillis
```
      Timeout after which an ongoing task cancellation will lead to a fatal TaskManager error, usually killing the JVM.
    - useSnapshotCompression
```
boolean useSnapshotCompression
```
      This flag defines if we use compression for the state snapshot data or not. Default: false
    - 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.
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.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.FilePathFilter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.io.FilePathFilter.DefaultFilter extends FilePathFilter implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.io.GenericCsvInputFormat extends DelimitedInputFormat<OT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - lineDelimiterIsLinebreak
```
boolean lineDelimiterIsLinebreak
```
    - fieldTypes
```
Class<T>[] fieldTypes
```
    - fieldIncluded
```
boolean[] fieldIncluded
```
    - fieldDelim
```
byte[] fieldDelim
```
    - fieldDelimString
```
String fieldDelimString
```
    - lenient
```
boolean lenient
```
    - skipFirstLineAsHeader
```
boolean skipFirstLineAsHeader
```
    - quotedStringParsing
```
boolean quotedStringParsing
```
    - quoteCharacter
```
byte quoteCharacter
```
    - commentPrefix
```
byte[] commentPrefix
```
    - commentPrefixString
```
String commentPrefixString
```
- Class org.apache.flink.api.common.io.GenericInputFormat extends RichInputFormat<OT,GenericInputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partitionNumber
```
int partitionNumber
```
      The partition of this split.
- Class org.apache.flink.api.common.io.GlobFilePathFilter extends FilePathFilter implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - includePatterns
```
List<E> includePatterns
```
    - excludePatterns
```
List<E> excludePatterns
```
- Class org.apache.flink.api.common.io.ParseException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  -6721968786653128017L
- Class org.apache.flink.api.common.io.ReplicatingInputFormat extends RichInputFormat<OT,S extends InputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - replicatedIF
```
InputFormat<OT,T extends InputSplit> replicatedIF
```
- Class org.apache.flink.api.common.io.RichInputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.io.RichOutputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.io.SerializedInputFormat extends BinaryInputFormat<T extends IOReadableWritable> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.io.SerializedOutputFormat extends BinaryOutputFormat<T extends IOReadableWritable> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.common.io.ratelimiting
- Class org.apache.flink.api.common.io.ratelimiting.GuavaFlinkConnectorRateLimiter extends Object implements Serializable
  
  serialVersionUID:
  
  -3680641524643737192L
  - Serialized Fields
    - globalRateBytesPerSecond
```
long globalRateBytesPerSecond
```
      Rate in bytes per second for the consumer on a whole.
    - localRateBytesPerSecond
```
long localRateBytesPerSecond
```
      Rate in bytes per second per subtask of the consumer.
    - runtimeContext
```
RuntimeContext runtimeContext
```
      Runtime context. *
    - rateLimiter
```
org.apache.flink.shaded.guava18.com.google.common.util.concurrent.RateLimiter rateLimiter
```
      RateLimiter. *
Package org.apache.flink.api.common.operators
- Class org.apache.flink.api.common.operators.DualInputSemanticProperties extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldMapping1
```
Map<K,V> fieldMapping1
```
      Mapping from fields in the source record(s) in the first input to fields in the destination record(s).
    - fieldMapping2
```
Map<K,V> fieldMapping2
```
      Mapping from fields in the source record(s) in the second input to fields in the destination record(s).
    - readFields1
```
FieldSet readFields1
```
      Set of fields that are read in the source record(s) from the first input.
    - readFields2
```
FieldSet readFields2
```
      Set of fields that are read in the source record(s) from the second input.
- Class org.apache.flink.api.common.operators.Keys.IncompatibleKeysException extends Exception implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.operators.ResourceSpec extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - 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.SemanticProperties.EmptySemanticProperties extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.operators.SemanticProperties.InvalidSemanticAnnotationException extends InvalidProgramException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.operators.SingleInputSemanticProperties extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldMapping
```
Map<K,V> fieldMapping
```
      Mapping from fields in the source record(s) to fields in the destination record(s).
    - readFields
```
FieldSet readFields
```
      Set of fields that are read in the source record(s).
- Class org.apache.flink.api.common.operators.SingleInputSemanticProperties.AllFieldsForwardedProperties extends SingleInputSemanticProperties implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.common.operators.base
- Class org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionAggregationConvergence extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionAggregator extends Object implements Serializable
  - Serialized Fields
    - count
```
long count
```
- Class org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionMapper extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - aggregator
```
BulkIterationBase.TerminationCriterionAggregator aggregator
```
Package org.apache.flink.api.common.operators.util
- Class org.apache.flink.api.common.operators.util.UserCodeClassWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - userCodeClass
```
Class<T> userCodeClass
```
- Class org.apache.flink.api.common.operators.util.UserCodeObjectWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - userCodeObject
```
Object userCodeObject
```
Package org.apache.flink.api.common.resources
- Class org.apache.flink.api.common.resources.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
```
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
```
      Name for queries against state created from this StateDescriptor.
- Class org.apache.flink.api.common.state.StateTtlConfig extends Object implements Serializable
  
  serialVersionUID:
  
  -7592693245044289793L
  - Serialized Fields
    - updateType
```
StateTtlConfig.UpdateType updateType
```
    - stateVisibility
```
StateTtlConfig.StateVisibility stateVisibility
```
    - 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.GenericPairComparator extends TypePairComparator<T1,T2> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - comparator1
```
TypeComparator<T> comparator1
```
    - comparator2
```
TypeComparator<T> comparator2
```
    - comparators1
```
TypeComparator<T>[] comparators1
```
    - comparators2
```
TypeComparator<T>[] comparators2
```
    - referenceKeyFields
```
Object[] referenceKeyFields
```
    - candidateKeyFields
```
Object[] candidateKeyFields
```
- Class org.apache.flink.api.common.typeutils.SingleThreadAccessCheckingTypeSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  131020282727167064L
  - Serialization Methods
    - writeObject
```
private void writeObject(ObjectOutputStream outputStream)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - singleThreadAccessChecker
```
org.apache.flink.api.common.typeutils.SingleThreadAccessCheckingTypeSerializer.SingleThreadAccessChecker singleThreadAccessChecker
```
    - originalSerializer
```
TypeSerializer<T> originalSerializer
```
- Class org.apache.flink.api.common.typeutils.TypeComparator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.TypeSerializer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.UnloadableDummyTypeSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  2526330533671642711L
  - Serialized Fields
    - actualBytes
```
byte[] actualBytes
```
    - originalError
```
Throwable originalError
```
Package org.apache.flink.api.common.typeutils.base
- Class org.apache.flink.api.common.typeutils.base.BasicTypeComparator extends TypeComparator<T extends Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.BigDecComparator extends BasicTypeComparator<BigDecimal> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BigDecSerializer extends TypeSerializerSingleton<BigDecimal> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BigIntComparator extends BasicTypeComparator<BigInteger> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BigIntSerializer extends TypeSerializerSingleton<BigInteger> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BooleanComparator extends BasicTypeComparator<Boolean> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BooleanSerializer extends TypeSerializerSingleton<Boolean> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BooleanValueComparator extends TypeComparator<BooleanValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
BooleanValue reference
```
    - tempReference
```
BooleanValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.BooleanValueSerializer extends TypeSerializerSingleton<BooleanValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ByteComparator extends BasicTypeComparator<Byte> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ByteSerializer extends TypeSerializerSingleton<Byte> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ByteValueComparator extends TypeComparator<ByteValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
ByteValue reference
```
    - tempReference
```
ByteValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.ByteValueSerializer extends TypeSerializerSingleton<ByteValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.CharComparator extends BasicTypeComparator<Character> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.CharSerializer extends TypeSerializerSingleton<Character> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.CharValueComparator extends TypeComparator<CharValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
CharValue reference
```
    - tempReference
```
CharValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.CharValueSerializer extends TypeSerializerSingleton<CharValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.DateComparator extends BasicTypeComparator<Date> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.DateSerializer extends TypeSerializerSingleton<Date> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.DoubleComparator extends BasicTypeComparator<Double> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.DoubleSerializer extends TypeSerializerSingleton<Double> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.DoubleValueComparator extends TypeComparator<DoubleValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
DoubleValue reference
```
    - tempReference
```
DoubleValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.DoubleValueSerializer extends TypeSerializerSingleton<DoubleValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.EnumComparator extends BasicTypeComparator<T extends Enum<T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.EnumSerializer extends TypeSerializer<T extends Enum<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - enumClass
```
Class<T> enumClass
```
    - valueToOrdinal
```
Map<K,V> valueToOrdinal
```
      Maintain our own map of enum value to their ordinal, instead of directly using Enum.ordinal(). This allows us to maintain backwards compatibility for previous serialized data in the case that the order of enum constants was changed or new constants were added.
      On a fresh start with no reconfiguration, the ordinals would simply be identical to the enum constants actual ordinals. Ordinals may change after reconfiguration.
    - values
```
Enum<E extends Enum<E>>[] values
```
      Array of enum constants with their indexes identical to their ordinals in the EnumSerializer.valueToOrdinal map. Serves as a bidirectional map to have fast access from ordinal to value. May be reordered after reconfiguration.
- Class org.apache.flink.api.common.typeutils.base.FloatComparator extends BasicTypeComparator<Float> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.FloatSerializer extends TypeSerializerSingleton<Float> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.FloatValueComparator extends TypeComparator<FloatValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
FloatValue reference
```
    - tempReference
```
FloatValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.FloatValueSerializer extends TypeSerializerSingleton<FloatValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.GenericArraySerializer extends TypeSerializer<C[]> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - componentClass
```
Class<T> componentClass
```
    - componentSerializer
```
TypeSerializer<T> componentSerializer
```
- Class org.apache.flink.api.common.typeutils.base.InstantComparator extends BasicTypeComparator<java.time.Instant> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.InstantSerializer extends TypeSerializerSingleton<java.time.Instant> implements Serializable
  
  serialVersionUID:
  
  -4131715684999061277L
- Class org.apache.flink.api.common.typeutils.base.IntComparator extends BasicTypeComparator<Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.IntSerializer extends TypeSerializerSingleton<Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.IntValueComparator extends TypeComparator<IntValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
IntValue reference
```
    - tempReference
```
IntValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.IntValueSerializer extends TypeSerializerSingleton<IntValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ListSerializer extends TypeSerializer<List<T>> implements Serializable
  
  serialVersionUID:
  
  1119562170939152304L
  - Serialized Fields
    - elementSerializer
```
TypeSerializer<T> elementSerializer
```
      The serializer for the elements of the list.
- Class org.apache.flink.api.common.typeutils.base.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.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.PojoTypeInfo extends CompositeType<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fields
```
PojoField[] fields
```
    - totalFields
```
int totalFields
```
- Class org.apache.flink.api.java.typeutils.RowTypeInfo extends TupleTypeInfoBase<Row> implements Serializable
  
  serialVersionUID:
  
  9158518989896601963L
  - Serialized Fields
    - fieldNames
```
String[] fieldNames
```
    - comparatorOrders
```
boolean[] comparatorOrders
```
      Temporary variable for directly passing orders to comparators.
- Class org.apache.flink.api.java.typeutils.TupleTypeInfo extends TupleTypeInfoBase<T extends Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldNames
```
String[] fieldNames
```
- Class org.apache.flink.api.java.typeutils.TupleTypeInfoBase extends CompositeType<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - types
```
TypeInformation<T>[] types
```
    - totalFields
```
int totalFields
```
- Class org.apache.flink.api.java.typeutils.TypeExtractionException extends Exception implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.ValueTypeInfo extends TypeInformation<T extends Value> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
- Class org.apache.flink.api.java.typeutils.WritableTypeInfo extends TypeInformation<T extends org.apache.hadoop.io.Writable> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
Package org.apache.flink.api.java.typeutils.runtime
- Class org.apache.flink.api.java.typeutils.runtime.CopyableValueComparator extends TypeComparator<T extends CopyableValue<T> & Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream s)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - type
```
Class<T> type
```
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.java.typeutils.runtime.CopyableValueSerializer extends TypeSerializer<T extends CopyableValue<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - valueClass
```
Class<T> valueClass
```
- Class org.apache.flink.api.java.typeutils.runtime.EitherSerializer extends TypeSerializer<Either<L,R>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - leftSerializer
```
TypeSerializer<T> leftSerializer
```
    - rightSerializer
```
TypeSerializer<T> rightSerializer
```
- Class org.apache.flink.api.java.typeutils.runtime.GenericTypeComparator extends TypeComparator<T extends Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascending
```
boolean ascending
```
    - type
```
Class<T> type
```
    - serializer
```
TypeSerializer<T> serializer
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.java.typeutils.runtime.KryoRegistration extends Object implements Serializable
  
  serialVersionUID:
  
  5375110512910892655L
  - Serialized Fields
    - registeredClass
```
Class<T> registeredClass
```
      The registered class.
      This can be a dummy class KryoRegistrationSerializerConfigSnapshot.DummyRegisteredClass if the class no longer exists when this registration instance was restored.
    - serializerClass
```
Class<T> serializerClass
```
      Class of the serializer to use for the registered class. Exists only if the serializer definition type is KryoRegistration.SerializerDefinitionType.CLASS.
      This can be a dummy serializer KryoRegistrationSerializerConfigSnapshot.DummyKryoSerializerClass if the serializer class no longer exists when this registration instance was restored.
    - serializableSerializerInstance
```
ExecutionConfig.SerializableSerializer<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable> serializableSerializerInstance
```
      A serializable instance of the serializer to use for the registered class. Exists only if the serializer definition type is KryoRegistration.SerializerDefinitionType.INSTANCE.
      This can be a dummy serializer KryoRegistrationSerializerConfigSnapshot.DummyKryoSerializerClass if the serializer class no longer exists or is no longer valid when this registration instance was restored.
    - serializerDefinitionType
```
KryoRegistration.SerializerDefinitionType serializerDefinitionType
```
- Class org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot.DummyKryoSerializerClass extends com.esotericsoftware.kryo.Serializer<RC> implements Serializable
  
  serialVersionUID:
  
  -6172780797425739308L
- Class org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot.DummyRegisteredClass extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.runtime.NullableSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  3335569358214720033L
  - Serialized Fields
    - originalSerializer
```
TypeSerializer<T> originalSerializer
```
    - padding
```
byte[] padding
```
- Class org.apache.flink.api.java.typeutils.runtime.NullAwareComparator extends TypeComparator<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - wrappedComparator
```
TypeComparator<T> wrappedComparator
```
    - order
```
boolean order
```
    - flatFields
```
int flatFields
```
    - nullReference
```
boolean nullReference
```
- Class org.apache.flink.api.java.typeutils.runtime.PojoComparator extends CompositeTypeComparator<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException,
                         ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - comparators
```
TypeComparator<T>[] comparators
```
    - normalizedKeyLengths
```
int[] normalizedKeyLengths
```
    - numLeadingNormalizableKeys
```
int numLeadingNormalizableKeys
```
    - normalizableKeyPrefixLen
```
int normalizableKeyPrefixLen
```
    - invertNormKey
```
boolean invertNormKey
```
    - serializer
```
TypeSerializer<T> serializer
```
    - type
```
Class<T> type
```
- Class org.apache.flink.api.java.typeutils.runtime.PojoSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException,
                         ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
      The POJO type class.
    - fieldSerializers
```
TypeSerializer<T>[] fieldSerializers
```
    - numFields
```
int numFields
```
    - registeredClasses
```
LinkedHashMap<K,V> registeredClasses
```
      Registered subclasses and their serializers. Each subclass to their registered class tag is maintained as a separate map ordered by the class tag.
    - registeredSerializers
```
TypeSerializer<T>[] registeredSerializers
```
    - executionConfig
```
ExecutionConfig executionConfig
```
      Configuration of the current execution.
- Class org.apache.flink.api.java.typeutils.runtime.RowComparator extends CompositeTypeComparator<Row> implements Serializable
  
  serialVersionUID:
  
  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.RowSerializer extends TypeSerializer<Row> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - legacyModeEnabled
```
boolean legacyModeEnabled
```
    - legacyOffset
```
int legacyOffset
```
    - fieldSerializers
```
TypeSerializer<T>[] fieldSerializers
```
    - arity
```
int arity
```
    - positionByName
```
LinkedHashMap<K,V> positionByName
```
- Class org.apache.flink.api.java.typeutils.runtime.RuntimeComparatorFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - comparator
```
TypeComparator<T> comparator
```
- Class org.apache.flink.api.java.typeutils.runtime.RuntimePairComparatorFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.RuntimeSerializerFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - serializer
```
TypeSerializer<T> serializer
```
    - firstSerializer
```
boolean firstSerializer
```
    - clazz
```
Class<T> clazz
```
- Class org.apache.flink.api.java.typeutils.runtime.Tuple0Serializer extends TupleSerializer<Tuple0> implements Serializable
  
  serialVersionUID:
  
  1278813169022975971L
- Class org.apache.flink.api.java.typeutils.runtime.TupleComparator extends TupleComparatorBase<T extends Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.TupleComparatorBase extends CompositeTypeComparator<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - keyPositions
```
int[] keyPositions
```
      key positions describe which fields are keys in what order
    - comparators
```
TypeComparator<T>[] comparators
```
      comparators for the key fields, in the same order as the key fields
    - normalizedKeyLengths
```
int[] normalizedKeyLengths
```
    - numLeadingNormalizableKeys
```
int numLeadingNormalizableKeys
```
    - normalizableKeyPrefixLen
```
int normalizableKeyPrefixLen
```
    - invertNormKey
```
boolean invertNormKey
```
    - serializers
```
TypeSerializer<T>[] serializers
```
      serializers to deserialize the first n fields for comparison
- Class org.apache.flink.api.java.typeutils.runtime.TupleSerializer extends TupleSerializerBase<T extends Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.TupleSerializerBase extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tupleClass
```
Class<T> tupleClass
```
    - fieldSerializers
```
TypeSerializer<T>[] fieldSerializers
```
    - arity
```
int arity
```
    - length
```
int length
```
- Class org.apache.flink.api.java.typeutils.runtime.ValueComparator extends TypeComparator<T extends Value & Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.java.typeutils.runtime.ValueSerializer extends TypeSerializer<T extends Value> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - type
```
Class<T> type
```
    - kryoRegistrations
```
LinkedHashMap<K,V> kryoRegistrations
```
      Map of class tag (using classname as tag) to their Kryo registration.
      This map serves as a preview of the final registration result of the Kryo instance, taking into account registration overwrites.
      Currently, we only have one single registration for the value type. Nevertheless, we keep this information here for future compatibility.
- Class org.apache.flink.api.java.typeutils.runtime.WritableComparator extends TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.java.typeutils.runtime.WritableSerializer extends TypeSerializer<T extends org.apache.hadoop.io.Writable> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
Package org.apache.flink.api.java.typeutils.runtime.kryo
- Class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  3L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - defaultSerializers
```
LinkedHashMap<K,V> defaultSerializers
```
    - defaultSerializerClasses
```
LinkedHashMap<K,V> defaultSerializerClasses
```
    - kryoRegistrations
```
LinkedHashMap<K,V> kryoRegistrations
```
      Map of class tag (using classname as tag) to their Kryo registration.
      This map serves as a preview of the final registration result of the Kryo instance, taking into account registration overwrites.
    - type
```
Class<T> type
```
    - registeredTypesWithSerializers
```
LinkedHashMap<K,V> registeredTypesWithSerializers
```
    - registeredTypesWithSerializerClasses
```
LinkedHashMap<K,V> registeredTypesWithSerializerClasses
```
    - registeredTypes
```
LinkedHashSet<E> registeredTypes
```
- Class org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.SpecificInstanceCollectionSerializer extends com.esotericsoftware.kryo.serializers.CollectionSerializer implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
- Class org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.SpecificInstanceCollectionSerializerForArrayList extends Serializers.SpecificInstanceCollectionSerializer<ArrayList> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.java.utils
- Class org.apache.flink.api.java.utils.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
```
    - org$apache$flink$api$scala$typeutils$CaseClassTypeInfo$$fieldTypes
```
scala.collection.Seq<A> org$apache$flink$api$scala$typeutils$CaseClassTypeInfo$$fieldTypes
```
    - fieldNames
```
scala.collection.Seq<A> fieldNames
```
    - REGEX_INT_FIELD
```
String REGEX_INT_FIELD
```
    - REGEX_STR_FIELD
```
String REGEX_STR_FIELD
```
    - REGEX_FIELD
```
String REGEX_FIELD
```
    - REGEX_NESTED_FIELDS
```
String REGEX_NESTED_FIELDS
```
    - REGEX_NESTED_FIELDS_WILDCARD
```
String REGEX_NESTED_FIELDS_WILDCARD
```
    - PATTERN_NESTED_FIELDS
```
Pattern PATTERN_NESTED_FIELDS
```
    - PATTERN_NESTED_FIELDS_WILDCARD
```
Pattern PATTERN_NESTED_FIELDS_WILDCARD
```
    - PATTERN_INT_FIELD
```
Pattern PATTERN_INT_FIELD
```
- Class org.apache.flink.api.scala.typeutils.EitherSerializer extends TypeSerializer<scala.util.Either<A,B>> implements Serializable
  
  serialVersionUID:
  
  9219995873023657525L
  - Serialized Fields
    - leftSerializer
```
TypeSerializer<T> leftSerializer
```
    - rightSerializer
```
TypeSerializer<T> rightSerializer
```
- Class org.apache.flink.api.scala.typeutils.EitherTypeInfo extends TypeInformation<T extends scala.util.Either<A,B>> implements Serializable
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
    - leftTypeInfo
```
TypeInformation<T> leftTypeInfo
```
    - rightTypeInfo
```
TypeInformation<T> rightTypeInfo
```
- Class org.apache.flink.api.scala.typeutils.EnumValueComparator extends TypeComparator<scala.Enumeration.Value> implements Serializable
  
  serialVersionUID:
  
  1000L
  - Serialized Fields
    - ascComp
```
boolean ascComp
```
    - intComparator
```
IntComparator intComparator
```
    - getFlatComparators
```
TypeComparator<T>[] getFlatComparators
```
    - bitmap$0
```
boolean bitmap$0
```
- Class org.apache.flink.api.scala.typeutils.EnumValueSerializer extends TypeSerializer<scala.Enumeration.Value> implements Serializable
  
  serialVersionUID:
  
  -2403076635594572920L
  - Serialized Fields
    - enum
```
scala.Enumeration enum
```
- Class org.apache.flink.api.scala.typeutils.EnumValueSerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.EnumValueTypeInfo extends TypeInformation<scala.Enumeration.Value> implements Serializable
  - Serialized Fields
    - enum
```
scala.Enumeration enum
```
    - clazz
```
Class<T> clazz
```
- Class org.apache.flink.api.scala.typeutils.NothingSerializer extends TypeSerializer<Object> implements Serializable
- Class org.apache.flink.api.scala.typeutils.OptionSerializer extends TypeSerializer<scala.Option<A>> implements Serializable
  
  serialVersionUID:
  
  -8635243274072627338L
  - Serialized Fields
    - elemSerializer
```
TypeSerializer<T> elemSerializer
```
- Class org.apache.flink.api.scala.typeutils.OptionSerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.OptionTypeComparator extends TypeComparator<scala.Option<A>> implements Serializable
  - Serialized Fields
    - ascending
```
boolean ascending
```
    - typeComparator
```
TypeComparator<T> typeComparator
```
    - reference
```
scala.Option<A> reference
```
    - getFlatComparators
```
TypeComparator<T>[] getFlatComparators
```
    - bitmap$0
```
boolean bitmap$0
```
- Class org.apache.flink.api.scala.typeutils.OptionTypeComparator$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
  - Serialized Fields
    - ZeroInByte
```
byte ZeroInByte
```
    - OneInByte
```
byte OneInByte
```
- Class org.apache.flink.api.scala.typeutils.OptionTypeInfo extends TypeInformation<T extends scala.Option<A>> implements Serializable
  - Serialized Fields
    - elemTypeInfo
```
TypeInformation<T> elemTypeInfo
```
- Class org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer extends org.apache.flink.api.scala.typeutils.CaseClassSerializer<T extends scala.Product> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream arg0)
```
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
- Class org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.ScalaNothingTypeInfo extends TypeInformation<scala.runtime.Nothing$> implements Serializable
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer extends TypeSerializer<T extends scala.collection.TraversableOnce<E>> implements Serializable
  
  serialVersionUID:
  
  7522917416391312410L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream arg0)
```
  - Serialized Fields
    - elementSerializer
```
TypeSerializer<T> elementSerializer
```
    - cbfCode
```
String cbfCode
```
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer.Key extends Object implements Serializable
  - Serialized Fields
    - classLoaderHash
```
int classLoaderHash
```
    - classLoaderRef
```
scala.ref.WeakReference<T> classLoaderRef
```
    - cbfCode
```
String cbfCode
```
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer.Key$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer.LazyRuntimeCompiler extends Object implements Serializable
  - Serialized Fields
    - classLoader
```
ClassLoader classLoader
```
    - code
```
String code
```
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer.LazyRuntimeCompiler$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
  - Serialized Fields
    - CACHE
```
org.apache.flink.shaded.guava18.com.google.common.cache.Cache<K,V> CACHE
```
- Class org.apache.flink.api.scala.typeutils.TraversableTypeInfo extends TypeInformation<T extends scala.collection.TraversableOnce<E>> implements Serializable
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
    - elementTypeInfo
```
TypeInformation<T> elementTypeInfo
```
- Class org.apache.flink.api.scala.typeutils.TrySerializer extends TypeSerializer<scala.util.Try<A>> implements Serializable
  
  serialVersionUID:
  
  -3052182891252564491L
  - Serialized Fields
    - elemSerializer
```
TypeSerializer<T> elemSerializer
```
    - throwableSerializer
```
TypeSerializer<T> throwableSerializer
```
- Class org.apache.flink.api.scala.typeutils.TrySerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.TryTypeInfo extends TypeInformation<T extends scala.util.Try<A>> implements Serializable
  - Serialized Fields
    - elemTypeInfo
```
TypeInformation<T> elemTypeInfo
```
- Class org.apache.flink.api.scala.typeutils.UnitSerializer extends TypeSerializerSingleton<scala.runtime.BoxedUnit> implements Serializable
  
  serialVersionUID:
  
  5413377487955047394L
- Class org.apache.flink.api.scala.typeutils.UnitSerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.UnitTypeInfo extends TypeInformation<scala.runtime.BoxedUnit> implements Serializable
Package org.apache.flink.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.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.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.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.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
```
- 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
```
- Class org.apache.flink.connector.file.sink.FileSinkCommittable extends Object implements Serializable
  - Serialized Fields
    - pendingFile
```
InProgressFileWriter.PendingFileRecoverable pendingFile
```
    - inProgressFileToCleanup
```
InProgressFileWriter.InProgressFileRecoverable inProgressFileToCleanup
```
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.
    - 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
```
- 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 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.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.LegacyMutationConverter extends Object implements Serializable
  
  serialVersionUID:
  
  7358222494016900667L
  - Serialized Fields
    - schema
```
HBaseTableSchema schema
```
- 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.HBaseLookupFunction extends TableFunction<Row> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hTableName
```
String hTableName
```
    - serializedConfig
```
byte[] serializedConfig
```
    - hbaseTableSchema
```
HBaseTableSchema hbaseTableSchema
```
- 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.HBaseInputFormat extends AbstractTableInputFormat<T extends Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
- 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
```
- Class org.apache.flink.connector.hbase1.source.HBaseRowInputFormat extends AbstractTableInputFormat<Row> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableName
```
String tableName
```
    - schema
```
HBaseTableSchema schema
```
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.HBaseInputFormat extends AbstractTableInputFormat<T extends Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
- 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
```
- Class org.apache.flink.connector.hbase2.source.HBaseRowInputFormat extends AbstractTableInputFormat<Row> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableName
```
String tableName
```
    - schema
```
HBaseTableSchema schema
```
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.JdbcOutputFormat extends JdbcBatchingOutputFormat<Row,Row,JdbcBatchStatementExecutor<Row>> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.connector.jdbc.dialect
- Class org.apache.flink.connector.jdbc.dialect.MySQLDialect extends org.apache.flink.connector.jdbc.dialect.AbstractDialect implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.jdbc.dialect.PostgresDialect extends org.apache.flink.connector.jdbc.dialect.AbstractDialect implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.connector.jdbc.internal
- Class org.apache.flink.connector.jdbc.internal.AbstractJdbcOutputFormat extends RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - connectionProvider
```
JdbcConnectionProvider connectionProvider
```
- Class org.apache.flink.connector.jdbc.internal.GenericJdbcSinkFunction extends RichSinkFunction<T> implements Serializable
  - Serialized Fields
    - outputFormat
```
AbstractJdbcOutputFormat<T> outputFormat
```
- Class org.apache.flink.connector.jdbc.internal.JdbcBatchingOutputFormat extends AbstractJdbcOutputFormat<In> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - executionOptions
```
JdbcExecutionOptions executionOptions
```
    - statementExecutorFactory
```
JdbcBatchingOutputFormat.StatementExecutorFactory<T extends JdbcBatchStatementExecutor<?>> statementExecutorFactory
```
    - jdbcRecordExtractor
```
JdbcBatchingOutputFormat.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.AbstractJdbcRowConverter extends Object implements Serializable
  - Serialized Fields
    - rowType
```
RowType rowType
```
    - toInternalConverters
```
org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcDeserializationConverter[] toInternalConverters
```
    - toExternalConverters
```
org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcSerializationConverter[] toExternalConverters
```
    - fieldTypes
```
LogicalType[] fieldTypes
```
- 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.PostgresRowConverter extends AbstractJdbcRowConverter implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.connector.jdbc.internal.options
- 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
```
- Class org.apache.flink.connector.jdbc.internal.options.JdbcOptions 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.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.JdbcDynamicOutputFormatBuilder extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jdbcOptions
```
JdbcOptions jdbcOptions
```
    - executionOptions
```
JdbcExecutionOptions executionOptions
```
    - dmlOptions
```
JdbcDmlOptions dmlOptions
```
    - rowDataTypeInformation
```
TypeInformation<T> rowDataTypeInformation
```
    - fieldDataTypes
```
DataType[] fieldDataTypes
```
- Class org.apache.flink.connector.jdbc.table.JdbcLookupFunction extends TableFunction<Row> implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - query
```
String query
```
    - connectionProvider
```
JdbcConnectionProvider connectionProvider
```
    - keyTypes
```
TypeInformation<T>[] keyTypes
```
    - keySqlTypes
```
int[] keySqlTypes
```
    - fieldNames
```
String[] fieldNames
```
    - keyNames
```
String[] keyNames
```
    - fieldTypes
```
TypeInformation<T>[] fieldTypes
```
    - outputSqlTypes
```
int[] outputSqlTypes
```
    - cacheMaxSize
```
long cacheMaxSize
```
    - cacheExpireMs
```
long cacheExpireMs
```
    - maxRetryTimes
```
int maxRetryTimes
```
- 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
```
    - 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
```
JdbcBatchingOutputFormat<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.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.connectors.hive
- Class org.apache.flink.connectors.hive.CachedSerializedValue extends SerializedValue<T> implements Serializable
  
  serialVersionUID:
  
  1L
- 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<RowData,HiveSourceSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - 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
```
    - 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 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.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.HiveInputFormatPartitionReader extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - 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
```
    - consumeOrder
```
ConsumeOrder consumeOrder
```
- 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
    - 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
```
- 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.
    - 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
  - 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.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.CoderParam extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - dataInfoCase_
```
int dataInfoCase_
```
    - dataInfo_
```
Object dataInfo_
```
    - dataType_
```
int dataType_
```
    - outputMode_
```
int outputMode_
```
    - 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_
```
Object description_
```
    - type_
```
FlinkFnApi.Schema.FieldType type_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.FieldType extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - typeInfoCase_
```
int typeInfoCase_
```
    - typeInfo_
```
Object typeInfo_
```
    - typeName_
```
int typeName_
```
    - nullable_
```
boolean nullable_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.LocalZonedTimestampInfo extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - precision_
```
int precision_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.MapInfo extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - keyType_
```
FlinkFnApi.Schema.FieldType keyType_
```
    - valueType_
```
FlinkFnApi.Schema.FieldType valueType_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.TimeInfo extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - precision_
```
int precision_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.TimestampInfo extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - precision_
```
int precision_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.VarBinaryInfo 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.VarCharInfo 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.ZonedTimestampInfo extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - precision_
```
int precision_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - typeInfoCase_
```
int typeInfoCase_
```
    - typeInfo_
```
Object typeInfo_
```
    - typeName_
```
int typeName_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.MapTypeInfo extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - keyType_
```
FlinkFnApi.TypeInfo keyType_
```
    - valueType_
```
FlinkFnApi.TypeInfo valueType_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo 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.TypeInfo.RowTypeInfo.Field extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - fieldName_
```
Object fieldName_
```
    - fieldType_
```
FlinkFnApi.TypeInfo fieldType_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - fieldTypes_
```
List<E> fieldTypes_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - payload_
```
com.google.protobuf.ByteString payload_
```
    - inputs_
```
List<E> inputs_
```
    - specs_
```
List<E> specs_
```
    - filterArg_
```
int filterArg_
```
    - distinct_
```
boolean distinct_
```
    - takesRowAsInput_
```
boolean takesRowAsInput_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - dataViewCase_
```
int dataViewCase_
```
    - dataView_
```
Object dataView_
```
    - name_
```
Object name_
```
    - fieldIndex_
```
int fieldIndex_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.ListView extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - elementType_
```
FlinkFnApi.Schema.FieldType elementType_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - keyType_
```
FlinkFnApi.Schema.FieldType keyType_
```
    - valueType_
```
FlinkFnApi.Schema.FieldType valueType_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - udfs_
```
List<E> udfs_
```
    - metricEnabled_
```
boolean metricEnabled_
```
    - grouping_
```
com.google.protobuf.Internal.IntList grouping_
```
    - groupingMemoizedSerializedSize
```
int groupingMemoizedSerializedSize
```
    - generateUpdateBefore_
```
boolean generateUpdateBefore_
```
    - keyType_
```
FlinkFnApi.Schema.FieldType keyType_
```
    - indexOfCountStar_
```
int indexOfCountStar_
```
    - stateCleaningEnabled_
```
boolean stateCleaningEnabled_
```
    - stateCacheSize_
```
int stateCacheSize_
```
    - mapStateReadCacheSize_
```
int mapStateReadCacheSize_
```
    - mapStateWriteCacheSize_
```
int mapStateWriteCacheSize_
```
    - countStarInserted_
```
boolean countStarInserted_
```
    - groupWindow_
```
FlinkFnApi.GroupWindow groupWindow_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - functionType_
```
int functionType_
```
    - runtimeContext_
```
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext runtimeContext_
```
    - payload_
```
com.google.protobuf.ByteString payload_
```
    - metricEnabled_
```
boolean metricEnabled_
```
    - keyTypeInfo_
```
FlinkFnApi.TypeInfo keyTypeInfo_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.JobParameter extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - key_
```
Object key_
```
    - value_
```
Object value_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - taskName_
```
Object taskName_
```
    - taskNameWithSubtasks_
```
Object taskNameWithSubtasks_
```
    - numberOfParallelSubtasks_
```
int numberOfParallelSubtasks_
```
    - maxNumberOfParallelSubtasks_
```
int maxNumberOfParallelSubtasks_
```
    - indexOfThisSubtask_
```
int indexOfThisSubtask_
```
    - attemptNumber_
```
int attemptNumber_
```
    - jobParameters_
```
List<E> jobParameters_
```
    - inBatchExecutionMode_
```
boolean inBatchExecutionMode_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunction extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - payload_
```
com.google.protobuf.ByteString payload_
```
    - inputs_
```
List<E> inputs_
```
    - windowIndex_
```
int windowIndex_
```
    - takesRowAsInput_
```
boolean takesRowAsInput_
```
    - isPandasUdf_
```
boolean isPandasUdf_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - udfs_
```
List<E> udfs_
```
    - metricEnabled_
```
boolean metricEnabled_
```
    - windows_
```
List<E> windows_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
Package org.apache.flink.formats.avro
- Class org.apache.flink.formats.avro.AvroDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  -6766681879020862312L
  - Serialized Fields
    - recordClazz
```
Class<T> recordClazz
```
      Class to deserialize to.
    - schemaString
```
String schemaString
```
      Schema in case of GenericRecord for serialization purpose.
- Class org.apache.flink.formats.avro.AvroInputFormat extends FileInputFormat<E> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - avroValueType
```
Class<T> avroValueType
```
    - reuseAvroValue
```
boolean reuseAvroValue
```
    - lastSync
```
long lastSync
```
- Class org.apache.flink.formats.avro.AvroOutputFormat extends FileOutputFormat<E> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - avroValueType
```
Class<T> avroValueType
```
- Class org.apache.flink.formats.avro.AvroRowDataDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nestedSchema
```
DeserializationSchema<T> nestedSchema
```
      Nested schema to deserialize the inputs into avro GenericRecord. *
    - typeInfo
```
TypeInformation<T> typeInfo
```
      Type information describing the result type.
    - runtimeConverter
```
AvroToRowDataConverters.AvroToRowDataConverter runtimeConverter
```
      Runtime instance that performs the actual work.
- Class org.apache.flink.formats.avro.AvroRowDataSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nestedSchema
```
SerializationSchema<T> nestedSchema
```
      Nested schema to serialize the GenericRecord into bytes. *
    - rowType
```
RowType rowType
```
      Logical type describing the input type.
    - runtimeConverter
```
RowDataToAvroConverters.RowDataToAvroConverter runtimeConverter
```
      Runtime instance that performs the actual work.
- Class org.apache.flink.formats.avro.AvroRowDeserializationSchema extends AbstractDeserializationSchema<Row> implements Serializable
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream inputStream)
                 throws ClassNotFoundException,
                        IOException
```
      Throws:
      
      ClassNotFoundException
      
      IOException
    - writeObject
```
private void writeObject(ObjectOutputStream outputStream)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - recordClazz
```
Class<T> recordClazz
```
      Avro record class for deserialization. Might be null if record class is not available.
    - schemaString
```
String schemaString
```
      Schema string for deserialization.
- Class org.apache.flink.formats.avro.AvroRowSerializationSchema extends Object implements Serializable
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream inputStream)
                 throws ClassNotFoundException,
                        IOException
```
      Throws:
      
      ClassNotFoundException
      
      IOException
    - writeObject
```
private void writeObject(ObjectOutputStream outputStream)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - recordClazz
```
Class<T> recordClazz
```
      Avro record class for serialization. Might be null if record class is not available.
    - schemaString
```
String schemaString
```
      Schema string for deserialization.
- Class org.apache.flink.formats.avro.AvroSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  -8766681879020862312L
  - Serialized Fields
    - recordClazz
```
Class<T> recordClazz
```
      Class to serialize to.
    - schemaString
```
String schemaString
```
- Class org.apache.flink.formats.avro.AvroWriterFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - avroBuilder
```
AvroBuilder<T> avroBuilder
```
      The builder to construct the Avro DataFileWriter.
- Class org.apache.flink.formats.avro.RegistryAvroDeserializationSchema extends AvroDeserializationSchema<T> implements Serializable
  
  serialVersionUID:
  
  -884738268437806062L
  - Serialized Fields
    - schemaCoderProvider
```
SchemaCoder.SchemaCoderProvider schemaCoderProvider
```
      Provider for schema coder. Used for initializing in each task.
- Class org.apache.flink.formats.avro.RegistryAvroSerializationSchema extends AvroSerializationSchema<T> implements Serializable
  
  serialVersionUID:
  
  -6766681879020862312L
  - Serialized Fields
    - schemaCoderProvider
```
SchemaCoder.SchemaCoderProvider schemaCoderProvider
```
      Provider for schema coder. Used for initializing in each task.
    - schemaCoder
```
SchemaCoder schemaCoder
```
Package org.apache.flink.formats.avro.glue.schema.registry
- Class org.apache.flink.formats.avro.glue.schema.registry.GlueSchemaRegistryAvroDeserializationSchema extends RegistryAvroDeserializationSchema<T> implements Serializable
- Class org.apache.flink.formats.avro.glue.schema.registry.GlueSchemaRegistryAvroSchemaCoderProvider extends Object implements Serializable
  - Serialized Fields
    - transportName
```
String transportName
```
    - configs
```
Map<K,V> configs
```
- Class org.apache.flink.formats.avro.glue.schema.registry.GlueSchemaRegistryAvroSerializationSchema extends RegistryAvroSerializationSchema<T> implements Serializable
Package org.apache.flink.formats.avro.registry.confluent
- Class org.apache.flink.formats.avro.registry.confluent.ConfluentRegistryAvroDeserializationSchema extends RegistryAvroDeserializationSchema<T> implements Serializable
  
  serialVersionUID:
  
  -1671641202177852775L
- Class org.apache.flink.formats.avro.registry.confluent.ConfluentRegistryAvroSerializationSchema extends RegistryAvroSerializationSchema<T> implements Serializable
  
  serialVersionUID:
  
  -1771641202177852775L
Package org.apache.flink.formats.avro.registry.confluent.debezium
- Class org.apache.flink.formats.avro.registry.confluent.debezium.DebeziumAvroDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - avroDeserializer
```
AvroRowDataDeserializationSchema avroDeserializer
```
      The deserializer to deserialize Debezium Avro data.
    - producedTypeInfo
```
TypeInformation<T> producedTypeInfo
```
      TypeInformation of the produced RowData.
- Class org.apache.flink.formats.avro.registry.confluent.debezium.DebeziumAvroSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - avroSerializer
```
AvroRowDataSerializationSchema avroSerializer
```
      The deserializer to deserialize Debezium Avro data.
Package org.apache.flink.formats.avro.typeutils
- Class org.apache.flink.formats.avro.typeutils.AvroSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - type
```
Class<T> type
```
    - schema
```
org.apache.flink.formats.avro.typeutils.SerializableAvroSchema schema
```
    - previousSchema
```
org.apache.flink.formats.avro.typeutils.SerializableAvroSchema previousSchema
```
- Class org.apache.flink.formats.avro.typeutils.AvroTypeInfo extends PojoTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo extends TypeInformation<org.apache.avro.generic.GenericRecord> implements Serializable
  
  serialVersionUID:
  
  4141977586453820650L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream ois)
                 throws ClassNotFoundException,
                        IOException
```
      Throws:
      
      ClassNotFoundException
      
      IOException
    - writeObject
```
private void writeObject(ObjectOutputStream oos)
                  throws IOException
```
      Throws:
      
      IOException
Package org.apache.flink.formats.avro.utils
- Class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.AvroSchemaSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.avro.Schema> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.formats.compress
- Class org.apache.flink.formats.compress.CompressWriterFactory extends Object implements Serializable
  - Serialized Fields
    - extractor
```
Extractor<T> extractor
```
    - hadoopConfigMap
```
Map<K,V> hadoopConfigMap
```
    - hadoopCodecName
```
String hadoopCodecName
```
    - codecExtension
```
String codecExtension
```
Package org.apache.flink.formats.compress.extractor
- Class org.apache.flink.formats.compress.extractor.DefaultExtractor extends Object implements Serializable
Package org.apache.flink.formats.csv
- Class org.apache.flink.formats.csv.AbstractCsvInputFormat extends FileInputFormat<T> implements Serializable
  - Serialized Fields
    - csvSchema
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema
```
- Class org.apache.flink.formats.csv.CsvFileSystemFormatFactory.CsvInputFormat extends AbstractCsvInputFormat<RowData> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - formatRowType
```
RowType formatRowType
```
    - fieldTypes
```
DataType[] fieldTypes
```
    - fieldNames
```
String[] fieldNames
```
    - selectFields
```
int[] selectFields
```
    - partitionKeys
```
List<E> partitionKeys
```
    - defaultPartValue
```
String defaultPartValue
```
    - limit
```
long limit
```
    - csvSelectFieldToProjectFieldMapping
```
int[] csvSelectFieldToProjectFieldMapping
```
    - csvSelectFieldToCsvFieldMapping
```
int[] csvSelectFieldToCsvFieldMapping
```
    - ignoreParseErrors
```
boolean ignoreParseErrors
```
- Class org.apache.flink.formats.csv.CsvRowDataDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - resultTypeInfo
```
TypeInformation<T> resultTypeInfo
```
      Type information describing the result type.
    - runtimeConverter
```
CsvToRowDataConverters.CsvToRowDataConverter runtimeConverter
```
      Runtime instance that performs the actual work.
    - csvSchema
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema
```
      Schema describing the input CSV data.
    - objectReader
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectReader objectReader
```
      Object reader used to read rows. It is configured by CsvSchema.
    - ignoreParseErrors
```
boolean ignoreParseErrors
```
      Flag indicating whether to ignore invalid fields/rows (default: throw an exception).
- Class org.apache.flink.formats.csv.CsvRowDataSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - rowType
```
RowType rowType
```
      Logical row type describing the input CSV data.
    - runtimeConverter
```
RowDataToCsvConverters.RowDataToCsvConverter runtimeConverter
```
      Runtime instance that performs the actual work.
    - csvMapper
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvMapper csvMapper
```
      CsvMapper used to write JsonNode into bytes.
    - csvSchema
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema
```
      Schema describing the input CSV data.
    - objectWriter
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectWriter objectWriter
```
      Object writer used to write rows. It is configured by CsvSchema.
- Class org.apache.flink.formats.csv.CsvRowDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  2135553495874539201L
  - Serialized Fields
    - typeInfo
```
TypeInformation<T> typeInfo
```
      Type information describing the result type.
    - runtimeConverter
```
org.apache.flink.formats.csv.CsvRowDeserializationSchema.RuntimeConverter runtimeConverter
```
      Runtime instance that performs the actual work.
    - csvSchema
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema
```
      Schema describing the input CSV data.
    - objectReader
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectReader objectReader
```
      Object reader used to read rows. It is configured by CsvSchema.
    - ignoreParseErrors
```
boolean ignoreParseErrors
```
      Flag indicating whether to ignore invalid fields/rows (default: throw an exception).
- Class org.apache.flink.formats.csv.CsvRowSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  2098447220136965L
  - Serialized Fields
    - typeInfo
```
RowTypeInfo typeInfo
```
      Type information describing the input CSV data.
    - runtimeConverter
```
org.apache.flink.formats.csv.CsvRowSerializationSchema.RuntimeConverter runtimeConverter
```
      Runtime instance that performs the actual work.
    - csvMapper
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvMapper csvMapper
```
      CsvMapper used to write JsonNode into bytes.
    - csvSchema
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema
```
      Schema describing the input CSV data.
    - objectWriter
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectWriter objectWriter
```
      Object writer used to write rows. It is configured by CsvSchema.
- Class org.apache.flink.formats.csv.CsvToRowDataConverters extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ignoreParseErrors
```
boolean ignoreParseErrors
```
      Flag indicating whether to ignore invalid fields/rows (default: throw an exception).
- Class org.apache.flink.formats.csv.RowCsvInputFormat extends AbstractCsvInputFormat<Row> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldTypes
```
TypeInformation<T>[] fieldTypes
```
    - selectedFieldNames
```
String[] selectedFieldNames
```
    - ignoreParseErrors
```
boolean ignoreParseErrors
```
- Class org.apache.flink.formats.csv.RowCsvInputFormat.Builder extends Object implements Serializable
  - Serialized Fields
    - filePaths
```
Path[] filePaths
```
    - fieldTypes
```
TypeInformation<T>[] fieldTypes
```
    - csvSchema
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema
```
    - ignoreParseErrors
```
boolean ignoreParseErrors
```
    - selectedFields
```
int[] selectedFields
```
- Class org.apache.flink.formats.csv.RowDataToCsvConverters extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.formats.hadoop.bulk
- Class org.apache.flink.formats.hadoop.bulk.DefaultHadoopFileCommitterFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.formats.json
- Class org.apache.flink.formats.json.JsonNodeDeserializationSchema extends AbstractDeserializationSchema<org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode> implements Serializable
  
  serialVersionUID:
  
  -1699854177598621044L
  - Serialized Fields
    - mapper
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper mapper
```
- Class org.apache.flink.formats.json.JsonRowDataDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - failOnMissingField
```
boolean failOnMissingField
```
      Flag indicating whether to fail if a field is missing.
    - ignoreParseErrors
```
boolean ignoreParseErrors
```
      Flag indicating whether to ignore invalid fields/rows (default: throw an exception).
    - resultTypeInfo
```
TypeInformation<T> resultTypeInfo
```
      TypeInformation of the produced RowData.
    - runtimeConverter
```
JsonToRowDataConverters.JsonToRowDataConverter runtimeConverter
```
      Runtime converter that converts JsonNodes into objects of Flink SQL internal data structures.
    - objectMapper
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper objectMapper
```
      Object mapper for parsing the JSON.
    - timestampFormat
```
TimestampFormat timestampFormat
```
      Timestamp format specification which is used to parse timestamp.
- Class org.apache.flink.formats.json.JsonRowDataSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - rowType
```
RowType rowType
```
      RowType to generate the runtime converter.
    - runtimeConverter
```
RowDataToJsonConverters.RowDataToJsonConverter runtimeConverter
```
      The converter that converts internal data formats to JsonNode.
    - mapper
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper mapper
```
      Object mapper that is used to create output JSON objects.
    - timestampFormat
```
TimestampFormat timestampFormat
```
      Timestamp format specification which is used to parse timestamp.
    - mapNullKeyMode
```
JsonOptions.MapNullKeyMode mapNullKeyMode
```
      The handling mode when serializing null keys for map data.
    - mapNullKeyLiteral
```
String mapNullKeyLiteral
```
      The string literal when handling mode for map null key LITERAL.
    - encodeDecimalAsPlainNumber
```
boolean encodeDecimalAsPlainNumber
```
      Flag indicating whether to serialize all decimals as plain numbers.
- Class org.apache.flink.formats.json.JsonRowDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  -228294330688809195L
  - Serialized Fields
    - typeInfo
```
RowTypeInfo typeInfo
```
      Type information describing the result type.
    - failOnMissingField
```
boolean failOnMissingField
```
    - objectMapper
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper objectMapper
```
      Object mapper for parsing the JSON.
    - runtimeConverter
```
org.apache.flink.formats.json.JsonRowDeserializationSchema.DeserializationRuntimeConverter runtimeConverter
```
    - ignoreParseErrors
```
boolean ignoreParseErrors
```
      Flag indicating whether to ignore invalid fields/rows (default: throw an exception).
- Class org.apache.flink.formats.json.JsonRowSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  -2885556750743978636L
  - Serialized Fields
    - typeInfo
```
RowTypeInfo typeInfo
```
      Type information describing the input type.
    - mapper
```
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper mapper
```
      Object mapper that is used to create output JSON objects.
    - runtimeConverter
```
org.apache.flink.formats.json.JsonRowSerializationSchema.SerializationRuntimeConverter runtimeConverter
```
- Class org.apache.flink.formats.json.JsonToRowDataConverters extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - failOnMissingField
```
boolean failOnMissingField
```
      Flag indicating whether to fail if a field is missing.
    - ignoreParseErrors
```
boolean ignoreParseErrors
```
      Flag indicating whether to ignore invalid fields/rows (default: throw an exception).
    - timestampFormat
```
TimestampFormat timestampFormat
```
      Timestamp format specification which is used to parse timestamp.
- Class org.apache.flink.formats.json.RowDataToJsonConverters extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - timestampFormat
```
TimestampFormat timestampFormat
```
      Timestamp format specification which is used to parse timestamp.
    - mapNullKeyMode
```
JsonOptions.MapNullKeyMode mapNullKeyMode
```
      The handling mode when serializing null keys for map data.
    - mapNullKeyLiteral
```
String mapNullKeyLiteral
```
      The string literal when handling mode for map null key LITERAL. is
Package org.apache.flink.formats.json.canal
- Class org.apache.flink.formats.json.canal.CanalJsonDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jsonDeserializer
```
JsonRowDataDeserializationSchema jsonDeserializer
```
      The deserializer to deserialize Canal JSON data.
    - hasMetadata
```
boolean hasMetadata
```
      Flag that indicates that an additional projection is required for metadata.
    - metadataConverters
```
org.apache.flink.formats.json.canal.CanalJsonDeserializationSchema.MetadataConverter[] metadataConverters
```
      Metadata to be extracted for every record.
    - producedTypeInfo
```
TypeInformation<T> producedTypeInfo
```
      TypeInformation of the produced RowData (physical + meta data).
    - database
```
String database
```
      Only read changelogs from the specific database.
    - table
```
String table
```
      Only read changelogs from the specific table.
    - ignoreParseErrors
```
boolean ignoreParseErrors
```
      Flag indicating whether to ignore invalid fields/rows (default: throw an exception).
    - fieldNames
```
List<E> fieldNames
```
      Names of fields.
    - fieldCount
```
int fieldCount
```
      Number of fields.
    - databasePattern
```
Pattern databasePattern
```
      Pattern of the specific database.
    - tablePattern
```
Pattern tablePattern
```
      Pattern of the specific table.
- Class org.apache.flink.formats.json.canal.CanalJsonSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jsonSerializer
```
JsonRowDataSerializationSchema jsonSerializer
```
      The serializer to serialize Canal JSON data.
Package org.apache.flink.formats.json.debezium
- Class org.apache.flink.formats.json.debezium.DebeziumJsonDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jsonDeserializer
```
JsonRowDataDeserializationSchema jsonDeserializer
```
      The deserializer to deserialize Debezium JSON data.
    - hasMetadata
```
boolean hasMetadata
```
      Flag that indicates that an additional projection is required for metadata.
    - metadataConverters
```
org.apache.flink.formats.json.debezium.DebeziumJsonDeserializationSchema.MetadataConverter[] metadataConverters
```
      Metadata to be extracted for every record.
    - producedTypeInfo
```
TypeInformation<T> producedTypeInfo
```
      TypeInformation of the produced RowData (physical + meta data).
    - schemaInclude
```
boolean schemaInclude
```
      Flag indicating whether the Debezium JSON data contains schema part or not. When Debezium Kafka Connect enables "value.converter.schemas.enable", the JSON will contain "schema" information, but we just ignore "schema" and extract data from "payload".
    - ignoreParseErrors
```
boolean ignoreParseErrors
```
      Flag indicating whether to ignore invalid fields/rows (default: throw an exception).
- Class org.apache.flink.formats.json.debezium.DebeziumJsonSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jsonSerializer
```
JsonRowDataSerializationSchema jsonSerializer
```
      The serializer to serialize Debezium JSON data. *
Package org.apache.flink.formats.json.maxwell
- Class org.apache.flink.formats.json.maxwell.MaxwellJsonDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jsonDeserializer
```
JsonRowDataDeserializationSchema jsonDeserializer
```
      The deserializer to deserialize Maxwell JSON data.
    - resultTypeInfo
```
TypeInformation<T> resultTypeInfo
```
      TypeInformation of the produced RowData. *
    - ignoreParseErrors
```
boolean ignoreParseErrors
```
      Flag indicating whether to ignore invalid fields/rows (default: throw an exception).
    - fieldCount
```
int fieldCount
```
      Number of fields.
- Class org.apache.flink.formats.json.maxwell.MaxwellJsonSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jsonSerializer
```
JsonRowDataSerializationSchema jsonSerializer
```
    - timestampFormat
```
TimestampFormat timestampFormat
```
      Timestamp format specification which is used to parse timestamp.
Package org.apache.flink.formats.parquet
- Class org.apache.flink.formats.parquet.ParquetAvroInputFormat extends ParquetInputFormat<org.apache.avro.generic.GenericRecord> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - avroSchemaString
```
String avroSchemaString
```
- Class org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat extends ParquetVectorizedInputFormat<RowData,SplitT extends FileSourceSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - producedType
```
RowType producedType
```
- Class org.apache.flink.formats.parquet.ParquetInputFormat extends FileInputFormat<E> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - skipWrongSchemaFileSplit
```
boolean skipWrongSchemaFileSplit
```
      The flag to specify whether to skip file splits with wrong schema.
    - skipCorruptedRecord
```
boolean skipCorruptedRecord
```
      The flag to specify whether to skip corrupted record.
    - skipThisSplit
```
boolean skipThisSplit
```
      The flag to track that the current split should be skipped.
    - fieldTypes
```
TypeInformation<T>[] fieldTypes
```
    - fieldNames
```
String[] fieldNames
```
    - filterPredicate
```
org.apache.parquet.filter2.predicate.FilterPredicate filterPredicate
```
- Class org.apache.flink.formats.parquet.ParquetMapInputFormat extends ParquetInputFormat<Map> implements Serializable
- Class org.apache.flink.formats.parquet.ParquetPojoInputFormat extends ParquetInputFormat<E> implements Serializable
  - Serialized Fields
    - pojoTypeClass
```
Class<T> pojoTypeClass
```
    - typeSerializer
```
TypeSerializer<T> typeSerializer
```
- Class org.apache.flink.formats.parquet.ParquetRowInputFormat extends ParquetInputFormat<Row> implements Serializable
  
  serialVersionUID:
  
  11L
- Class org.apache.flink.formats.parquet.ParquetVectorizedInputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hadoopConfig
```
SerializableConfiguration hadoopConfig
```
    - projectedFields
```
String[] projectedFields
```
    - projectedTypes
```
LogicalType[] projectedTypes
```
    - batchFactory
```
ColumnBatchFactory<SplitT extends FileSourceSplit> batchFactory
```
    - batchSize
```
int batchSize
```
    - isUtcTimestamp
```
boolean isUtcTimestamp
```
    - isCaseSensitive
```
boolean isCaseSensitive
```
- Class org.apache.flink.formats.parquet.ParquetWriterFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - writerBuilder
```
ParquetBuilder<T> writerBuilder
```
      The builder to construct the ParquetWriter.
Package org.apache.flink.formats.parquet.row
- Class org.apache.flink.formats.parquet.row.ParquetRowDataBuilder.FlinkParquetBuilder extends Object implements Serializable
  - Serialized Fields
    - rowType
```
RowType rowType
```
    - configuration
```
SerializableConfiguration configuration
```
    - utcTimestamp
```
boolean utcTimestamp
```
Package org.apache.flink.formats.parquet.utils
- Class org.apache.flink.formats.parquet.utils.SerializableConfiguration 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
    - conf
```
Configuration conf
```
Package org.apache.flink.formats.parquet.vector
Package org.apache.flink.formats.sequencefile
- Class org.apache.flink.formats.sequencefile.SequenceFileWriterFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - serializableHadoopConfig
```
org.apache.flink.formats.sequencefile.SerializableHadoopConfiguration serializableHadoopConfig
```
    - keyClass
```
Class<T> keyClass
```
    - valueClass
```
Class<T> valueClass
```
    - compressionCodecName
```
String compressionCodecName
```
    - compressionType
```
org.apache.hadoop.io.SequenceFile.CompressionType compressionType
```
Package org.apache.flink.graph
- Class org.apache.flink.graph.AnalyticHelper extends RichOutputFormat<T> implements Serializable
  - Serialized Fields
    - id
```
String id
```
- Class org.apache.flink.graph.Edge extends Tuple3<K,K,V> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.Triplet extends Tuple5<K,K,VV,VV,EV> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.Vertex extends Tuple2<K,V> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.graph.asm.dataset
- Class org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum extends Object implements Serializable
  - Serialized Fields
    - count
```
long count
```
    - checksum
```
long checksum
```
Package org.apache.flink.graph.asm.degree.annotate
- Class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.DegreeCount extends Object implements Serializable
- Class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.JoinEdgeDegreeWithVertexDegree extends Object implements Serializable
  - Serialized Fields
    - valueAndDegrees
```
Tuple3<T0,T1,T2> valueAndDegrees
```
    - output
```
Edge<K,V> output
```
- Class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.JoinEdgeWithVertexDegree extends Object implements Serializable
  - Serialized Fields
    - valueAndDegree
```
Tuple2<T0,T1> valueAndDegree
```
    - output
```
Edge<K,V> output
```
- Class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.JoinVertexWithVertexDegree extends Object implements Serializable
  - Serialized Fields
    - zero
```
LongValue zero
```
    - output
```
Vertex<K,V> output
```
- Class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.MapEdgeToSourceId extends Object implements Serializable
  - Serialized Fields
    - output
```
Vertex<K,V> output
```
- Class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.MapEdgeToTargetId extends Object implements Serializable
  - Serialized Fields
    - output
```
Vertex<K,V> output
```
Package org.apache.flink.graph.asm.degree.annotate.directed
- Class org.apache.flink.graph.asm.degree.annotate.directed.VertexDegrees.Degrees extends Tuple3<LongValue,LongValue,LongValue> implements Serializable
  - Serialized Fields
    - hasher
```
MurmurHash hasher
```
Package org.apache.flink.graph.asm.result
- Class org.apache.flink.graph.asm.result.BinaryResult.MirrorResult extends Object implements Serializable
- Class org.apache.flink.graph.asm.result.BinaryResultBase extends ResultBase implements Serializable
  - Serialized Fields
    - vertexId0
```
Object vertexId0
```
    - vertexId1
```
Object vertexId1
```
- Class org.apache.flink.graph.asm.result.TertiaryResultBase extends ResultBase implements Serializable
  - Serialized Fields
    - vertexId0
```
Object vertexId0
```
    - vertexId1
```
Object vertexId1
```
    - vertexId2
```
Object vertexId2
```
- Class org.apache.flink.graph.asm.result.UnaryResultBase extends ResultBase implements Serializable
  - Serialized Fields
    - vertexId0
```
Object vertexId0
```
Package org.apache.flink.graph.asm.translate
- Class org.apache.flink.graph.asm.translate.RichTranslateFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.graph.asm.translate.translators
- Class org.apache.flink.graph.asm.translate.translators.LongToLongValue extends Object implements Serializable
- Class org.apache.flink.graph.asm.translate.translators.LongValueAddOffset extends Object implements Serializable
  - Serialized Fields
    - offset
```
long offset
```
- Class org.apache.flink.graph.asm.translate.translators.LongValueToSignedIntValue extends Object implements Serializable
- Class org.apache.flink.graph.asm.translate.translators.LongValueToStringValue extends Object implements Serializable
- Class org.apache.flink.graph.asm.translate.translators.LongValueToUnsignedIntValue extends Object implements Serializable
- Class org.apache.flink.graph.asm.translate.translators.ToNullValue extends Object implements Serializable
Package org.apache.flink.graph.bipartite
- Class org.apache.flink.graph.bipartite.BipartiteEdge extends Tuple3<KT,KB,EV> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.bipartite.Projection extends Tuple6<KC,VVC,VV,VV,EV,EV> implements Serializable
Package org.apache.flink.graph.drivers.transform
- Class org.apache.flink.graph.drivers.transform.LongValueWithProperHashCode extends LongValue implements Serializable
- Class org.apache.flink.graph.drivers.transform.LongValueWithProperHashCode.LongValueWithProperHashCodeSerializer extends TypeSerializerSingleton<LongValueWithProperHashCode> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.drivers.transform.LongValueWithProperHashCode.LongValueWithProperHashCodeTypeInfo extends TypeInformation<LongValueWithProperHashCode> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.graph.examples
- Class org.apache.flink.graph.examples.EuclideanGraphWeighing.Point extends Object implements Serializable
  - Serialized Fields
    - x
```
double x
```
    - y
```
double y
```
- Class org.apache.flink.graph.examples.IncrementalSSSP.InvalidateMessenger extends ScatterFunction<Long,Double,Double,Double> implements Serializable
  - Serialized Fields
    - edgeToBeRemoved
```
Edge<K,V> edgeToBeRemoved
```
- Class org.apache.flink.graph.examples.IncrementalSSSP.VertexDistanceUpdater extends GatherFunction<Long,Double,Double> implements Serializable
- Class org.apache.flink.graph.examples.PageRank.RankMessenger extends ScatterFunction<K,Double,Double,Double> implements Serializable
- Class org.apache.flink.graph.examples.PageRank.VertexRankUpdater extends GatherFunction<K,Double,Double> implements Serializable
  - Serialized Fields
    - beta
```
double beta
```
- Class org.apache.flink.graph.examples.PregelSSSP.SSSPCombiner extends MessageCombiner<Long,Double> implements Serializable
- Class org.apache.flink.graph.examples.PregelSSSP.SSSPComputeFunction extends ComputeFunction<Long,Double,Double,Double> implements Serializable
  - Serialized Fields
    - srcId
```
long srcId
```
Package org.apache.flink.graph.generator
- Class org.apache.flink.graph.generator.CirculantGraph.OffsetRange extends Object implements Serializable
  - Serialized Fields
    - offset
```
long offset
```
    - length
```
long length
```
Package org.apache.flink.graph.gsa
- Class org.apache.flink.graph.gsa.ApplyFunction extends Object implements Serializable
  - Serialized Fields
    - numberOfVertices
```
long numberOfVertices
```
    - runtimeContext
```
IterationRuntimeContext runtimeContext
```
    - out
```
Collector<T> out
```
    - outVal
```
Vertex<K,V> outVal
```
- Class org.apache.flink.graph.gsa.GatherFunction extends Object implements Serializable
  - Serialized Fields
    - numberOfVertices
```
long numberOfVertices
```
    - runtimeContext
```
IterationRuntimeContext runtimeContext
```
- Class org.apache.flink.graph.gsa.Neighbor extends Tuple2<VV,EV> implements Serializable
- Class org.apache.flink.graph.gsa.SumFunction extends Object implements Serializable
  - Serialized Fields
    - numberOfVertices
```
long numberOfVertices
```
    - runtimeContext
```
IterationRuntimeContext runtimeContext
```
Package org.apache.flink.graph.library
- Class org.apache.flink.graph.library.ConnectedComponents.CCMessenger extends ScatterFunction<K,VV extends Comparable<VV>,VV extends Comparable<VV>,NullValue> implements Serializable
  - Serialized Fields
    - typeInformation
```
TypeInformation<T> typeInformation
```
- Class org.apache.flink.graph.library.ConnectedComponents.CCUpdater extends GatherFunction<K,VV extends Comparable<VV>,VV extends Comparable<VV>> implements Serializable
- Class org.apache.flink.graph.library.LabelPropagation.SendNewLabelToNeighbors extends ScatterFunction<K,VV extends Comparable<VV>,VV extends Comparable<VV>,NullValue> implements Serializable
  - Serialized Fields
    - typeInformation
```
TypeInformation<T> typeInformation
```
- Class org.apache.flink.graph.library.LabelPropagation.UpdateVertexLabel extends GatherFunction<K,VV extends Comparable<VV>,VV extends Comparable<VV>> implements Serializable
- Class org.apache.flink.graph.library.SingleSourceShortestPaths.MinDistanceMessenger extends ScatterFunction<K,Double,Double,Double> implements Serializable
- Class org.apache.flink.graph.library.SingleSourceShortestPaths.VertexDistanceUpdater extends GatherFunction<K,Double,Double> implements Serializable
- Class org.apache.flink.graph.library.Summarization.EdgeValue extends Tuple2<EV,Long> implements Serializable
- Class org.apache.flink.graph.library.Summarization.VertexGroupItem extends Tuple4<K,K,Either<VGV,NullValue>,Long> implements Serializable
  - Serialized Fields
    - nullValue
```
Either.Right<L,R> nullValue
```
- Class org.apache.flink.graph.library.Summarization.VertexValue extends Tuple2<VV,Long> implements Serializable
- Class org.apache.flink.graph.library.Summarization.VertexWithRepresentative extends Tuple2<K,K> implements Serializable
- Class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees extends Tuple4<K,K,Integer,Integer> implements Serializable
- Class org.apache.flink.graph.library.TriangleEnumerator.Triad extends Tuple3<K,K,K> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.graph.library.clustering.directed
- Class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient.Result extends UnaryResultBase<T> implements Serializable
  - Serialized Fields
    - degree
```
LongValue degree
```
    - triangleCount
```
LongValue triangleCount
```
- Class org.apache.flink.graph.library.clustering.directed.TriangleListing.Result extends TertiaryResultBase<T> implements Serializable
  - Serialized Fields
    - bitmask
```
ByteValue bitmask
```
Package org.apache.flink.graph.library.clustering.undirected
- Class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient.Result extends UnaryResultBase<T> implements Serializable
  - Serialized Fields
    - degree
```
LongValue degree
```
    - triangleCount
```
LongValue triangleCount
```
- Class org.apache.flink.graph.library.clustering.undirected.TriangleListing.Result extends TertiaryResultBase<T> implements Serializable
Package org.apache.flink.graph.library.linkanalysis
- Class org.apache.flink.graph.library.linkanalysis.Functions.SumScore extends Object implements Serializable
- Class org.apache.flink.graph.library.linkanalysis.HITS.Result extends UnaryResultBase<T> implements Serializable
  - Serialized Fields
    - hubScore
```
DoubleValue hubScore
```
    - authorityScore
```
DoubleValue authorityScore
```
- Class org.apache.flink.graph.library.linkanalysis.PageRank.Result extends UnaryResultBase<T> implements Serializable
  - Serialized Fields
    - pageRankScore
```
DoubleValue pageRankScore
```
Package org.apache.flink.graph.library.similarity
- Class org.apache.flink.graph.library.similarity.AdamicAdar.Result extends BinaryResultBase<T> implements Serializable
  - Serialized Fields
    - adamicAdarScore
```
FloatValue adamicAdarScore
```
- Class org.apache.flink.graph.library.similarity.JaccardIndex.Result extends BinaryResultBase<T> implements Serializable
  - Serialized Fields
    - sharedNeighborCount
```
IntValue sharedNeighborCount
```
    - distinctNeighborCount
```
IntValue distinctNeighborCount
```
Package org.apache.flink.graph.pregel
- Class org.apache.flink.graph.pregel.ComputeFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - outVertex
```
Vertex<K,V> outVertex
```
    - outMsg
```
Tuple2<T0,T1> outMsg
```
    - runtimeContext
```
IterationRuntimeContext runtimeContext
```
    - edges
```
Iterator<E> edges
```
    - out
```
Collector<T> out
```
    - edgeIterator
```
org.apache.flink.graph.pregel.ComputeFunction.EdgesIterator<K,EV> edgeIterator
```
    - edgesUsed
```
boolean edgesUsed
```
    - setNewVertexValueCalled
```
boolean setNewVertexValueCalled
```
- Class org.apache.flink.graph.pregel.MessageCombiner extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - out
```
Collector<T> out
```
    - outValue
```
Tuple2<T0,T1> outValue
```
- Class org.apache.flink.graph.pregel.MessageIterator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - first
```
Object first
```
Package org.apache.flink.graph.spargel
- Class org.apache.flink.graph.spargel.GatherFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - numberOfVertices
```
long numberOfVertices
```
    - optDegrees
```
boolean optDegrees
```
    - runtimeContext
```
IterationRuntimeContext runtimeContext
```
    - out
```
Collector<T> out
```
    - outWithDegrees
```
Collector<T> outWithDegrees
```
    - outVal
```
Vertex<K,V> outVal
```
    - outValWithDegrees
```
Vertex<K,V> outValWithDegrees
```
    - inDegree
```
long inDegree
```
    - outDegree
```
long outDegree
```
    - setNewVertexValueCalled
```
boolean setNewVertexValueCalled
```
- Class org.apache.flink.graph.spargel.MessageIterator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.spargel.ScatterFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - numberOfVertices
```
long numberOfVertices
```
    - direction
```
EdgeDirection direction
```
    - outValue
```
Tuple2<T0,T1> outValue
```
    - runtimeContext
```
IterationRuntimeContext runtimeContext
```
    - edges
```
Iterator<E> edges
```
    - out
```
Collector<T> out
```
    - vertexId
```
Object vertexId
```
    - edgeIterator
```
org.apache.flink.graph.spargel.ScatterFunction.EdgesIterator<K,EV> edgeIterator
```
    - edgesUsed
```
boolean edgesUsed
```
    - inDegree
```
long inDegree
```
    - outDegree
```
long outDegree
```
Package org.apache.flink.graph.types.valuearray
- Class org.apache.flink.graph.types.valuearray.ByteValueArray extends Object implements Serializable
  - Serialized Fields
    - isBounded
```
boolean isBounded
```
    - data
```
byte[] data
```
    - position
```
int position
```
    - hash
```
MurmurHash hash
```
    - hashValue
```
IntValue hashValue
```
    - iterator
```
org.apache.flink.graph.types.valuearray.ByteValueArray.ReadIterator iterator
```
- Class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator extends TypeComparator<ByteValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
ByteValueArray reference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.graph.types.valuearray.ByteValueArraySerializer extends TypeSerializerSingleton<ByteValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.types.valuearray.CharValueArray extends Object implements Serializable
  - Serialized Fields
    - isBounded
```
boolean isBounded
```
    - data
```
char[] data
```
    - position
```
int position
```
    - hash
```
MurmurHash hash
```
    - hashValue
```
IntValue hashValue
```
    - iterator
```
org.apache.flink.graph.types.valuearray.CharValueArray.ReadIterator iterator
```
- Class org.apache.flink.graph.types.valuearray.CharValueArrayComparator extends TypeComparator<CharValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
CharValueArray reference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.graph.types.valuearray.CharValueArraySerializer extends TypeSerializerSingleton<CharValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.types.valuearray.DoubleValueArray extends Object implements Serializable
  - Serialized Fields
    - isBounded
```
boolean isBounded
```
    - data
```
double[] data
```
    - position
```
int position
```
    - hash
```
MurmurHash hash
```
    - hashValue
```
IntValue hashValue
```
    - iterator
```
org.apache.flink.graph.types.valuearray.DoubleValueArray.ReadIterator iterator
```
- Class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator extends TypeComparator<DoubleValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
DoubleValueArray reference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.graph.types.valuearray.DoubleValueArraySerializer extends TypeSerializerSingleton<DoubleValueArray> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.graph.types.valuearray.FloatValueArray extends Object implements Serializable
  - Serialized Fields
    - isBounded
```
boolean isBounded
```
    - data
```
float[] data
```
    - position
```
int position
```
    - hash
```
MurmurHash hash
```
    - hashValue
```
IntValue hashValue
```
    - iterator
```
org.apache.flink.graph.types.valuearray.FloatValueArray.ReadIterator iterator
```
- Class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator extends <

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

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.addons.hbase1

Class org.apache.flink.addons.hbase1.TableInputFormat extends HBaseInputFormat<T extends Tuple> 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

executionRetryDelay

restartStrategyConfiguration

taskCancellationIntervalMillis

taskCancellationTimeoutMillis

useSnapshotCompression

globalJobParameters

registeredTypesWithKryoSerializers

registeredTypesWithKryoSerializerClasses

defaultKryoSerializers

defaultKryoSerializerClasses

registeredKryoTypes

registeredPojoTypes