Serialized Form (Flink : 1.16-SNAPSHOT API)

Package com.google.protobuf
- Class com.google.protobuf.Any extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - cachedUnpackValue
```
com.google.protobuf.Message cachedUnpackValue
```
    - typeUrl_
```
Object typeUrl_
```
    - value_
```
com.google.protobuf.ByteString value_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.Api extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - name_
```
Object name_
```
    - methods_
```
List<E> methods_
```
    - options_
```
List<E> options_
```
    - version_
```
Object version_
```
    - sourceContext_
```
com.google.protobuf.SourceContext sourceContext_
```
    - mixins_
```
List<E> mixins_
```
    - syntax_
```
int syntax_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.BoolValue extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - value_
```
boolean value_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.ByteString extends Object implements Serializable
  - Serialized Fields
    - hash
```
int hash
```
- Class com.google.protobuf.BytesValue extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - value_
```
com.google.protobuf.ByteString value_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.CodedOutputStream.OutOfSpaceException extends IOException implements Serializable
  
  serialVersionUID:
  
  -6947486886997889499L
- Class com.google.protobuf.DescriptorProtos.DescriptorProto extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - name_
```
Object name_
```
    - field_
```
List<E> field_
```
    - extension_
```
List<E> extension_
```
    - nestedType_
```
List<E> nestedType_
```
    - enumType_
```
List<E> enumType_
```
    - extensionRange_
```
List<E> extensionRange_
```
    - oneofDecl_
```
List<E> oneofDecl_
```
    - options_
```
com.google.protobuf.DescriptorProtos.MessageOptions options_
```
    - reservedRange_
```
List<E> reservedRange_
```
    - reservedName_
```
com.google.protobuf.LazyStringList reservedName_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.DescriptorProto.ExtensionRange extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - start_
```
int start_
```
    - end_
```
int end_
```
    - options_
```
com.google.protobuf.DescriptorProtos.ExtensionRangeOptions options_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.DescriptorProto.ReservedRange extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - start_
```
int start_
```
    - end_
```
int end_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.EnumDescriptorProto extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - name_
```
Object name_
```
    - value_
```
List<E> value_
```
    - options_
```
com.google.protobuf.DescriptorProtos.EnumOptions options_
```
    - reservedRange_
```
List<E> reservedRange_
```
    - reservedName_
```
com.google.protobuf.LazyStringList reservedName_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.EnumDescriptorProto.EnumReservedRange extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - start_
```
int start_
```
    - end_
```
int end_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.EnumOptions extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<com.google.protobuf.DescriptorProtos.EnumOptions> implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - allowAlias_
```
boolean allowAlias_
```
    - deprecated_
```
boolean deprecated_
```
    - uninterpretedOption_
```
List<E> uninterpretedOption_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.EnumValueDescriptorProto extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - name_
```
Object name_
```
    - number_
```
int number_
```
    - options_
```
com.google.protobuf.DescriptorProtos.EnumValueOptions options_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.EnumValueOptions extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<com.google.protobuf.DescriptorProtos.EnumValueOptions> implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - deprecated_
```
boolean deprecated_
```
    - uninterpretedOption_
```
List<E> uninterpretedOption_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.ExtensionRangeOptions extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<com.google.protobuf.DescriptorProtos.ExtensionRangeOptions> implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - uninterpretedOption_
```
List<E> uninterpretedOption_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.FieldDescriptorProto extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - name_
```
Object name_
```
    - number_
```
int number_
```
    - label_
```
int label_
```
    - type_
```
int type_
```
    - typeName_
```
Object typeName_
```
    - extendee_
```
Object extendee_
```
    - defaultValue_
```
Object defaultValue_
```
    - oneofIndex_
```
int oneofIndex_
```
    - jsonName_
```
Object jsonName_
```
    - options_
```
com.google.protobuf.DescriptorProtos.FieldOptions options_
```
    - proto3Optional_
```
boolean proto3Optional_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.FieldOptions extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<com.google.protobuf.DescriptorProtos.FieldOptions> implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - ctype_
```
int ctype_
```
    - packed_
```
boolean packed_
```
    - jstype_
```
int jstype_
```
    - lazy_
```
boolean lazy_
```
    - deprecated_
```
boolean deprecated_
```
    - weak_
```
boolean weak_
```
    - uninterpretedOption_
```
List<E> uninterpretedOption_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.FileDescriptorProto extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - name_
```
Object name_
```
    - package_
```
Object package_
```
    - dependency_
```
com.google.protobuf.LazyStringList dependency_
```
    - publicDependency_
```
com.google.protobuf.Internal.IntList publicDependency_
```
    - weakDependency_
```
com.google.protobuf.Internal.IntList weakDependency_
```
    - messageType_
```
List<E> messageType_
```
    - enumType_
```
List<E> enumType_
```
    - service_
```
List<E> service_
```
    - extension_
```
List<E> extension_
```
    - options_
```
com.google.protobuf.DescriptorProtos.FileOptions options_
```
    - sourceCodeInfo_
```
com.google.protobuf.DescriptorProtos.SourceCodeInfo sourceCodeInfo_
```
    - syntax_
```
Object syntax_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.FileDescriptorSet extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - file_
```
List<E> file_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.FileOptions extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<com.google.protobuf.DescriptorProtos.FileOptions> implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - javaPackage_
```
Object javaPackage_
```
    - javaOuterClassname_
```
Object javaOuterClassname_
```
    - javaMultipleFiles_
```
boolean javaMultipleFiles_
```
    - javaGenerateEqualsAndHash_
```
boolean javaGenerateEqualsAndHash_
```
    - javaStringCheckUtf8_
```
boolean javaStringCheckUtf8_
```
    - optimizeFor_
```
int optimizeFor_
```
    - goPackage_
```
Object goPackage_
```
    - ccGenericServices_
```
boolean ccGenericServices_
```
    - javaGenericServices_
```
boolean javaGenericServices_
```
    - pyGenericServices_
```
boolean pyGenericServices_
```
    - phpGenericServices_
```
boolean phpGenericServices_
```
    - deprecated_
```
boolean deprecated_
```
    - ccEnableArenas_
```
boolean ccEnableArenas_
```
    - objcClassPrefix_
```
Object objcClassPrefix_
```
    - csharpNamespace_
```
Object csharpNamespace_
```
    - swiftPrefix_
```
Object swiftPrefix_
```
    - phpClassPrefix_
```
Object phpClassPrefix_
```
    - phpNamespace_
```
Object phpNamespace_
```
    - phpMetadataNamespace_
```
Object phpMetadataNamespace_
```
    - rubyPackage_
```
Object rubyPackage_
```
    - uninterpretedOption_
```
List<E> uninterpretedOption_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.GeneratedCodeInfo extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - annotation_
```
List<E> annotation_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.GeneratedCodeInfo.Annotation extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - path_
```
com.google.protobuf.Internal.IntList path_
```
    - pathMemoizedSerializedSize
```
int pathMemoizedSerializedSize
```
    - sourceFile_
```
Object sourceFile_
```
    - begin_
```
int begin_
```
    - end_
```
int end_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.MessageOptions extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<com.google.protobuf.DescriptorProtos.MessageOptions> implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - messageSetWireFormat_
```
boolean messageSetWireFormat_
```
    - noStandardDescriptorAccessor_
```
boolean noStandardDescriptorAccessor_
```
    - deprecated_
```
boolean deprecated_
```
    - mapEntry_
```
boolean mapEntry_
```
    - uninterpretedOption_
```
List<E> uninterpretedOption_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.MethodDescriptorProto extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - name_
```
Object name_
```
    - inputType_
```
Object inputType_
```
    - outputType_
```
Object outputType_
```
    - options_
```
com.google.protobuf.DescriptorProtos.MethodOptions options_
```
    - clientStreaming_
```
boolean clientStreaming_
```
    - serverStreaming_
```
boolean serverStreaming_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.MethodOptions extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<com.google.protobuf.DescriptorProtos.MethodOptions> implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - deprecated_
```
boolean deprecated_
```
    - idempotencyLevel_
```
int idempotencyLevel_
```
    - uninterpretedOption_
```
List<E> uninterpretedOption_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.OneofDescriptorProto extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - name_
```
Object name_
```
    - options_
```
com.google.protobuf.DescriptorProtos.OneofOptions options_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.OneofOptions extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<com.google.protobuf.DescriptorProtos.OneofOptions> implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - uninterpretedOption_
```
List<E> uninterpretedOption_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.ServiceDescriptorProto extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - name_
```
Object name_
```
    - method_
```
List<E> method_
```
    - options_
```
com.google.protobuf.DescriptorProtos.ServiceOptions options_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.ServiceOptions extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<com.google.protobuf.DescriptorProtos.ServiceOptions> implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - deprecated_
```
boolean deprecated_
```
    - uninterpretedOption_
```
List<E> uninterpretedOption_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.SourceCodeInfo extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - location_
```
List<E> location_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.SourceCodeInfo.Location extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - path_
```
com.google.protobuf.Internal.IntList path_
```
    - pathMemoizedSerializedSize
```
int pathMemoizedSerializedSize
```
    - span_
```
com.google.protobuf.Internal.IntList span_
```
    - spanMemoizedSerializedSize
```
int spanMemoizedSerializedSize
```
    - leadingComments_
```
Object leadingComments_
```
    - trailingComments_
```
Object trailingComments_
```
    - leadingDetachedComments_
```
com.google.protobuf.LazyStringList leadingDetachedComments_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.UninterpretedOption extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - name_
```
List<E> name_
```
    - identifierValue_
```
Object identifierValue_
```
    - positiveIntValue_
```
long positiveIntValue_
```
    - negativeIntValue_
```
long negativeIntValue_
```
    - doubleValue_
```
double doubleValue_
```
    - stringValue_
```
com.google.protobuf.ByteString stringValue_
```
    - aggregateValue_
```
Object aggregateValue_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.DescriptorProtos.UninterpretedOption.NamePart extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - bitField0_
```
int bitField0_
```
    - namePart_
```
Object namePart_
```
    - isExtension_
```
boolean isExtension_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.Descriptors.DescriptorValidationException extends Exception implements Serializable
  
  serialVersionUID:
  
  5750205775490483148L
  - Serialized Fields
    - name
```
String name
```
    - proto
```
com.google.protobuf.Message proto
```
    - description
```
String description
```
- Class com.google.protobuf.DoubleValue extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - value_
```
double value_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.Duration extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - seconds_
```
long seconds_
```
    - nanos_
```
int nanos_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.Empty extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.Enum extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - name_
```
Object name_
```
    - enumvalue_
```
List<E> enumvalue_
```
    - options_
```
List<E> options_
```
    - sourceContext_
```
com.google.protobuf.SourceContext sourceContext_
```
    - syntax_
```
int syntax_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.EnumValue extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - name_
```
Object name_
```
    - number_
```
int number_
```
    - options_
```
List<E> options_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.Field extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - kind_
```
int kind_
```
    - cardinality_
```
int cardinality_
```
    - number_
```
int number_
```
    - name_
```
Object name_
```
    - typeUrl_
```
Object typeUrl_
```
    - oneofIndex_
```
int oneofIndex_
```
    - packed_
```
boolean packed_
```
    - options_
```
List<E> options_
```
    - jsonName_
```
Object jsonName_
```
    - defaultValue_
```
Object defaultValue_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.FieldMask extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - paths_
```
com.google.protobuf.LazyStringList paths_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.FloatValue extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - value_
```
float value_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.GeneratedMessage extends com.google.protobuf.AbstractMessage implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - unknownFields
```
com.google.protobuf.UnknownFieldSet unknownFields
```
- Class com.google.protobuf.GeneratedMessage.ExtendableMessage extends com.google.protobuf.GeneratedMessage implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - extensions
```
com.google.protobuf.FieldSet<T extends com.google.protobuf.FieldSet.FieldDescriptorLite<T>> extensions
```
- Class com.google.protobuf.GeneratedMessageLite.SerializedForm extends Object implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - readResolve
```
protected Object readResolve()
                      throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - messageClass
```
Class<T> messageClass
```
    - messageClassName
```
String messageClassName
```
    - asBytes
```
byte[] asBytes
```
- Class com.google.protobuf.GeneratedMessageV3 extends com.google.protobuf.AbstractMessage implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - unknownFields
```
com.google.protobuf.UnknownFieldSet unknownFields
```
- Class com.google.protobuf.GeneratedMessageV3.ExtendableMessage extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - extensions
```
com.google.protobuf.FieldSet<T extends com.google.protobuf.FieldSet.FieldDescriptorLite<T>> extensions
```
- Class com.google.protobuf.HBaseZeroCopyByteString extends com.google.protobuf.LiteralByteString implements Serializable
- Class com.google.protobuf.Int32Value extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - value_
```
int value_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.Int64Value extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - value_
```
long value_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.InvalidProtocolBufferException extends IOException implements Serializable
  
  serialVersionUID:
  
  -1616151763072450476L
  - Serialized Fields
    - unfinishedMessage
```
com.google.protobuf.MessageLite unfinishedMessage
```
    - wasThrownFromInputStream
```
boolean wasThrownFromInputStream
```
- Class com.google.protobuf.InvalidProtocolBufferException.InvalidWireTypeException extends com.google.protobuf.InvalidProtocolBufferException implements Serializable
  
  serialVersionUID:
  
  3283890091615336259L
- Class com.google.protobuf.ListValue extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - values_
```
List<E> values_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.MapFieldLite extends LinkedHashMap<K,V> implements Serializable
  - Serialized Fields
    - isMutable
```
boolean isMutable
```
- Class com.google.protobuf.Method extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - name_
```
Object name_
```
    - requestTypeUrl_
```
Object requestTypeUrl_
```
    - requestStreaming_
```
boolean requestStreaming_
```
    - responseTypeUrl_
```
Object responseTypeUrl_
```
    - responseStreaming_
```
boolean responseStreaming_
```
    - options_
```
List<E> options_
```
    - syntax_
```
int syntax_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.Mixin extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - name_
```
Object name_
```
    - root_
```
Object root_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.Option extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - name_
```
Object name_
```
    - value_
```
com.google.protobuf.Any value_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.RpcUtil.AlreadyCalledException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  5469741279507848266L
- Class com.google.protobuf.ServiceException extends Exception implements Serializable
  
  serialVersionUID:
  
  -1219262335729891920L
- Class com.google.protobuf.SourceContext extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - fileName_
```
Object fileName_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.StringValue extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - value_
```
Object value_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.Struct extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - fields_
```
com.google.protobuf.MapField<K,V> fields_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.TextFormat.InvalidEscapeSequenceException extends IOException implements Serializable
  
  serialVersionUID:
  
  -8164033650142593304L
- Class com.google.protobuf.TextFormat.ParseException extends IOException implements Serializable
  
  serialVersionUID:
  
  3196188060225107702L
  - Serialized Fields
    - line
```
int line
```
    - column
```
int column
```
- Class com.google.protobuf.TextFormat.UnknownFieldParseException extends com.google.protobuf.TextFormat.ParseException implements Serializable
  - Serialized Fields
    - unknownField
```
String unknownField
```
- Class com.google.protobuf.Timestamp extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - seconds_
```
long seconds_
```
    - nanos_
```
int nanos_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.Type extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - name_
```
Object name_
```
    - fields_
```
List<E> fields_
```
    - oneofs_
```
com.google.protobuf.LazyStringList oneofs_
```
    - options_
```
List<E> options_
```
    - sourceContext_
```
com.google.protobuf.SourceContext sourceContext_
```
    - syntax_
```
int syntax_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.UInt32Value extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - value_
```
int value_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.UInt64Value extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - value_
```
long value_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
- Class com.google.protobuf.UninitializedMessageException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  -7466929953374883507L
  - Serialized Fields
    - missingFields
```
List<E> missingFields
```
- Class com.google.protobuf.Value extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - kindCase_
```
int kindCase_
```
    - kind_
```
Object kind_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
Package org.apache.calcite.jdbc
- Class org.apache.calcite.jdbc.JavaCollation extends org.apache.calcite.sql.SqlCollation implements Serializable
  - Serialized Fields
    - collator
```
Collator collator
```
- Class org.apache.calcite.jdbc.JavaRecordType extends org.apache.calcite.rel.type.RelRecordType implements Serializable
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
- Class org.apache.calcite.jdbc.SqlTimeoutException extends SQLException implements Serializable
Package org.apache.calcite.rex
- Class org.apache.calcite.rex.RexFieldCollation extends org.apache.calcite.util.Pair<org.apache.calcite.rex.RexNode,com.google.common.collect.ImmutableSet<org.apache.calcite.sql.SqlKind>> implements Serializable
- Class org.apache.calcite.rex.RexSlot.SelfPopulatingList extends CopyOnWriteArrayList<String> implements Serializable
  - Serialized Fields
    - prefix
```
String prefix
```
Package org.apache.calcite.sql
- Class org.apache.calcite.sql.SqlCollation extends Object implements Serializable
  - Serialized Fields
    - collationName
```
String collationName
```
    - wrappedCharset
```
org.apache.calcite.util.SerializableCharset wrappedCharset
```
    - locale
```
Locale locale
```
    - strength
```
String strength
```
    - coercibility
```
org.apache.calcite.sql.SqlCollation.Coercibility coercibility
```
Package org.apache.calcite.sql.validate
- Class org.apache.calcite.sql.validate.CyclicDefinitionException extends RuntimeException implements Serializable
  - Serialized Fields
    - depth
```
int depth
```
    - path
```
List<E> path
```
- Class org.apache.calcite.sql.validate.SqlValidatorException extends Exception implements Serializable
  
  serialVersionUID:
  
  -831683113957131387L
Package org.apache.calcite.sql2rel
- Class org.apache.calcite.sql2rel.RelFieldTrimmer.TrimResult extends org.apache.calcite.util.Pair<org.apache.calcite.rel.RelNode,org.apache.calcite.util.mapping.Mapping> implements Serializable
Package org.apache.flink.api.common
- Class org.apache.flink.api.common.ArchivedExecutionConfig extends Object implements Serializable
  
  serialVersionUID:
  
  2907040336948181163L
  - Serialized Fields
    - executionMode
```
String executionMode
```
    - restartStrategyDescription
```
String restartStrategyDescription
```
    - parallelism
```
int parallelism
```
    - maxParallelism
```
int maxParallelism
```
    - objectReuseEnabled
```
boolean objectReuseEnabled
```
    - periodicMaterializeIntervalMillis
```
long periodicMaterializeIntervalMillis
```
    - globalJobParameters
```
Map<K,V> globalJobParameters
```
- Class org.apache.flink.api.common.ExecutionConfig extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - executionMode
```
ExecutionMode executionMode
```
      Defines how data exchange happens - batch or pipelined
    - closureCleanerLevel
```
ExecutionConfig.ClosureCleanerLevel closureCleanerLevel
```
    - parallelism
```
int parallelism
```
    - maxParallelism
```
int maxParallelism
```
      The program wide maximum parallelism used for operators which haven't specified a maximum parallelism. The maximum parallelism specifies the upper limit for dynamic scaling and the number of key groups used for partitioned state.
    - numberOfExecutionRetries
```
int numberOfExecutionRetries
```
      Deprecated. Should no longer be used because it is subsumed by RestartStrategyConfiguration
    - forceKryo
```
boolean forceKryo
```
    - disableGenericTypes
```
boolean disableGenericTypes
```
      Flag to indicate whether generic types (through Kryo) are supported
    - enableAutoGeneratedUids
```
boolean enableAutoGeneratedUids
```
    - objectReuse
```
boolean objectReuse
```
    - autoTypeRegistrationEnabled
```
boolean autoTypeRegistrationEnabled
```
    - forceAvro
```
boolean forceAvro
```
    - autoWatermarkInterval
```
long autoWatermarkInterval
```
    - latencyTrackingInterval
```
long latencyTrackingInterval
```
      Interval in milliseconds for sending latency tracking marks from the sources to the sinks.
    - isLatencyTrackingConfigured
```
boolean isLatencyTrackingConfigured
```
    - periodicMaterializeIntervalMillis
```
long periodicMaterializeIntervalMillis
```
      Interval in milliseconds to perform periodic changelog materialization.
    - materializationMaxAllowedFailures
```
int materializationMaxAllowedFailures
```
      Max allowed number of consecutive failures for changelog materialization
    - executionRetryDelay
```
long executionRetryDelay
```
      Deprecated. Should no longer be used because it is subsumed by RestartStrategyConfiguration
    - restartStrategyConfiguration
```
RestartStrategies.RestartStrategyConfiguration restartStrategyConfiguration
```
    - isDynamicGraph
```
boolean isDynamicGraph
```
    - taskCancellationIntervalMillis
```
long taskCancellationIntervalMillis
```
    - taskCancellationTimeoutMillis
```
long taskCancellationTimeoutMillis
```
      Timeout after which an ongoing task cancellation will lead to a fatal TaskManager error, usually killing the JVM.
    - useSnapshotCompression
```
boolean useSnapshotCompression
```
      This flag defines if we use compression for the state snapshot data or not. Default: false
    - globalJobParameters
```
ExecutionConfig.GlobalJobParameters globalJobParameters
```
    - registeredTypesWithKryoSerializers
```
LinkedHashMap<K,V> registeredTypesWithKryoSerializers
```
    - registeredTypesWithKryoSerializerClasses
```
LinkedHashMap<K,V> registeredTypesWithKryoSerializerClasses
```
    - defaultKryoSerializers
```
LinkedHashMap<K,V> defaultKryoSerializers
```
    - defaultKryoSerializerClasses
```
LinkedHashMap<K,V> defaultKryoSerializerClasses
```
    - registeredKryoTypes
```
LinkedHashSet<E> registeredKryoTypes
```
    - registeredPojoTypes
```
LinkedHashSet<E> registeredPojoTypes
```
- Class org.apache.flink.api.common.ExecutionConfig.GlobalJobParameters extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.ExecutionConfig.SerializableSerializer extends Object implements Serializable
  
  serialVersionUID:
  
  4687893502781067189L
  - Serialized Fields
    - serializer
```
com.esotericsoftware.kryo.Serializer<T> serializer
```
- Class org.apache.flink.api.common.InvalidProgramException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  3119881934024032887L
- Class org.apache.flink.api.common.JobID extends AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.NonSerializableUserCodeException extends InvalidProgramException implements Serializable
  
  serialVersionUID:
  
  2L
Package org.apache.flink.api.common.accumulators
- Class org.apache.flink.api.common.accumulators.AverageAccumulator extends Object implements Serializable
  
  serialVersionUID:
  
  3672555084179165255L
  - Serialized Fields
    - count
```
long count
```
    - sum
```
double sum
```
- Class org.apache.flink.api.common.accumulators.DoubleCounter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - localValue
```
double localValue
```
- Class org.apache.flink.api.common.accumulators.DoubleMaximum extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - max
```
double max
```
- Class org.apache.flink.api.common.accumulators.DoubleMinimum extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - min
```
double min
```
- Class org.apache.flink.api.common.accumulators.Histogram extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - treeMap
```
TreeMap<K,V> treeMap
```
- Class org.apache.flink.api.common.accumulators.IntCounter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - localValue
```
int localValue
```
- Class org.apache.flink.api.common.accumulators.IntMaximum extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - max
```
int max
```
- Class org.apache.flink.api.common.accumulators.IntMinimum extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - min
```
int min
```
- Class org.apache.flink.api.common.accumulators.ListAccumulator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - localValue
```
ArrayList<E> localValue
```
- Class org.apache.flink.api.common.accumulators.LongCounter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - localValue
```
long localValue
```
- Class org.apache.flink.api.common.accumulators.LongMaximum extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - max
```
long max
```
- Class org.apache.flink.api.common.accumulators.LongMinimum extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - min
```
long min
```
- Class org.apache.flink.api.common.accumulators.SerializedListAccumulator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - localValue
```
ArrayList<E> localValue
```
Package org.apache.flink.api.common.aggregators
- Class org.apache.flink.api.common.aggregators.DoubleSumAggregator extends Object implements Serializable
  - Serialized Fields
    - wrapper
```
DoubleValue wrapper
```
    - sum
```
double sum
```
- Class org.apache.flink.api.common.aggregators.DoubleZeroConvergence extends Object implements Serializable
- Class org.apache.flink.api.common.aggregators.LongSumAggregator extends Object implements Serializable
  - Serialized Fields
    - sum
```
long sum
```
- Class org.apache.flink.api.common.aggregators.LongZeroConvergence extends Object implements Serializable
Package org.apache.flink.api.common.cache
- Class org.apache.flink.api.common.cache.DistributedCache.DistributedCacheEntry extends Object implements Serializable
  - Serialized Fields
    - filePath
```
String filePath
```
    - isExecutable
```
Boolean isExecutable
```
    - isZipped
```
boolean isZipped
```
    - blobKey
```
byte[] blobKey
```
Package org.apache.flink.api.common.distributions
- Class org.apache.flink.api.common.distributions.CommonRangeBoundaries extends Object implements Serializable
  - Serialized Fields
    - typeComparator
```
TypeComparator<T> typeComparator
```
    - boundaries
```
Object[][] boundaries
```
    - flatComparators
```
TypeComparator<T>[] flatComparators
```
    - keys
```
Object[] keys
```
Package org.apache.flink.api.common.eventtime
- Class org.apache.flink.api.common.eventtime.TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - assigner
```
SerializableTimestampAssigner<T> assigner
```
- Class org.apache.flink.api.common.eventtime.Watermark extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - timestamp
```
long timestamp
```
      The timestamp of the watermark in milliseconds.
- Class org.apache.flink.api.common.eventtime.WatermarkAlignmentParams extends Object implements Serializable
  - Serialized Fields
    - maxAllowedWatermarkDrift
```
long maxAllowedWatermarkDrift
```
    - updateInterval
```
long updateInterval
```
    - watermarkGroup
```
String watermarkGroup
```
Package org.apache.flink.api.common.functions
- Class org.apache.flink.api.common.functions.AbstractRichFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.InvalidTypesException extends InvalidProgramException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichAggregateFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichCoGroupFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichCrossFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichFilterFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichFlatJoinFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichFlatMapFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichGroupCombineFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichGroupReduceFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichJoinFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichMapFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichMapPartitionFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.RichReduceFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.common.functions.util
- Class org.apache.flink.api.common.functions.util.NoOpFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.functions.util.PrintSinkOutputWriter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - target
```
boolean target
```
    - sinkIdentifier
```
String sinkIdentifier
```
Package org.apache.flink.api.common.io
- Class org.apache.flink.api.common.io.BinaryInputFormat extends FileInputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - blockSize
```
long blockSize
```
      The block size to use.
    - readRecords
```
long readRecords
```
      The number of records already read from the block. This is used to decide if the end of the block has been reached.
- Class org.apache.flink.api.common.io.BinaryOutputFormat extends FileOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - blockSize
```
long blockSize
```
      The block size to use.
- Class org.apache.flink.api.common.io.DelimitedInputFormat extends FileInputFormat<OT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - charsetName
```
String charsetName
```
    - offset
```
long offset
```
    - delimiter
```
byte[] delimiter
```
    - delimiterString
```
String delimiterString
```
    - lineLengthLimit
```
int lineLengthLimit
```
    - bufferSize
```
int bufferSize
```
    - numLineSamples
```
int numLineSamples
```
- Class org.apache.flink.api.common.io.DelimitedInputFormatTest.MyTextInputFormat extends DelimitedInputFormat<String> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.io.FileInputFormat extends RichInputFormat<OT,FileInputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - filePath
```
Path filePath
```
      Deprecated. Please override FileInputFormat.supportsMultiPaths() and use FileInputFormat.getFilePaths() and FileInputFormat.setFilePaths(Path...).
      
      The path to the file that contains the input.
    - filePaths
```
Path[] filePaths
```
      The list of paths to files and directories that contain the input.
    - minSplitSize
```
long minSplitSize
```
      The minimal split size, set by the configure() method.
    - numSplits
```
int numSplits
```
      The desired number of splits, as set by the configure() method.
    - openTimeout
```
long openTimeout
```
      Stream opening timeout.
    - unsplittable
```
boolean unsplittable
```
      Some file input formats are not splittable on a block level (deflate) Therefore, the FileInputFormat can only read whole files.
    - enumerateNestedFiles
```
boolean enumerateNestedFiles
```
      The flag to specify whether recursive traversal of the input directory structure is enabled.
    - filesFilter
```
FilePathFilter filesFilter
```
      Files filter for determining what files/directories should be included.
- Class org.apache.flink.api.common.io.FileOutputFormat extends RichOutputFormat<IT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - outputFilePath
```
Path outputFilePath
```
      The path of the file to be written.
    - writeMode
```
FileSystem.WriteMode writeMode
```
      The write mode of the output.
    - outputDirectoryMode
```
FileOutputFormat.OutputDirectoryMode outputDirectoryMode
```
      The output directory mode
- Class org.apache.flink.api.common.io.FileOutputFormatTest.DummyFileOutputFormat extends FileOutputFormat<IntValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - testFileName
```
boolean testFileName
```
- Class org.apache.flink.api.common.io.FilePathFilter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.io.FilePathFilter.DefaultFilter extends FilePathFilter implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.io.GenericCsvInputFormat extends DelimitedInputFormat<OT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - lineDelimiterIsLinebreak
```
boolean lineDelimiterIsLinebreak
```
    - fieldTypes
```
Class<T>[] fieldTypes
```
    - fieldIncluded
```
boolean[] fieldIncluded
```
    - fieldDelim
```
byte[] fieldDelim
```
    - fieldDelimString
```
String fieldDelimString
```
    - lenient
```
boolean lenient
```
    - skipFirstLineAsHeader
```
boolean skipFirstLineAsHeader
```
    - quotedStringParsing
```
boolean quotedStringParsing
```
    - quoteCharacter
```
byte quoteCharacter
```
    - commentPrefix
```
byte[] commentPrefix
```
    - commentPrefixString
```
String commentPrefixString
```
- Class org.apache.flink.api.common.io.GenericInputFormat extends RichInputFormat<OT,GenericInputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partitionNumber
```
int partitionNumber
```
      The partition of this split.
- Class org.apache.flink.api.common.io.GlobFilePathFilter extends FilePathFilter implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - includePatterns
```
List<E> includePatterns
```
    - excludePatterns
```
List<E> excludePatterns
```
- Class org.apache.flink.api.common.io.OutputFormatBase extends RichOutputFormat<OUT> implements Serializable
  - Serialized Fields
    - semaphore
```
Semaphore semaphore
```
    - maxConcurrentRequestsTimeout
```
java.time.Duration maxConcurrentRequestsTimeout
```
    - maxConcurrentRequests
```
int maxConcurrentRequests
```
    - throwable
```
AtomicReference<V> throwable
```
- 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
- Class org.apache.flink.api.common.io.SinkUtils extends Object implements Serializable
Package org.apache.flink.api.common.io.ratelimiting
- Class org.apache.flink.api.common.io.ratelimiting.GuavaFlinkConnectorRateLimiter extends Object implements Serializable
  
  serialVersionUID:
  
  -3680641524643737192L
  - Serialized Fields
    - globalRateBytesPerSecond
```
long globalRateBytesPerSecond
```
      Rate in bytes per second for the consumer on a whole.
    - localRateBytesPerSecond
```
long localRateBytesPerSecond
```
      Rate in bytes per second per subtask of the consumer.
    - runtimeContext
```
RuntimeContext runtimeContext
```
      Runtime context. *
    - rateLimiter
```
org.apache.flink.shaded.guava30.com.google.common.util.concurrent.RateLimiter rateLimiter
```
      RateLimiter. *
Package org.apache.flink.api.common.operators
- Class org.apache.flink.api.common.operators.DualInputSemanticProperties extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldMapping1
```
Map<K,V> fieldMapping1
```
      Mapping from fields in the source record(s) in the first input to fields in the destination record(s).
    - fieldMapping2
```
Map<K,V> fieldMapping2
```
      Mapping from fields in the source record(s) in the second input to fields in the destination record(s).
    - readFields1
```
FieldSet readFields1
```
      Set of fields that are read in the source record(s) from the first input.
    - readFields2
```
FieldSet readFields2
```
      Set of fields that are read in the source record(s) from the second input.
- Class org.apache.flink.api.common.operators.GenericDataSinkBaseTest extends Object implements Serializable
  - Serialized Fields
    - source
```
GenericDataSourceBase<OUT,T extends InputFormat<OUT,?>> source
```
- Class org.apache.flink.api.common.operators.GenericDataSourceBaseTest extends Object implements Serializable
- Class org.apache.flink.api.common.operators.Keys.IncompatibleKeysException extends Exception implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.operators.ResourceSpec extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
  - Serialized Fields
    - cpuCores
```
CPUResource cpuCores
```
      How many cpu cores are needed. Can be null only if it is unknown.
    - taskHeapMemory
```
MemorySize taskHeapMemory
```
      How much task heap memory is needed.
    - taskOffHeapMemory
```
MemorySize taskOffHeapMemory
```
      How much task off-heap memory is needed.
    - managedMemory
```
MemorySize managedMemory
```
      How much managed memory is needed.
    - extendedResources
```
Map<K,V> extendedResources
```
- Class org.apache.flink.api.common.operators.SelectorFunctionKeysTest.KeySelector1 extends Object implements Serializable
- Class org.apache.flink.api.common.operators.SelectorFunctionKeysTest.KeySelector2 extends Object implements Serializable
- Class org.apache.flink.api.common.operators.SelectorFunctionKeysTest.KeySelector3 extends Object implements Serializable
- Class org.apache.flink.api.common.operators.SelectorFunctionKeysTest.KeySelector4 extends Object implements Serializable
- Class org.apache.flink.api.common.operators.SemanticProperties.EmptySemanticProperties extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.operators.SemanticProperties.InvalidSemanticAnnotationException extends InvalidProgramException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.operators.SingleInputSemanticProperties extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldMapping
```
Map<K,V> fieldMapping
```
      Mapping from fields in the source record(s) to fields in the destination record(s).
    - readFields
```
FieldSet readFields
```
      Set of fields that are read in the source record(s).
- Class org.apache.flink.api.common.operators.SingleInputSemanticProperties.AllFieldsForwardedProperties extends SingleInputSemanticProperties implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.operators.SlotSharingGroup extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - name
```
String name
```
    - cpuCores
```
CPUResource cpuCores
```
      How many cpu cores are needed. Can be null only if it is unknown.
    - taskHeapMemory
```
MemorySize taskHeapMemory
```
      How much task heap memory is needed.
    - taskOffHeapMemory
```
MemorySize taskOffHeapMemory
```
      How much task off-heap memory is needed.
    - managedMemory
```
MemorySize managedMemory
```
      How much managed memory is needed.
    - externalResources
```
Map<K,V> externalResources
```
      A extensible field for user specified resources from SlotSharingGroup.
Package org.apache.flink.api.common.operators.base
- Class org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionAggregationConvergence extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionAggregator extends Object implements Serializable
  - Serialized Fields
    - count
```
long count
```
- Class org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionMapper extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - aggregator
```
BulkIterationBase.TerminationCriterionAggregator aggregator
```
- Class org.apache.flink.api.common.operators.base.FlatMapOperatorCollectionTest extends Object implements Serializable
- Class org.apache.flink.api.common.operators.base.FlatMapOperatorCollectionTest.IdRichFlatMap extends RichFlatMapFunction<IN,IN> implements Serializable
  - Serialized Fields
    - isOpened
```
boolean isOpened
```
    - isClosed
```
boolean isClosed
```
- Class org.apache.flink.api.common.operators.base.InnerJoinOperatorBaseTest extends Object implements Serializable
- Class org.apache.flink.api.common.operators.base.MapOperatorTest extends Object implements Serializable
- Class org.apache.flink.api.common.operators.base.OuterJoinOperatorBaseTest extends Object implements Serializable
  - Serialized Fields
    - joiner
```
org.apache.flink.api.common.operators.base.OuterJoinOperatorBaseTest.MockRichFlatJoinFunction joiner
```
    - baseOperator
```
OuterJoinOperatorBase<IN1,IN2,OUT,FT extends FlatJoinFunction<IN1,IN2,OUT>> baseOperator
```
    - executionConfig
```
ExecutionConfig executionConfig
```
    - runtimeContext
```
RuntimeContext runtimeContext
```
- Class org.apache.flink.api.common.operators.base.PartitionMapOperatorTest extends Object implements Serializable
Package org.apache.flink.api.common.operators.util
- Class org.apache.flink.api.common.operators.util.NonRichGenericInputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partitionNumber
```
int partitionNumber
```
- Class org.apache.flink.api.common.operators.util.TestNonRichInputFormat extends org.apache.flink.api.common.operators.util.NonRichGenericInputFormat<String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - count
```
int count
```
- Class org.apache.flink.api.common.operators.util.TestNonRichOutputFormat extends Object implements Serializable
  - Serialized Fields
    - output
```
List<E> output
```
- Class org.apache.flink.api.common.operators.util.TestRichInputFormat extends GenericInputFormat<String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - count
```
int count
```
    - openCalled
```
boolean openCalled
```
    - closeCalled
```
boolean closeCalled
```
- Class org.apache.flink.api.common.operators.util.TestRichOutputFormat extends RichOutputFormat<String> implements Serializable
  - Serialized Fields
    - output
```
List<E> output
```
- Class org.apache.flink.api.common.operators.util.UserCodeClassWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - userCodeClass
```
Class<T> userCodeClass
```
- Class org.apache.flink.api.common.operators.util.UserCodeObjectWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - userCodeObject
```
Object userCodeObject
```
Package org.apache.flink.api.common.resources
- Class org.apache.flink.api.common.resources.CPUResource extends Resource<CPUResource> implements Serializable
  
  serialVersionUID:
  
  7228645888210984393L
- Class org.apache.flink.api.common.resources.ExternalResource extends Resource<ExternalResource> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.resources.Resource extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - name
```
String name
```
    - value
```
BigDecimal value
```
- Class org.apache.flink.api.common.resources.TestResource extends Resource<org.apache.flink.api.common.resources.TestResource> implements Serializable
Package org.apache.flink.api.common.restartstrategy
- Class org.apache.flink.api.common.restartstrategy.RestartStrategies.ExponentialDelayRestartStrategyConfiguration extends RestartStrategies.RestartStrategyConfiguration implements Serializable
  
  serialVersionUID:
  
  1467941615941965194L
  - Serialized Fields
    - initialBackoff
```
Time initialBackoff
```
    - maxBackoff
```
Time maxBackoff
```
    - backoffMultiplier
```
double backoffMultiplier
```
    - resetBackoffThreshold
```
Time resetBackoffThreshold
```
    - jitterFactor
```
double jitterFactor
```
- Class org.apache.flink.api.common.restartstrategy.RestartStrategies.FailureRateRestartStrategyConfiguration extends RestartStrategies.RestartStrategyConfiguration implements Serializable
  
  serialVersionUID:
  
  1195028697539661739L
  - Serialized Fields
    - maxFailureRate
```
int maxFailureRate
```
    - failureInterval
```
Time failureInterval
```
    - delayBetweenAttemptsInterval
```
Time delayBetweenAttemptsInterval
```
- Class org.apache.flink.api.common.restartstrategy.RestartStrategies.FallbackRestartStrategyConfiguration extends RestartStrategies.RestartStrategyConfiguration implements Serializable
  
  serialVersionUID:
  
  -4441787204284085544L
- Class org.apache.flink.api.common.restartstrategy.RestartStrategies.FixedDelayRestartStrategyConfiguration extends RestartStrategies.RestartStrategyConfiguration implements Serializable
  
  serialVersionUID:
  
  4149870149673363190L
  - Serialized Fields
    - restartAttempts
```
int restartAttempts
```
    - delayBetweenAttemptsInterval
```
Time delayBetweenAttemptsInterval
```
- Class org.apache.flink.api.common.restartstrategy.RestartStrategies.NoRestartStrategyConfiguration extends RestartStrategies.RestartStrategyConfiguration implements Serializable
  
  serialVersionUID:
  
  -5894362702943349962L
- Class org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration extends Object implements Serializable
  
  serialVersionUID:
  
  6285853591578313960L
Package org.apache.flink.api.common.serialization
- Class org.apache.flink.api.common.serialization.AbstractDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - type
```
TypeInformation<T> type
```
      The type produced by this DeserializationSchema.
- Class org.apache.flink.api.common.serialization.SimpleStringEncoder extends Object implements Serializable
  
  serialVersionUID:
  
  -6865107843734614452L
  - Serialized Fields
    - charsetName
```
String charsetName
```
- Class org.apache.flink.api.common.serialization.SimpleStringSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
- Class org.apache.flink.api.common.serialization.TypeInformationSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  -5359448468131559102L
  - Serialized Fields
    - typeInfo
```
TypeInformation<T> typeInfo
```
      The type information, to be returned by TypeInformationSerializationSchema.getProducedType().
    - serializer
```
TypeSerializer<T> serializer
```
      The serializer for the actual de-/serialization.
Package org.apache.flink.api.common.state
- Class org.apache.flink.api.common.state.AggregatingStateDescriptor extends StateDescriptor<AggregatingState<IN,OUT>,ACC> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - aggFunction
```
AggregateFunction<IN,ACC,OUT> aggFunction
```
      The aggregation function for the state.
- Class org.apache.flink.api.common.state.ListStateDescriptor extends StateDescriptor<ListState<T>,List<T>> implements Serializable
  
  serialVersionUID:
  
  2L
- Class org.apache.flink.api.common.state.MapStateDescriptor extends StateDescriptor<MapState<UK,UV>,Map<UK,UV>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.state.ReducingStateDescriptor extends StateDescriptor<ReducingState<T>,T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - reduceFunction
```
ReduceFunction<T> reduceFunction
```
- Class org.apache.flink.api.common.state.StateDescriptor extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - name
```
String name
```
      Name that uniquely identifies state created from this StateDescriptor.
    - serializerAtomicReference
```
AtomicReference<V> serializerAtomicReference
```
      The serializer for the type. May be eagerly initialized in the constructor, or lazily once the StateDescriptor.initializeSerializerUnlessSet(ExecutionConfig) method is called.
    - typeInfo
```
TypeInformation<T> typeInfo
```
      The type information describing the value type. Only used to if the serializer is created lazily.
    - queryableStateName
```
String queryableStateName
```
      Name for queries against state created from this StateDescriptor.
    - ttlConfig
```
StateTtlConfig ttlConfig
```
      The configuration of state time-to-live(TTL), it is disabled by default.
- Class org.apache.flink.api.common.state.StateTtlConfig extends Object implements Serializable
  
  serialVersionUID:
  
  -7592693245044289793L
  - Serialized Fields
    - updateType
```
StateTtlConfig.UpdateType updateType
```
    - stateVisibility
```
StateTtlConfig.StateVisibility stateVisibility
```
    - ttlTimeCharacteristic
```
StateTtlConfig.TtlTimeCharacteristic ttlTimeCharacteristic
```
    - ttl
```
Time ttl
```
    - cleanupStrategies
```
StateTtlConfig.CleanupStrategies cleanupStrategies
```
- Class org.apache.flink.api.common.state.StateTtlConfig.CleanupStrategies extends Object implements Serializable
  
  serialVersionUID:
  
  -1617740467277313524L
  - Serialized Fields
    - isCleanupInBackground
```
boolean isCleanupInBackground
```
    - strategies
```
EnumMap<K extends Enum<K>,V> strategies
```
- Class org.apache.flink.api.common.state.StateTtlConfig.IncrementalCleanupStrategy extends Object implements Serializable
  
  serialVersionUID:
  
  3109278696501988780L
  - Serialized Fields
    - cleanupSize
```
int cleanupSize
```
      Max number of keys pulled from queue for clean up upon state touch for any key.
    - runCleanupForEveryRecord
```
boolean runCleanupForEveryRecord
```
      Whether to run incremental cleanup per each processed record.
- Class org.apache.flink.api.common.state.StateTtlConfig.RocksdbCompactFilterCleanupStrategy extends Object implements Serializable
  
  serialVersionUID:
  
  3109278796506988980L
  - Serialized Fields
    - queryTimeAfterNumEntries
```
long queryTimeAfterNumEntries
```
      Number of state entries to process by compaction filter before updating current timestamp.
- Class org.apache.flink.api.common.state.ValueStateDescriptor extends StateDescriptor<ValueState<T>,T> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.common.time
- Class org.apache.flink.api.common.time.Time extends Object implements Serializable
  
  serialVersionUID:
  
  -350254188460915999L
  - Serialized Fields
    - unit
```
TimeUnit unit
```
      The time unit for this policy's time interval.
    - size
```
long size
```
      The size of the windows generated by this policy.
Package org.apache.flink.api.common.typeinfo
- Class org.apache.flink.api.common.typeinfo.BasicArrayTypeInfo extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - arrayClass
```
Class<T> arrayClass
```
    - componentInfo
```
TypeInformation<T> componentInfo
```
- Class org.apache.flink.api.common.typeinfo.BasicTypeInfo extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  -430955220409131770L
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
    - serializer
```
TypeSerializer<T> serializer
```
    - possibleCastTargetTypes
```
Class<T>[] possibleCastTargetTypes
```
    - comparatorClass
```
Class<T> comparatorClass
```
- Class org.apache.flink.api.common.typeinfo.FractionalTypeInfo extends NumericTypeInfo<T> implements Serializable
  
  serialVersionUID:
  
  554334260950199994L
- Class org.apache.flink.api.common.typeinfo.IntegerTypeInfo extends NumericTypeInfo<T> implements Serializable
  
  serialVersionUID:
  
  -8068827354966766955L
- Class org.apache.flink.api.common.typeinfo.LocalTimeTypeInfo extends TypeInformation<T extends java.time.temporal.Temporal> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
    - serializer
```
TypeSerializer<T> serializer
```
    - comparatorClass
```
Class<T> comparatorClass
```
- Class org.apache.flink.api.common.typeinfo.NothingTypeInfo extends TypeInformation<Nothing> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeinfo.NumericTypeInfo extends BasicTypeInfo<T> implements Serializable
  
  serialVersionUID:
  
  -5937777910658986986L
- Class org.apache.flink.api.common.typeinfo.PrimitiveArrayTypeInfo extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - arrayClass
```
Class<T> arrayClass
```
      The class of the array (such as int[].class).
    - serializer
```
TypeSerializer<T> serializer
```
      The serializer for the array.
    - comparatorClass
```
Class<T> comparatorClass
```
      The class of the comparator for the array.
- Class org.apache.flink.api.common.typeinfo.SqlTimeTypeInfo extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  -132955295409131880L
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
    - serializer
```
TypeSerializer<T> serializer
```
    - comparatorClass
```
Class<T> comparatorClass
```
- Class org.apache.flink.api.common.typeinfo.TypeInformation extends Object implements Serializable
  
  serialVersionUID:
  
  -7742311969684489493L
Package org.apache.flink.api.common.typeutils
- Class org.apache.flink.api.common.typeutils.CompositeSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldSerializers
```
TypeSerializer<T>[] fieldSerializers
```
      Serializers for fields which constitute T.
    - precomputed
```
CompositeSerializer.PrecomputedParameters precomputed
```
- Class org.apache.flink.api.common.typeutils.CompositeSerializer.PrecomputedParameters extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - immutableTargetType
```
boolean immutableTargetType
```
      Whether target type is immutable.
    - immutable
```
boolean immutable
```
      Whether target type and its fields are immutable.
    - length
```
int length
```
      Byte length of target object in serialized form.
    - stateful
```
boolean stateful
```
      Whether any field serializer is stateful.
- Class org.apache.flink.api.common.typeutils.CompositeType extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
- Class org.apache.flink.api.common.typeutils.CompositeType.InvalidFieldReferenceException extends IllegalArgumentException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.CompositeTypeComparator extends TypeComparator<T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshotTest.NestedSerializer extends TypeSerializer<String> implements Serializable
  
  serialVersionUID:
  
  -6175000932620623446L
  - Serialized Fields
    - targetCompatibility
```
org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshotTest.TargetCompatibility targetCompatibility
```
- Class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshotTest.TestCompositeTypeSerializer extends TypeSerializer<String> implements Serializable
  
  serialVersionUID:
  
  -545688468997398105L
  - Serialized Fields
    - mockOuterSchemaCompatibility
```
CompositeTypeSerializerSnapshot.OuterSchemaCompatibility mockOuterSchemaCompatibility
```
    - nestedSerializers
```
TypeSerializer<T>[] nestedSerializers
```
- Class org.apache.flink.api.common.typeutils.GenericPairComparator extends TypePairComparator<T1,T2> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - comparator1
```
TypeComparator<T> comparator1
```
    - comparator2
```
TypeComparator<T> comparator2
```
    - comparators1
```
TypeComparator<T>[] comparators1
```
    - comparators2
```
TypeComparator<T>[] comparators2
```
    - referenceKeyFields
```
Object[] referenceKeyFields
```
    - candidateKeyFields
```
Object[] candidateKeyFields
```
- Class org.apache.flink.api.common.typeutils.SingleThreadAccessCheckingTypeSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  131020282727167064L
  - Serialization Methods
    - writeObject
```
private void writeObject(ObjectOutputStream outputStream)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - singleThreadAccessChecker
```
org.apache.flink.api.common.typeutils.SingleThreadAccessCheckingTypeSerializer.SingleThreadAccessChecker singleThreadAccessChecker
```
    - originalSerializer
```
TypeSerializer<T> originalSerializer
```
- Class org.apache.flink.api.common.typeutils.TypeComparator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.TypeSerializer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtilTest extends Object implements Serializable
- Class org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtilTest.AbstractIntSerializer extends TypeSerializer<Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtilTest.TestIntSerializer extends org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtilTest.AbstractIntSerializer implements Serializable
  
  serialVersionUID:
  
  -3684467698271707216L
- Class org.apache.flink.api.common.typeutils.UnloadableDummyTypeSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  2526330533671642711L
  - Serialized Fields
    - actualBytes
```
byte[] actualBytes
```
    - originalError
```
Throwable originalError
```
Package org.apache.flink.api.common.typeutils.base
- Class org.apache.flink.api.common.typeutils.base.BasicTypeComparator extends TypeComparator<T extends Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.BigDecComparator extends BasicTypeComparator<BigDecimal> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BigDecSerializer extends TypeSerializerSingleton<BigDecimal> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BigIntComparator extends BasicTypeComparator<BigInteger> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BigIntSerializer extends TypeSerializerSingleton<BigInteger> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BooleanComparator extends BasicTypeComparator<Boolean> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BooleanSerializer extends TypeSerializerSingleton<Boolean> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.BooleanValueComparator extends TypeComparator<BooleanValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
BooleanValue reference
```
    - tempReference
```
BooleanValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.BooleanValueSerializer extends TypeSerializerSingleton<BooleanValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ByteComparator extends BasicTypeComparator<Byte> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ByteSerializer extends TypeSerializerSingleton<Byte> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ByteValueComparator extends TypeComparator<ByteValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
ByteValue reference
```
    - tempReference
```
ByteValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.ByteValueSerializer extends TypeSerializerSingleton<ByteValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.CharComparator extends BasicTypeComparator<Character> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.CharSerializer extends TypeSerializerSingleton<Character> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.CharValueComparator extends TypeComparator<CharValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
CharValue reference
```
    - tempReference
```
CharValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.CharValueSerializer extends TypeSerializerSingleton<CharValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.DateComparator extends BasicTypeComparator<Date> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.DateSerializer extends TypeSerializerSingleton<Date> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.DoubleComparator extends BasicTypeComparator<Double> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.DoubleSerializer extends TypeSerializerSingleton<Double> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.DoubleValueComparator extends TypeComparator<DoubleValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
DoubleValue reference
```
    - tempReference
```
DoubleValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.DoubleValueSerializer extends TypeSerializerSingleton<DoubleValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.EnumComparator extends BasicTypeComparator<T extends Enum<T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.EnumSerializer extends TypeSerializer<T extends Enum<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - enumClass
```
Class<T> enumClass
```
    - valueToOrdinal
```
Map<K,V> valueToOrdinal
```
      Maintain our own map of enum value to their ordinal, instead of directly using Enum.ordinal(). This allows us to maintain backwards compatibility for previous serialized data in the case that the order of enum constants was changed or new constants were added.
      On a fresh start with no reconfiguration, the ordinals would simply be identical to the enum constants actual ordinals. Ordinals may change after reconfiguration.
    - values
```
Enum<E extends Enum<E>>[] values
```
      Array of enum constants with their indexes identical to their ordinals in the EnumSerializer.valueToOrdinal map. Serves as a bidirectional map to have fast access from ordinal to value. May be reordered after reconfiguration.
- Class org.apache.flink.api.common.typeutils.base.FloatComparator extends BasicTypeComparator<Float> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.FloatSerializer extends TypeSerializerSingleton<Float> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.FloatValueComparator extends TypeComparator<FloatValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
FloatValue reference
```
    - tempReference
```
FloatValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.FloatValueSerializer extends TypeSerializerSingleton<FloatValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.GenericArraySerializer extends TypeSerializer<C[]> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - componentClass
```
Class<T> componentClass
```
    - componentSerializer
```
TypeSerializer<T> componentSerializer
```
- Class org.apache.flink.api.common.typeutils.base.InstantComparator extends BasicTypeComparator<java.time.Instant> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.InstantSerializer extends TypeSerializerSingleton<java.time.Instant> implements Serializable
  
  serialVersionUID:
  
  -4131715684999061277L
- Class org.apache.flink.api.common.typeutils.base.IntComparator extends BasicTypeComparator<Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.IntSerializer extends TypeSerializerSingleton<Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.IntValueComparator extends TypeComparator<IntValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
IntValue reference
```
    - tempReference
```
IntValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.IntValueSerializer extends TypeSerializerSingleton<IntValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ListSerializer extends TypeSerializer<List<T>> implements Serializable
  
  serialVersionUID:
  
  1119562170939152304L
  - Serialized Fields
    - elementSerializer
```
TypeSerializer<T> elementSerializer
```
      The serializer for the elements of the list.
- Class org.apache.flink.api.common.typeutils.base.LocalDateComparator extends TypeComparator<java.time.LocalDate> implements Serializable
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
LocalDateComparator[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.LocalDateSerializer extends TypeSerializerSingleton<java.time.LocalDate> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.LocalDateTimeComparator extends TypeComparator<java.time.LocalDateTime> implements Serializable
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - dateComparator
```
LocalDateComparator dateComparator
```
    - timeComparator
```
LocalTimeComparator timeComparator
```
    - comparators
```
LocalDateTimeComparator[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.LocalDateTimeSerializer extends TypeSerializerSingleton<java.time.LocalDateTime> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.LocalTimeComparator extends BasicTypeComparator<java.time.LocalTime> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.LocalTimeSerializer extends TypeSerializerSingleton<java.time.LocalTime> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.LongComparator extends BasicTypeComparator<Long> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.LongSerializer extends TypeSerializerSingleton<Long> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.LongValueComparator extends TypeComparator<LongValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
LongValue reference
```
    - tempReference
```
LongValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.LongValueSerializer extends TypeSerializerSingleton<LongValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.MapSerializer extends TypeSerializer<Map<K,V>> implements Serializable
  
  serialVersionUID:
  
  -6885593032367050078L
  - Serialized Fields
    - keySerializer
```
TypeSerializer<T> keySerializer
```
      The serializer for the keys in the map
    - valueSerializer
```
TypeSerializer<T> valueSerializer
```
      The serializer for the values in the map
- Class org.apache.flink.api.common.typeutils.base.NullValueComparator extends TypeComparator<NullValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.NullValueSerializer extends TypeSerializerSingleton<NullValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ShortComparator extends BasicTypeComparator<Short> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ShortSerializer extends TypeSerializerSingleton<Short> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.ShortValueComparator extends TypeComparator<ShortValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
ShortValue reference
```
    - tempReference
```
ShortValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.ShortValueSerializer extends TypeSerializerSingleton<ShortValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.SqlDateSerializer extends TypeSerializerSingleton<Date> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.SqlTimeSerializer extends TypeSerializerSingleton<Time> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.SqlTimestampComparator extends BasicTypeComparator<Date> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.SqlTimestampSerializer extends TypeSerializerSingleton<Timestamp> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.StringComparator extends BasicTypeComparator<String> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.StringSerializer extends TypeSerializerSingleton<String> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.StringValueComparator extends TypeComparator<StringValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascendingComparison
```
boolean ascendingComparison
```
    - reference
```
StringValue reference
```
    - tempReference
```
StringValue tempReference
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.common.typeutils.base.StringValueSerializer extends TypeSerializerSingleton<StringValue> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  8766687317209282373L
- Class org.apache.flink.api.common.typeutils.base.VoidSerializer extends TypeSerializerSingleton<Void> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.common.typeutils.base.array
- Class org.apache.flink.api.common.typeutils.base.array.BooleanPrimitiveArrayComparator extends PrimitiveArrayComparator<boolean[],BooleanComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.BooleanPrimitiveArraySerializer extends TypeSerializerSingleton<boolean[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.BytePrimitiveArrayComparator extends PrimitiveArrayComparator<byte[],ByteComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.BytePrimitiveArraySerializer extends TypeSerializerSingleton<byte[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.CharPrimitiveArrayComparator extends PrimitiveArrayComparator<char[],CharComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.CharPrimitiveArraySerializer extends TypeSerializerSingleton<char[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.DoublePrimitiveArrayComparator extends PrimitiveArrayComparator<double[],DoubleComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.DoublePrimitiveArraySerializer extends TypeSerializerSingleton<double[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.FloatPrimitiveArrayComparator extends PrimitiveArrayComparator<float[],FloatComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.FloatPrimitiveArraySerializer extends TypeSerializerSingleton<float[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.IntPrimitiveArrayComparator extends PrimitiveArrayComparator<int[],IntComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.IntPrimitiveArraySerializer extends TypeSerializerSingleton<int[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.LongPrimitiveArrayComparator extends PrimitiveArrayComparator<long[],LongComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.LongPrimitiveArraySerializer extends TypeSerializerSingleton<long[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.PrimitiveArrayComparator extends TypeComparator<T> implements Serializable
  - Serialized Fields
    - comparators
```
TypeComparator<T>[] comparators
```
    - ascending
```
boolean ascending
```
    - comparator
```
BasicTypeComparator<T extends Comparable<T>> comparator
```
- Class org.apache.flink.api.common.typeutils.base.array.ShortPrimitiveArrayComparator extends PrimitiveArrayComparator<short[],ShortComparator> implements Serializable
- Class org.apache.flink.api.common.typeutils.base.array.ShortPrimitiveArraySerializer extends TypeSerializerSingleton<short[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.common.typeutils.base.array.StringArraySerializer extends TypeSerializerSingleton<String[]> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.connector.sink
Package org.apache.flink.api.connector.sink2
Package org.apache.flink.api.connector.source
- Class org.apache.flink.api.connector.source.ReaderInfo extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - subtaskId
```
int subtaskId
```
    - location
```
String location
```
Package org.apache.flink.api.connector.source.lib
- Class org.apache.flink.api.connector.source.lib.NumberSequenceSource extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - from
```
long from
```
      The starting number in the sequence, inclusive.
    - to
```
long to
```
      The end number in the sequence, inclusive.
Package org.apache.flink.api.java
- Class org.apache.flink.api.java.Utils.ChecksumHashCode extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - count
```
long count
```
    - checksum
```
long checksum
```
- Class org.apache.flink.api.java.Utils.ChecksumHashCodeHelper extends RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - id
```
String id
```
    - counter
```
long counter
```
    - checksum
```
long checksum
```
- Class org.apache.flink.api.java.Utils.CollectHelper extends RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - id
```
String id
```
    - serializer
```
TypeSerializer<T> serializer
```
    - accumulator
```
SerializedListAccumulator<T> accumulator
```
- Class org.apache.flink.api.java.Utils.CountHelper extends RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - id
```
String id
```
    - counter
```
long counter
```
Package org.apache.flink.api.java.aggregation
- Class org.apache.flink.api.java.aggregation.AggregationFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.aggregation.MaxAggregationFunction extends AggregationFunction<T extends Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.aggregation.MaxAggregationFunction.MaxAggregationFunctionFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.aggregation.MinAggregationFunction extends AggregationFunction<T extends Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.aggregation.MinAggregationFunction.MinAggregationFunctionFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.aggregation.SumAggregationFunction extends AggregationFunction<T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.aggregation.SumAggregationFunction.SumAggregationFunctionFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.aggregation.UnsupportedAggregationTypeException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  -1721898801986321005L
Package org.apache.flink.api.java.functions
- Class org.apache.flink.api.java.functions.FirstReducer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - count
```
int count
```
- Class org.apache.flink.api.java.functions.FlatMapIterator extends RichFlatMapFunction<IN,OUT> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.functions.FormattingMapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - formatter
```
TextOutputFormat.TextFormatter<IN> formatter
```
- Class org.apache.flink.api.java.functions.GroupReduceIterator extends RichGroupReduceFunction<IN,OUT> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.functions.IdPartitioner extends Object implements Serializable
  
  serialVersionUID:
  
  -1206233785103357568L
- Class org.apache.flink.api.java.functions.NullByteKeySelector extends Object implements Serializable
  
  serialVersionUID:
  
  614256539098549020L
- Class org.apache.flink.api.java.functions.SampleInCoordinator extends Object implements Serializable
  - Serialized Fields
    - withReplacement
```
boolean withReplacement
```
    - numSample
```
int numSample
```
    - seed
```
long seed
```
- Class org.apache.flink.api.java.functions.SampleInPartition extends RichMapPartitionFunction<T,IntermediateSampleData<T>> implements Serializable
  - Serialized Fields
    - withReplacement
```
boolean withReplacement
```
    - numSample
```
int numSample
```
    - seed
```
long seed
```
- Class org.apache.flink.api.java.functions.SampleWithFraction extends RichMapPartitionFunction<T,T> implements Serializable
  - Serialized Fields
    - withReplacement
```
boolean withReplacement
```
    - fraction
```
double fraction
```
    - seed
```
long seed
```
- Class org.apache.flink.api.java.functions.SelectByMaxFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fields
```
int[] fields
```
- Class org.apache.flink.api.java.functions.SelectByMinFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fields
```
int[] fields
```
Package org.apache.flink.api.java.hadoop.common
- Class org.apache.flink.api.java.hadoop.common.HadoopInputFormatCommonBase extends RichInputFormat<T,SPITTYPE extends InputSplit> implements Serializable
- Class org.apache.flink.api.java.hadoop.common.HadoopOutputFormatCommonBase extends RichOutputFormat<T> implements Serializable
Package org.apache.flink.api.java.hadoop.mapred
- Class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormat extends HadoopInputFormatBase<K,V,Tuple2<K,V>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase extends HadoopInputFormatCommonBase<T,HadoopInputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - mapredInputFormat
```
org.apache.hadoop.mapred.InputFormat<K,V> mapredInputFormat
```
    - keyClass
```
Class<T> keyClass
```
    - valueClass
```
Class<T> valueClass
```
    - jobConf
```
org.apache.hadoop.mapred.JobConf jobConf
```
- Class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormat extends HadoopOutputFormatBase<K,V,Tuple2<K,V>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase extends HadoopOutputFormatCommonBase<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - jobConf
```
org.apache.hadoop.mapred.JobConf jobConf
```
    - mapredOutputFormat
```
org.apache.hadoop.mapred.OutputFormat<K,V> mapredOutputFormat
```
Package org.apache.flink.api.java.hadoop.mapred.wrapper
- Class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit extends LocatableInputSplit implements Serializable
  
  serialVersionUID:
  
  -6990336376163226160L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - splitType
```
Class<T> splitType
```
Package org.apache.flink.api.java.hadoop.mapreduce
- Class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat extends HadoopInputFormatBase<K,V,Tuple2<K,V>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase extends HadoopInputFormatCommonBase<T,HadoopInputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - mapreduceInputFormat
```
org.apache.hadoop.mapreduce.InputFormat<K,V> mapreduceInputFormat
```
    - keyClass
```
Class<T> keyClass
```
    - valueClass
```
Class<T> valueClass
```
    - configuration
```
Configuration configuration
```
    - fetched
```
boolean fetched
```
    - hasNext
```
boolean hasNext
```
- Class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormat extends HadoopOutputFormatBase<K,V,Tuple2<K,V>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase extends HadoopOutputFormatCommonBase<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - configuration
```
Configuration configuration
```
    - mapreduceOutputFormat
```
org.apache.hadoop.mapreduce.OutputFormat<K,V> mapreduceOutputFormat
```
Package org.apache.flink.api.java.hadoop.mapreduce.wrapper
- Class org.apache.flink.api.java.hadoop.mapreduce.wrapper.HadoopInputSplit extends LocatableInputSplit implements Serializable
  
  serialVersionUID:
  
  6119153593707857235L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - splitType
```
Class<T> splitType
```
Package org.apache.flink.api.java.io
- Class org.apache.flink.api.java.io.BlockingShuffleOutputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - intermediateDataSetId
```
AbstractID intermediateDataSetId
```
- Class org.apache.flink.api.java.io.CollectionInputFormat extends GenericInputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - serializer
```
TypeSerializer<T> serializer
```
- Class org.apache.flink.api.java.io.CsvInputFormat extends GenericCsvInputFormat<OUT> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.io.CsvOutputFormat extends FileOutputFormat<T extends Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldDelimiter
```
String fieldDelimiter
```
    - recordDelimiter
```
String recordDelimiter
```
    - charsetName
```
String charsetName
```
    - allowNullValues
```
boolean allowNullValues
```
    - quoteStrings
```
boolean quoteStrings
```
- Class org.apache.flink.api.java.io.DiscardingOutputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.io.IteratorInputFormat extends GenericInputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - iterator
```
Iterator<E> iterator
```
- Class org.apache.flink.api.java.io.LocalCollectionOutputFormat extends RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - typeSerializer
```
TypeSerializer<T> typeSerializer
```
    - id
```
int id
```
- Class org.apache.flink.api.java.io.ParallelIteratorInputFormat extends GenericInputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - source
```
SplittableIterator<T> source
```
- Class org.apache.flink.api.java.io.PojoCsvInputFormat extends CsvInputFormat<OUT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - pojoTypeClass
```
Class<T> pojoTypeClass
```
    - pojoFieldNames
```
String[] pojoFieldNames
```
- Class org.apache.flink.api.java.io.PrimitiveInputFormat extends DelimitedInputFormat<OT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - primitiveClass
```
Class<T> primitiveClass
```
- Class org.apache.flink.api.java.io.PrintingOutputFormat extends RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - writer
```
PrintSinkOutputWriter<IN> writer
```
- Class org.apache.flink.api.java.io.RowCsvInputFormat extends CsvInputFormat<Row> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - arity
```
int arity
```
    - fieldTypeInfos
```
TypeInformation<T>[] fieldTypeInfos
```
    - fieldPosMap
```
int[] fieldPosMap
```
    - emptyColumnAsNull
```
boolean emptyColumnAsNull
```
- Class org.apache.flink.api.java.io.SplitDataProperties.SourcePartitionerMarker extends Object implements Serializable
  
  serialVersionUID:
  
  -8554223652384442571L
  - Serialized Fields
    - partitionMarker
```
String partitionMarker
```
- Class org.apache.flink.api.java.io.TextInputFormat extends DelimitedInputFormat<String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - charsetName
```
String charsetName
```
      The name of the charset to use for decoding.
- Class org.apache.flink.api.java.io.TextOutputFormat extends FileOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - charsetName
```
String charsetName
```
- Class org.apache.flink.api.java.io.TextValueInputFormat extends DelimitedInputFormat<StringValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - charsetName
```
String charsetName
```
    - skipInvalidLines
```
boolean skipInvalidLines
```
- Class org.apache.flink.api.java.io.TupleCsvInputFormat extends CsvInputFormat<OUT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tupleSerializer
```
TupleSerializerBase<T> tupleSerializer
```
- Class org.apache.flink.api.java.io.TypeSerializerInputFormat extends BinaryInputFormat<T> implements Serializable
  
  serialVersionUID:
  
  2123068581665107480L
  - Serialized Fields
    - serializer
```
TypeSerializer<T> serializer
```
- Class org.apache.flink.api.java.io.TypeSerializerOutputFormat extends BinaryOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  -6653022644629315158L
  - Serialized Fields
    - serializer
```
TypeSerializer<T> serializer
```
Package org.apache.flink.api.java.operators
- Class org.apache.flink.api.java.operators.CrossOperator.ProjectCrossFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fields
```
int[] fields
```
    - isFromFirst
```
boolean[] isFromFirst
```
    - outTuple
```
Tuple outTuple
```
- Class org.apache.flink.api.java.operators.JoinOperator.DefaultJoin.WrappingFlatJoinFunction extends WrappingFunction<JoinFunction<IN1,IN2,OUT>> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.java.operators.translation
- Class org.apache.flink.api.java.operators.translation.CombineToGroupCombineWrapper extends Object implements Serializable
  - Serialized Fields
    - wrappedFunction
```
CombineFunction<IN,OUT> wrappedFunction
```
- Class org.apache.flink.api.java.operators.translation.KeyExtractingMapper extends RichMapFunction<T,Tuple2<K,T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - keySelector
```
KeySelector<IN,KEY> keySelector
```
    - tuple
```
Tuple2<T0,T1> tuple
```
- Class org.apache.flink.api.java.operators.translation.KeyRemovingMapper extends RichMapFunction<Tuple2<K,T>,T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.operators.translation.PlanFilterOperator.FlatMapFilter extends WrappingFunction<FilterFunction<T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.operators.translation.RichCombineToGroupCombineWrapper extends RichGroupCombineFunction<IN,IN> implements Serializable
  - Serialized Fields
    - wrappedFunction
```
RichGroupReduceFunction<IN,OUT> wrappedFunction
```
- Class org.apache.flink.api.java.operators.translation.Tuple3UnwrappingIterator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - lastGroupKey
```
Object lastGroupKey
```
    - lastSortKey
```
Object lastSortKey
```
    - iterator
```
Iterator<E> iterator
```
    - iteratorAvailable
```
boolean iteratorAvailable
```
- Class org.apache.flink.api.java.operators.translation.Tuple3WrappingCollector extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tui
```
Tuple3UnwrappingIterator<T,K1,K2> tui
```
    - outTuple
```
Tuple3<T0,T1,T2> outTuple
```
    - wrappedCollector
```
Collector<T> wrappedCollector
```
- Class org.apache.flink.api.java.operators.translation.TupleLeftUnwrappingJoiner extends WrappingFunction<FlatJoinFunction<I1,I2,OUT>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.operators.translation.TupleRightUnwrappingJoiner extends WrappingFunction<FlatJoinFunction<I1,I2,OUT>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.operators.translation.TupleUnwrappingIterator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - lastKey
```
Object lastKey
```
    - iterator
```
Iterator<E> iterator
```
    - iteratorAvailable
```
boolean iteratorAvailable
```
- Class org.apache.flink.api.java.operators.translation.TupleUnwrappingJoiner extends WrappingFunction<FlatJoinFunction<I1,I2,OUT>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.operators.translation.TupleWrappingCollector extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tui
```
TupleUnwrappingIterator<T,K> tui
```
    - outTuple
```
Tuple2<T0,T1> outTuple
```
    - wrappedCollector
```
Collector<T> wrappedCollector
```
- Class org.apache.flink.api.java.operators.translation.TwoKeyExtractingMapper extends RichMapFunction<T,Tuple3<K1,K2,T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - keySelector1
```
KeySelector<IN,KEY> keySelector1
```
    - keySelector2
```
KeySelector<IN,KEY> keySelector2
```
    - tuple
```
Tuple3<T0,T1,T2> tuple
```
- Class org.apache.flink.api.java.operators.translation.WrappingFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - wrappedFunction
```
Function wrappedFunction
```
Package org.apache.flink.api.java.summarize
- Class org.apache.flink.api.java.summarize.NumericColumnSummary extends ColumnSummary implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nonMissingCount
```
long nonMissingCount
```
    - nullCount
```
long nullCount
```
    - nanCount
```
long nanCount
```
    - infinityCount
```
long infinityCount
```
    - min
```
Object min
```
    - max
```
Object max
```
    - sum
```
Object sum
```
    - mean
```
Double mean
```
    - variance
```
Double variance
```
    - standardDeviation
```
Double standardDeviation
```
Package org.apache.flink.api.java.summarize.aggregation
- Class org.apache.flink.api.java.summarize.aggregation.BooleanSummaryAggregator extends Object implements Serializable
  - Serialized Fields
    - trueCount
```
long trueCount
```
    - falseCount
```
long falseCount
```
    - nullCount
```
long nullCount
```
- Class org.apache.flink.api.java.summarize.aggregation.CompensatedSum extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - value
```
double value
```
    - delta
```
double delta
```
- Class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator extends NumericSummaryAggregator<Double> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator.MaxDoubleAggregator extends Object implements Serializable
  - Serialized Fields
    - max
```
double max
```
- Class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator.MinDoubleAggregator extends Object implements Serializable
  - Serialized Fields
    - min
```
double min
```
- Class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator.SumDoubleAggregator extends Object implements Serializable
  - Serialized Fields
    - sum
```
CompensatedSum sum
```
- Class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator extends NumericSummaryAggregator<Float> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator.MaxFloatAggregator extends Object implements Serializable
  - Serialized Fields
    - max
```
float max
```
- Class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator.MinFloatAggregator extends Object implements Serializable
  - Serialized Fields
    - min
```
float min
```
- Class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator.SumFloatAggregator extends Object implements Serializable
  - Serialized Fields
    - sum
```
CompensatedSum sum
```
- Class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator extends NumericSummaryAggregator<Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator.MaxIntegerAggregator extends Object implements Serializable
  - Serialized Fields
    - max
```
int max
```
- Class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator.MinIntegerAggregator extends Object implements Serializable
  - Serialized Fields
    - min
```
int min
```
- Class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator.SumIntegerAggregator extends Object implements Serializable
  - Serialized Fields
    - sum
```
int sum
```
- Class org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator extends NumericSummaryAggregator<Long> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator.MaxLongAggregator extends Object implements Serializable
  - Serialized Fields
    - max
```
long max
```
- Class org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator.MinLongAggregator extends Object implements Serializable
  - Serialized Fields
    - min
```
long min
```
- Class org.apache.flink.api.java.summarize.aggregation.NumericSummaryAggregator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nonMissingCount
```
long nonMissingCount
```
    - nullCount
```
long nullCount
```
    - nanCount
```
long nanCount
```
    - infinityCount
```
long infinityCount
```
    - min
```
Aggregator<T,R> min
```
    - max
```
Aggregator<T,R> max
```
    - sum
```
Aggregator<T,R> sum
```
    - mean
```
CompensatedSum mean
```
    - m2
```
CompensatedSum m2
```
      Sum of squares of differences from the current mean (used to calculate variance).
      The algorithm is described in: "Scalable and Numerically Stable Descriptive Statistics in SystemML", Tian et al, International Conference on Data Engineering 2012
- Class org.apache.flink.api.java.summarize.aggregation.ObjectSummaryAggregator extends Object implements Serializable
  - Serialized Fields
    - nonNullCount
```
long nonNullCount
```
    - nullCount
```
long nullCount
```
- Class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator extends NumericSummaryAggregator<Short> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator.MaxShortAggregator extends Object implements Serializable
  - Serialized Fields
    - max
```
short max
```
- Class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator.MinShortAggregator extends Object implements Serializable
  - Serialized Fields
    - min
```
short min
```
- Class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator.SumShortAggregator extends Object implements Serializable
  - Serialized Fields
    - sum
```
short sum
```
- Class org.apache.flink.api.java.summarize.aggregation.StringSummaryAggregator extends Object implements Serializable
  - Serialized Fields
    - nonNullCount
```
long nonNullCount
```
    - nullCount
```
long nullCount
```
    - emptyCount
```
long emptyCount
```
    - minStringLength
```
int minStringLength
```
    - maxStringLength
```
int maxStringLength
```
    - meanLength
```
CompensatedSum meanLength
```
- Class org.apache.flink.api.java.summarize.aggregation.TupleSummaryAggregator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - columnAggregators
```
Aggregator<T,R>[] columnAggregators
```
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator extends Object implements Serializable
  - Serialized Fields
    - aggregator
```
Aggregator<T,R> aggregator
```
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.BooleanValueSummaryAggregator extends ValueSummaryAggregator<BooleanValue,Boolean,BooleanColumnSummary,BooleanSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.DoubleValueSummaryAggregator extends ValueSummaryAggregator<DoubleValue,Double,NumericColumnSummary<Double>,DoubleSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.FloatValueSummaryAggregator extends ValueSummaryAggregator<FloatValue,Float,NumericColumnSummary<Float>,FloatSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.IntegerValueSummaryAggregator extends ValueSummaryAggregator<IntValue,Integer,NumericColumnSummary<Integer>,IntegerSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.LongValueSummaryAggregator extends ValueSummaryAggregator<LongValue,Long,NumericColumnSummary<Long>,LongSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.ShortValueSummaryAggregator extends ValueSummaryAggregator<ShortValue,Short,NumericColumnSummary<Short>,ShortSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.StringValueSummaryAggregator extends ValueSummaryAggregator<StringValue,String,StringColumnSummary,StringSummaryAggregator> implements Serializable
Package org.apache.flink.api.java.tuple
- Class org.apache.flink.api.java.tuple.Tuple extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.tuple.Tuple0 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readResolve
```
private Object readResolve()
                    throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
- Class org.apache.flink.api.java.tuple.Tuple1 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple10 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple11 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple12 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple13 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple14 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple15 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple16 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple17 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple18 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple19 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
    - f18
```
Object f18
```
      Field 18 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple2 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple20 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
    - f18
```
Object f18
```
      Field 18 of the tuple.
    - f19
```
Object f19
```
      Field 19 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple21 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
    - f18
```
Object f18
```
      Field 18 of the tuple.
    - f19
```
Object f19
```
      Field 19 of the tuple.
    - f20
```
Object f20
```
      Field 20 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple22 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
    - f18
```
Object f18
```
      Field 18 of the tuple.
    - f19
```
Object f19
```
      Field 19 of the tuple.
    - f20
```
Object f20
```
      Field 20 of the tuple.
    - f21
```
Object f21
```
      Field 21 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple23 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
    - f18
```
Object f18
```
      Field 18 of the tuple.
    - f19
```
Object f19
```
      Field 19 of the tuple.
    - f20
```
Object f20
```
      Field 20 of the tuple.
    - f21
```
Object f21
```
      Field 21 of the tuple.
    - f22
```
Object f22
```
      Field 22 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple24 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
    - f18
```
Object f18
```
      Field 18 of the tuple.
    - f19
```
Object f19
```
      Field 19 of the tuple.
    - f20
```
Object f20
```
      Field 20 of the tuple.
    - f21
```
Object f21
```
      Field 21 of the tuple.
    - f22
```
Object f22
```
      Field 22 of the tuple.
    - f23
```
Object f23
```
      Field 23 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple25 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
    - f9
```
Object f9
```
      Field 9 of the tuple.
    - f10
```
Object f10
```
      Field 10 of the tuple.
    - f11
```
Object f11
```
      Field 11 of the tuple.
    - f12
```
Object f12
```
      Field 12 of the tuple.
    - f13
```
Object f13
```
      Field 13 of the tuple.
    - f14
```
Object f14
```
      Field 14 of the tuple.
    - f15
```
Object f15
```
      Field 15 of the tuple.
    - f16
```
Object f16
```
      Field 16 of the tuple.
    - f17
```
Object f17
```
      Field 17 of the tuple.
    - f18
```
Object f18
```
      Field 18 of the tuple.
    - f19
```
Object f19
```
      Field 19 of the tuple.
    - f20
```
Object f20
```
      Field 20 of the tuple.
    - f21
```
Object f21
```
      Field 21 of the tuple.
    - f22
```
Object f22
```
      Field 22 of the tuple.
    - f23
```
Object f23
```
      Field 23 of the tuple.
    - f24
```
Object f24
```
      Field 24 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple3 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple4 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple5 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple6 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple7 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple8 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
- Class org.apache.flink.api.java.tuple.Tuple9 extends Tuple implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - f0
```
Object f0
```
      Field 0 of the tuple.
    - f1
```
Object f1
```
      Field 1 of the tuple.
    - f2
```
Object f2
```
      Field 2 of the tuple.
    - f3
```
Object f3
```
      Field 3 of the tuple.
    - f4
```
Object f4
```
      Field 4 of the tuple.
    - f5
```
Object f5
```
      Field 5 of the tuple.
    - f6
```
Object f6
```
      Field 6 of the tuple.
    - f7
```
Object f7
```
      Field 7 of the tuple.
    - f8
```
Object f8
```
      Field 8 of the tuple.
Package org.apache.flink.api.java.typeutils
- Class org.apache.flink.api.java.typeutils.EitherTypeInfo extends TypeInformation<Either<L,R>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - leftType
```
TypeInformation<T> leftType
```
    - rightType
```
TypeInformation<T> rightType
```
- Class org.apache.flink.api.java.typeutils.EnumTypeInfo extends TypeInformation<T extends Enum<T>> implements Serializable
  
  serialVersionUID:
  
  8936740290137178660L
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
- Class org.apache.flink.api.java.typeutils.GenericTypeInfo extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  -7959114120287706504L
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
- Class org.apache.flink.api.java.typeutils.ListTypeInfo extends TypeInformation<List<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - elementTypeInfo
```
TypeInformation<T> elementTypeInfo
```
- Class org.apache.flink.api.java.typeutils.MapTypeInfo extends TypeInformation<Map<K,V>> implements Serializable
  - Serialized Fields
    - keyTypeInfo
```
TypeInformation<T> keyTypeInfo
```
    - valueTypeInfo
```
TypeInformation<T> valueTypeInfo
```
- Class org.apache.flink.api.java.typeutils.MissingTypeInfo extends TypeInformation<InvalidTypesException> implements Serializable
  
  serialVersionUID:
  
  -4212082837126702723L
  - Serialized Fields
    - functionName
```
String functionName
```
    - typeException
```
InvalidTypesException typeException
```
- Class org.apache.flink.api.java.typeutils.MultisetTypeInfo extends MapTypeInfo<T,Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.ObjectArrayTypeInfo extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - arrayType
```
Class<T> arrayType
```
    - componentInfo
```
TypeInformation<T> componentInfo
```
- Class org.apache.flink.api.java.typeutils.PojoField extends Object implements Serializable
  
  serialVersionUID:
  
  1975295846436559363L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException,
                         ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - type
```
TypeInformation<T> type
```
- Class org.apache.flink.api.java.typeutils.PojoParametrizedTypeExtractionTest.ConcreteMapFunction extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.DuplicateMapper extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.FancyCollectionSubtype extends HashSet<T> implements Serializable
  
  serialVersionUID:
  
  -3494469602638179921L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.FromTuple extends Tuple3<String,String,Long> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - special
```
int special
```
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyMapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyMapper2 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyMapper3 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyMapper4 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyMapper5 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyMapper6 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyMapper7 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.MyValue extends Object implements Serializable
  
  serialVersionUID:
  
  8607223484689147046L
- Class org.apache.flink.api.java.typeutils.PojoTypeExtractionTest.PojoTuple extends Tuple3<B,C,Long> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - extraField
```
Object extraField
```
- Class org.apache.flink.api.java.typeutils.PojoTypeInfo extends CompositeType<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fields
```
PojoField[] fields
```
    - totalFields
```
int totalFields
```
- Class org.apache.flink.api.java.typeutils.RowTypeInfo extends TupleTypeInfoBase<Row> implements Serializable
  
  serialVersionUID:
  
  9158518989896601963L
  - Serialized Fields
    - fieldNames
```
String[] fieldNames
```
    - comparatorOrders
```
boolean[] comparatorOrders
```
      Temporary variable for directly passing orders to comparators.
- Class org.apache.flink.api.java.typeutils.TupleTypeInfo extends TupleTypeInfoBase<T extends Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldNames
```
String[] fieldNames
```
- Class org.apache.flink.api.java.typeutils.TupleTypeInfoBase extends CompositeType<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - types
```
TypeInformation<T>[] types
```
    - totalFields
```
int totalFields
```
- Class org.apache.flink.api.java.typeutils.TypeExtractionException extends Exception implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorInputFormatsTest.DerivedInputFormat extends GenericInputFormat<Short> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorInputFormatsTest.DerivedTupleInputFormat extends GenericInputFormat<Tuple3<String,Short,Double>> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorInputFormatsTest.DummyFloatInputFormat extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorInputFormatsTest.FinalRelativeInputFormat extends org.apache.flink.api.java.typeutils.TypeExtractorInputFormatsTest.RelativeInputFormat<Integer> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorInputFormatsTest.QueryableInputFormat extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorInputFormatsTest.RelativeInputFormat extends GenericInputFormat<Tuple3<String,T,Double>> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.ChainedFour extends org.apache.flink.api.java.typeutils.TypeExtractorTest.ChainedThree implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.ChainedOne extends Tuple3<X,Long,Y> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.ChainedThree extends org.apache.flink.api.java.typeutils.TypeExtractorTest.ChainedTwo<String> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.ChainedTwo extends org.apache.flink.api.java.typeutils.TypeExtractorTest.ChainedOne<String,V> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.CustomArrayObject2 extends Tuple1<F> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.CustomTuple extends Tuple2<String,Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.CustomTuple2WithArray extends Tuple2<K[],K> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.DummyFlatMapFunction extends RichFlatMapFunction<Tuple2<A,B>,Tuple2<C,D>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.DuplicateValue extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.DuplicateValueNested extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.Edge extends Tuple3<K,K,V> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.EdgeMapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.EdgeMapper2 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.EdgeMapper3 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.EdgeMapper4 extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.EitherMapper extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.EitherMapper2 extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.EitherMapper3 extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.FieldDuplicator extends RichMapFunction<T,Tuple2<T,T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.GenericArrayClass extends RichMapFunction<T[],T[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper extends RichMapFunction<T,T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper2 extends RichMapFunction<Tuple2<T,String>,T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper3 extends RichMapFunction<T,V> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper4 extends org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper<D> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper5 extends org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper<Tuple2<D,D>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.JoinWithCustomTuple2WithArray extends RichJoinFunction<org.apache.flink.api.java.typeutils.TypeExtractorTest.CustomTuple2WithArray<T>,org.apache.flink.api.java.typeutils.TypeExtractorTest.CustomTuple2WithArray<T>,org.apache.flink.api.java.typeutils.TypeExtractorTest.CustomTuple2WithArray<T>> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.LongKeyValue extends Tuple2<Long,V> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.Mapper extends org.apache.flink.api.java.typeutils.TypeExtractorTest.IdentityMapper<String> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.Mapper2 extends org.apache.flink.api.java.typeutils.TypeExtractorTest.Mapper implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.MapperWithMultiDimGenericArray extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.MapWithResultTypeQueryable extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.MyQueryableMapper extends RichMapFunction<String,A> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.Nested extends Tuple2<V,Tuple2<T,T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.Nested2 extends org.apache.flink.api.java.typeutils.TypeExtractorTest.Nested<T,org.apache.flink.api.java.typeutils.TypeExtractorTest.Nested<Integer,T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.OneAppender extends RichMapFunction<T,Tuple2<T,Integer>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeExtractorTest.SameTypeVariable extends Tuple2<X,X> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyEitherMapper extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyFaultyMapper extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyFaultyMapper2 extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyFaultyTypeInfo extends TypeInformation<org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyFaulty> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyOptionMapper extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyOptionTypeInfo extends TypeInformation<org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyOption<T>> implements Serializable
  - Serialized Fields
    - innerType
```
TypeInformation<T> innerType
```
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyTuple3Mapper extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyTupleMapperL1 extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyTupleMapperL2 extends org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyTupleMapperL1<C,Boolean> implements Serializable
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyTupleTypeInfo extends TypeInformation<org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.MyTuple<T0,T1>> implements Serializable
  - Serialized Fields
    - field0
```
TypeInformation<T> field0
```
    - field1
```
TypeInformation<T> field1
```
- Class org.apache.flink.api.java.typeutils.TypeInfoFactoryTest.WithFieldTypeInfoAnnotationMapper extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.ValueTypeInfo extends TypeInformation<T extends Value> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
- Class org.apache.flink.api.java.typeutils.ValueTypeInfoTest.AlternativeClass extends Object implements Serializable
  
  serialVersionUID:
  
  -163437084575260172L
- Class org.apache.flink.api.java.typeutils.ValueTypeInfoTest.TestClass extends Object implements Serializable
  
  serialVersionUID:
  
  -492760806806568285L
- Class org.apache.flink.api.java.typeutils.WritableTypeInfo extends TypeInformation<T extends org.apache.hadoop.io.Writable> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
Package org.apache.flink.api.java.typeutils.runtime
- Class org.apache.flink.api.java.typeutils.runtime.CopyableSerializerUpgradeTest.SimpleCopyable extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - value
```
long value
```
- Class org.apache.flink.api.java.typeutils.runtime.CopyableValueComparator extends TypeComparator<T extends CopyableValue<T> & Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream s)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - type
```
Class<T> type
```
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.java.typeutils.runtime.CopyableValueSerializer extends TypeSerializer<T extends CopyableValue<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - valueClass
```
Class<T> valueClass
```
- Class org.apache.flink.api.java.typeutils.runtime.EitherSerializer extends TypeSerializer<Either<L,R>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - leftSerializer
```
TypeSerializer<T> leftSerializer
```
    - rightSerializer
```
TypeSerializer<T> rightSerializer
```
- Class org.apache.flink.api.java.typeutils.runtime.GenericTypeComparator extends TypeComparator<T extends Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascending
```
boolean ascending
```
    - type
```
Class<T> type
```
    - serializer
```
TypeSerializer<T> serializer
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.java.typeutils.runtime.KryoRegistration extends Object implements Serializable
  
  serialVersionUID:
  
  5375110512910892655L
  - Serialized Fields
    - registeredClass
```
Class<T> registeredClass
```
      The registered class.
      This can be a dummy class KryoRegistrationSerializerConfigSnapshot.DummyRegisteredClass if the class no longer exists when this registration instance was restored.
    - serializerClass
```
Class<T> serializerClass
```
      Class of the serializer to use for the registered class. Exists only if the serializer definition type is KryoRegistration.SerializerDefinitionType.CLASS.
      This can be a dummy serializer KryoRegistrationSerializerConfigSnapshot.DummyKryoSerializerClass if the serializer class no longer exists when this registration instance was restored.
    - serializableSerializerInstance
```
ExecutionConfig.SerializableSerializer<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable> serializableSerializerInstance
```
      A serializable instance of the serializer to use for the registered class. Exists only if the serializer definition type is KryoRegistration.SerializerDefinitionType.INSTANCE.
      This can be a dummy serializer KryoRegistrationSerializerConfigSnapshot.DummyKryoSerializerClass if the serializer class no longer exists or is no longer valid when this registration instance was restored.
    - serializerDefinitionType
```
KryoRegistration.SerializerDefinitionType serializerDefinitionType
```
- Class org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot.DummyKryoSerializerClass extends com.esotericsoftware.kryo.Serializer<RC> implements Serializable
  
  serialVersionUID:
  
  -6172780797425739308L
- Class org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot.DummyRegisteredClass extends Object implements Serializable
- Class org.apache.flink.api.java.typeutils.runtime.LegacyRowSerializerTest.MyPojo extends Object implements Serializable
  - Serialized Fields
    - name
```
String name
```
- Class org.apache.flink.api.java.typeutils.runtime.NullableSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  3335569358214720033L
  - Serialized Fields
    - originalSerializer
```
TypeSerializer<T> originalSerializer
```
    - padding
```
byte[] padding
```
- Class org.apache.flink.api.java.typeutils.runtime.NullAwareComparator extends TypeComparator<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - wrappedComparator
```
TypeComparator<T> wrappedComparator
```
    - order
```
boolean order
```
    - flatFields
```
int flatFields
```
    - nullReference
```
boolean nullReference
```
- Class org.apache.flink.api.java.typeutils.runtime.PojoComparator extends CompositeTypeComparator<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException,
                         ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - comparators
```
TypeComparator<T>[] comparators
```
    - normalizedKeyLengths
```
int[] normalizedKeyLengths
```
    - numLeadingNormalizableKeys
```
int numLeadingNormalizableKeys
```
    - normalizableKeyPrefixLen
```
int normalizableKeyPrefixLen
```
    - invertNormKey
```
boolean invertNormKey
```
    - serializer
```
TypeSerializer<T> serializer
```
    - type
```
Class<T> type
```
- Class org.apache.flink.api.java.typeutils.runtime.PojoSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException,
                         ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
      The POJO type class.
    - fieldSerializers
```
TypeSerializer<T>[] fieldSerializers
```
    - numFields
```
int numFields
```
    - registeredClasses
```
LinkedHashMap<K,V> registeredClasses
```
      Registered subclasses and their serializers. Each subclass to their registered class tag is maintained as a separate map ordered by the class tag.
    - registeredSerializers
```
TypeSerializer<T>[] registeredSerializers
```
    - executionConfig
```
ExecutionConfig executionConfig
```
      Configuration of the current execution.
- Class org.apache.flink.api.java.typeutils.runtime.RowComparator extends CompositeTypeComparator<Row> implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - arity
```
int arity
```
      The number of fields of the Row
    - keyPositions
```
int[] keyPositions
```
      key positions describe which fields are keys in what order
    - comparators
```
NullAwareComparator<T>[] comparators
```
      null-aware comparators for the key fields, in the same order as the key fields
    - serializers
```
TypeSerializer<T>[] serializers
```
      serializers to deserialize the first n fields for comparison
    - normalizedKeyLengths
```
int[] normalizedKeyLengths
```
      auxiliary fields for normalized key support
    - numLeadingNormalizableKeys
```
int numLeadingNormalizableKeys
```
    - normalizableKeyPrefixLen
```
int normalizableKeyPrefixLen
```
    - invertNormKey
```
boolean invertNormKey
```
    - mask1
```
boolean[] mask1
```
    - mask2
```
boolean[] mask2
```
- Class org.apache.flink.api.java.typeutils.runtime.RowComparatorTest.MyPojo extends Object implements Serializable
  - Serialized Fields
    - name
```
String name
```
- Class org.apache.flink.api.java.typeutils.runtime.RowSerializer extends TypeSerializer<Row> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - supportsRowKind
```
boolean supportsRowKind
```
    - rowKindOffset
```
int rowKindOffset
```
    - fieldSerializers
```
TypeSerializer<T>[] fieldSerializers
```
    - arity
```
int arity
```
    - positionByName
```
LinkedHashMap<K,V> positionByName
```
- Class org.apache.flink.api.java.typeutils.runtime.RowSerializerTest.MyPojo extends Object implements Serializable
  - Serialized Fields
    - name
```
String name
```
- Class org.apache.flink.api.java.typeutils.runtime.RuntimeComparatorFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - comparator
```
TypeComparator<T> comparator
```
- Class org.apache.flink.api.java.typeutils.runtime.RuntimePairComparatorFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.RuntimeSerializerFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - serializer
```
TypeSerializer<T> serializer
```
    - clazz
```
Class<T> clazz
```
- Class org.apache.flink.api.java.typeutils.runtime.Tuple0Serializer extends TupleSerializer<Tuple0> implements Serializable
  
  serialVersionUID:
  
  1278813169022975971L
- Class org.apache.flink.api.java.typeutils.runtime.TupleComparator extends TupleComparatorBase<T extends Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.TupleComparatorBase extends CompositeTypeComparator<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - keyPositions
```
int[] keyPositions
```
      key positions describe which fields are keys in what order
    - comparators
```
TypeComparator<T>[] comparators
```
      comparators for the key fields, in the same order as the key fields
    - normalizedKeyLengths
```
int[] normalizedKeyLengths
```
    - numLeadingNormalizableKeys
```
int numLeadingNormalizableKeys
```
    - normalizableKeyPrefixLen
```
int normalizableKeyPrefixLen
```
    - invertNormKey
```
boolean invertNormKey
```
    - serializers
```
TypeSerializer<T>[] serializers
```
      serializers to deserialize the first n fields for comparison
- Class org.apache.flink.api.java.typeutils.runtime.TupleSerializer extends TupleSerializerBase<T extends Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.TupleSerializerBase extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tupleClass
```
Class<T> tupleClass
```
    - fieldSerializers
```
TypeSerializer<T>[] fieldSerializers
```
    - arity
```
int arity
```
    - length
```
int length
```
- Class org.apache.flink.api.java.typeutils.runtime.ValueComparator extends TypeComparator<T extends Value & Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.java.typeutils.runtime.ValueID extends Object implements Serializable
  
  serialVersionUID:
  
  -562791433077971752L
  - Serialized Fields
    - id
```
UUID id
```
- Class org.apache.flink.api.java.typeutils.runtime.ValueSerializer extends TypeSerializer<T extends Value> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - type
```
Class<T> type
```
    - kryoRegistrations
```
LinkedHashMap<K,V> kryoRegistrations
```
      Map of class tag (using classname as tag) to their Kryo registration.
      This map serves as a preview of the final registration result of the Kryo instance, taking into account registration overwrites.
      Currently, we only have one single registration for the value type. Nevertheless, we keep this information here for future compatibility.
- Class org.apache.flink.api.java.typeutils.runtime.ValueSerializerUpgradeTest.NameValue extends Object implements Serializable
  
  serialVersionUID:
  
  2277251654485371327L
  - Serialized Fields
    - name
```
String name
```
- Class org.apache.flink.api.java.typeutils.runtime.WritableComparator extends TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.java.typeutils.runtime.WritableSerializer extends TypeSerializer<T extends org.apache.hadoop.io.Writable> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
Package org.apache.flink.api.java.typeutils.runtime.kryo
- Class org.apache.flink.api.java.typeutils.runtime.kryo.KryoClearedBufferTest.TestRecordSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.flink.api.java.typeutils.runtime.kryo.KryoClearedBufferTest.TestRecord> implements Serializable
  
  serialVersionUID:
  
  6971996565421454985L
- Class org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.DogKryoSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.Dog> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.DogV2KryoSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.Dog> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.ParrotKryoSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.Parrot> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  3L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - defaultSerializers
```
LinkedHashMap<K,V> defaultSerializers
```
    - defaultSerializerClasses
```
LinkedHashMap<K,V> defaultSerializerClasses
```
    - kryoRegistrations
```
LinkedHashMap<K,V> kryoRegistrations
```
      Map of class tag (using classname as tag) to their Kryo registration.
      This map serves as a preview of the final registration result of the Kryo instance, taking into account registration overwrites.
    - type
```
Class<T> type
```
    - registeredTypesWithSerializers
```
LinkedHashMap<K,V> registeredTypesWithSerializers
```
    - registeredTypesWithSerializerClasses
```
LinkedHashMap<K,V> registeredTypesWithSerializerClasses
```
    - registeredTypes
```
LinkedHashSet<E> registeredTypes
```
- Class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializerConcurrencyTest.TestSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializerConcurrencyTest.WrappedString> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.kryo.KryoWithCustomSerializersTest.LocalDateSerializer extends com.esotericsoftware.kryo.Serializer<org.joda.time.LocalDate> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.SpecificInstanceCollectionSerializer extends com.esotericsoftware.kryo.serializers.CollectionSerializer implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
- Class org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.SpecificInstanceCollectionSerializerForArrayList extends Serializers.SpecificInstanceCollectionSerializer<ArrayList> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.java.utils
- Class org.apache.flink.api.java.utils.AbstractParameterTool extends ExecutionConfig.GlobalJobParameters implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.utils.MultipleParameterTool extends AbstractParameterTool implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - data
```
Map<K,V> data
```
- Class org.apache.flink.api.java.utils.ParameterTool extends AbstractParameterTool implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - data
```
Map<K,V> data
```
- Class org.apache.flink.api.java.utils.RequiredParametersException extends Exception implements Serializable
  - Serialized Fields
    - missingArguments
```
List<E> missingArguments
```
      Deprecated.
Package org.apache.flink.api.scala.operators
- Class org.apache.flink.api.scala.operators.ScalaCsvOutputFormat extends FileOutputFormat<T extends scala.Product> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldDelimiter
```
String fieldDelimiter
```
    - recordDelimiter
```
String recordDelimiter
```
    - charsetName
```
String charsetName
```
    - allowNullValues
```
boolean allowNullValues
```
    - quoteStrings
```
boolean quoteStrings
```
Package org.apache.flink.api.scala.typeutils
- Class org.apache.flink.api.scala.typeutils.CaseClassComparator extends TupleComparatorBase<T extends scala.Product> implements Serializable
  - Serialized Fields
    - extractedKeys
```
Object[] extractedKeys
```
- Class org.apache.flink.api.scala.typeutils.CaseClassSerializer extends TupleSerializerBase<T extends scala.Product> implements Serializable
  
  serialVersionUID:
  
  7341356073446263475L
- Class org.apache.flink.api.scala.typeutils.CaseClassTypeInfo extends TupleTypeInfoBase<T extends scala.Product> implements Serializable
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
    - typeParamTypeInfos
```
TypeInformation<T>[] typeParamTypeInfos
```
    - fieldTypes
```
scala.collection.Seq<A> fieldTypes
```
    - fieldNames
```
scala.collection.Seq<A> fieldNames
```
    - REGEX_INT_FIELD
```
String REGEX_INT_FIELD
```
    - REGEX_STR_FIELD
```
String REGEX_STR_FIELD
```
    - REGEX_FIELD
```
String REGEX_FIELD
```
    - REGEX_NESTED_FIELDS
```
String REGEX_NESTED_FIELDS
```
    - REGEX_NESTED_FIELDS_WILDCARD
```
String REGEX_NESTED_FIELDS_WILDCARD
```
    - PATTERN_NESTED_FIELDS
```
Pattern PATTERN_NESTED_FIELDS
```
    - PATTERN_NESTED_FIELDS_WILDCARD
```
Pattern PATTERN_NESTED_FIELDS_WILDCARD
```
    - PATTERN_INT_FIELD
```
Pattern PATTERN_INT_FIELD
```
- Class org.apache.flink.api.scala.typeutils.EitherSerializer extends TypeSerializer<scala.util.Either<A,B>> implements Serializable
  
  serialVersionUID:
  
  9219995873023657525L
  - Serialized Fields
    - leftSerializer
```
TypeSerializer<T> leftSerializer
```
    - rightSerializer
```
TypeSerializer<T> rightSerializer
```
- Class org.apache.flink.api.scala.typeutils.EitherTypeInfo extends TypeInformation<T extends scala.util.Either<A,B>> implements Serializable
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
    - leftTypeInfo
```
TypeInformation<T> leftTypeInfo
```
    - rightTypeInfo
```
TypeInformation<T> rightTypeInfo
```
- Class org.apache.flink.api.scala.typeutils.EnumValueComparator extends TypeComparator<scala.Enumeration.Value> implements Serializable
  
  serialVersionUID:
  
  1000L
  - Serialized Fields
    - getFlatComparators
```
TypeComparator<T>[] getFlatComparators
```
    - ascComp
```
boolean ascComp
```
    - intComparator
```
IntComparator intComparator
```
    - bitmap$0
```
boolean bitmap$0
```
- Class org.apache.flink.api.scala.typeutils.EnumValueSerializer extends TypeSerializer<scala.Enumeration.Value> implements Serializable
  
  serialVersionUID:
  
  -2403076635594572920L
  - Serialized Fields
    - enum
```
scala.Enumeration enum
```
- Class org.apache.flink.api.scala.typeutils.EnumValueSerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.EnumValueTypeInfo extends TypeInformation<scala.Enumeration.Value> implements Serializable
  - Serialized Fields
    - enum
```
scala.Enumeration enum
```
    - clazz
```
Class<T> clazz
```
- Class org.apache.flink.api.scala.typeutils.NothingSerializer extends TypeSerializer<Object> implements Serializable
- Class org.apache.flink.api.scala.typeutils.OptionSerializer extends TypeSerializer<scala.Option<A>> implements Serializable
  
  serialVersionUID:
  
  -8635243274072627338L
  - Serialized Fields
    - elemSerializer
```
TypeSerializer<T> elemSerializer
```
- Class org.apache.flink.api.scala.typeutils.OptionSerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.OptionTypeComparator extends TypeComparator<scala.Option<A>> implements Serializable
  - Serialized Fields
    - getFlatComparators
```
TypeComparator<T>[] getFlatComparators
```
    - ascending
```
boolean ascending
```
    - typeComparator
```
TypeComparator<T> typeComparator
```
    - reference
```
scala.Option<A> reference
```
    - bitmap$0
```
boolean bitmap$0
```
- Class org.apache.flink.api.scala.typeutils.OptionTypeComparator$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
  - Serialized Fields
    - ZeroInByte
```
byte ZeroInByte
```
    - OneInByte
```
byte OneInByte
```
- Class org.apache.flink.api.scala.typeutils.OptionTypeInfo extends TypeInformation<T extends scala.Option<A>> implements Serializable
  - Serialized Fields
    - elemTypeInfo
```
TypeInformation<T> elemTypeInfo
```
- Class org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer extends org.apache.flink.api.scala.typeutils.CaseClassSerializer<T extends scala.Product> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream arg0)
```
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
- Class org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.ScalaNothingTypeInfo extends TypeInformation<scala.runtime.Nothing$> implements Serializable
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer extends TypeSerializer<T extends scala.collection.TraversableOnce<E>> implements Serializable
  
  serialVersionUID:
  
  7522917416391312410L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream arg0)
```
  - Serialized Fields
    - elementSerializer
```
TypeSerializer<T> elementSerializer
```
    - cbfCode
```
String cbfCode
```
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer.Key extends Object implements Serializable
  - Serialized Fields
    - classLoaderHash
```
int classLoaderHash
```
    - classLoaderRef
```
scala.ref.WeakReference<T> classLoaderRef
```
    - cbfCode
```
String cbfCode
```
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer.Key$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer.LazyRuntimeCompiler extends Object implements Serializable
  - Serialized Fields
    - classLoader
```
ClassLoader classLoader
```
    - code
```
String code
```
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer.LazyRuntimeCompiler$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.TraversableSerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
  - Serialized Fields
    - CACHE
```
org.apache.flink.shaded.guava30.com.google.common.cache.Cache<K,V> CACHE
```
- Class org.apache.flink.api.scala.typeutils.TraversableTypeInfo extends TypeInformation<T extends scala.collection.TraversableOnce<E>> implements Serializable
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
    - elementTypeInfo
```
TypeInformation<T> elementTypeInfo
```
- Class org.apache.flink.api.scala.typeutils.TrySerializer extends TypeSerializer<scala.util.Try<A>> implements Serializable
  
  serialVersionUID:
  
  -3052182891252564491L
  - Serialized Fields
    - elemSerializer
```
TypeSerializer<T> elemSerializer
```
    - throwableSerializer
```
TypeSerializer<T> throwableSerializer
```
- Class org.apache.flink.api.scala.typeutils.TrySerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.TryTypeInfo extends TypeInformation<T extends scala.util.Try<A>> implements Serializable
  - Serialized Fields
    - elemTypeInfo
```
TypeInformation<T> elemTypeInfo
```
- Class org.apache.flink.api.scala.typeutils.UnitSerializer extends TypeSerializerSingleton<scala.runtime.BoxedUnit> implements Serializable
  
  serialVersionUID:
  
  5413377487955047394L
- Class org.apache.flink.api.scala.typeutils.UnitSerializer$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.api.scala.typeutils.UnitTypeInfo extends TypeInformation<scala.runtime.BoxedUnit> implements Serializable
Package org.apache.flink.batch.connectors.cassandra
- Class org.apache.flink.batch.connectors.cassandra.CassandraInputFormat extends CassandraInputFormatBase<OUT extends Tuple> implements Serializable
  
  serialVersionUID:
  
  3642323148032444264L
- Class org.apache.flink.batch.connectors.cassandra.CassandraInputFormatBase extends RichInputFormat<OUT,InputSplit> implements Serializable
  
  serialVersionUID:
  
  -1519372881115104601L
  - Serialized Fields
    - logger
```
org.slf4j.Logger logger
```
    - query
```
String query
```
    - builder
```
ClusterBuilder builder
```
- Class org.apache.flink.batch.connectors.cassandra.CassandraOutputFormat extends CassandraTupleOutputFormat<OUT extends Tuple> implements Serializable
- Class org.apache.flink.batch.connectors.cassandra.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 org.apache.flink.batch.connectors.cassandra.CassandraOutputFormatBase<OUT,Void> implements Serializable
  
  serialVersionUID:
  
  -1701885135103942460L
  - Serialized Fields
    - mapperOptions
```
MapperOptions mapperOptions
```
    - outputClass
```
Class<T> outputClass
```
- Class org.apache.flink.batch.connectors.cassandra.CassandraRowOutputFormat extends org.apache.flink.batch.connectors.cassandra.CassandraColumnarOutputFormatBase<Row> implements Serializable
- Class org.apache.flink.batch.connectors.cassandra.CassandraTupleOutputFormat extends org.apache.flink.batch.connectors.cassandra.CassandraColumnarOutputFormatBase<OUT extends Tuple> implements Serializable
Package org.apache.flink.batch.tests
- Class org.apache.flink.batch.tests.BlockingIncrementingMapFunction extends RichMapFunction<Long,Long> implements Serializable
  - Serialized Fields
    - latchFilePath
```
String latchFilePath
```
- Class org.apache.flink.batch.tests.Generator extends Object implements Serializable
  - Serialized Fields
    - numRecords
```
long numRecords
```
    - numKeys
```
long numKeys
```
    - recordsPerPartition
```
long recordsPerPartition
```
    - keysPerPartition
```
long keysPerPartition
```
    - recordCnt
```
long recordCnt
```
    - partitionId
```
int partitionId
```
    - infinite
```
boolean infinite
```
Package org.apache.flink.cep
- Class org.apache.flink.cep.PatternStream.CoMapTimeout extends Object implements Serializable
  
  serialVersionUID:
  
  2059391566945212552L
- Class org.apache.flink.cep.RichPatternFlatSelectFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cep.RichPatternSelectFunction extends AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cep.configuration
- Class org.apache.flink.cep.configuration.SharedBufferCacheConfig extends Object implements Serializable
  - Serialized Fields
    - eventsBufferCacheSlots
```
int eventsBufferCacheSlots
```
    - entryCacheSlots
```
int entryCacheSlots
```
    - cacheStatisticsInterval
```
java.time.Duration cacheStatisticsInterval
```
Package org.apache.flink.cep.functions
- Class org.apache.flink.cep.functions.PatternProcessFunction extends AbstractRichFunction implements Serializable
Package org.apache.flink.cep.functions.adaptors
- Class org.apache.flink.cep.functions.adaptors.PatternFlatSelectAdapter extends PatternProcessFunction<IN,OUT> implements Serializable
  - Serialized Fields
    - flatSelectFunction
```
PatternFlatSelectFunction<IN,OUT> flatSelectFunction
```
- Class org.apache.flink.cep.functions.adaptors.PatternSelectAdapter extends PatternProcessFunction<IN,OUT> implements Serializable
  - Serialized Fields
    - selectFunction
```
PatternSelectFunction<IN,OUT> selectFunction
```
- Class org.apache.flink.cep.functions.adaptors.PatternTimeoutFlatSelectAdapter extends PatternFlatSelectAdapter<IN,OUT> implements Serializable
  - Serialized Fields
    - flatTimeoutFunction
```
PatternFlatTimeoutFunction<IN,OUT> flatTimeoutFunction
```
    - timedOutPartialMatchesTag
```
OutputTag<T> timedOutPartialMatchesTag
```
- Class org.apache.flink.cep.functions.adaptors.PatternTimeoutSelectAdapter extends PatternSelectAdapter<IN,OUT> implements Serializable
  - Serialized Fields
    - timeoutFunction
```
PatternTimeoutFunction<IN,OUT> timeoutFunction
```
    - timedOutPartialMatchesTag
```
OutputTag<T> timedOutPartialMatchesTag
```
Package org.apache.flink.cep.nfa
- Class org.apache.flink.cep.nfa.DeweyNumber extends Object implements Serializable
  
  serialVersionUID:
  
  6170434818252267825L
  - Serialized Fields
    - deweyNumber
```
int[] deweyNumber
```
- Class org.apache.flink.cep.nfa.DeweyNumber.DeweyNumberSerializer extends TypeSerializerSingleton<DeweyNumber> implements Serializable
  
  serialVersionUID:
  
  -5086792497034943656L
- Class org.apache.flink.cep.nfa.NFA.NFASerializer extends TypeSerializer<NFA.MigratedNFA<T>> implements Serializable
  
  serialVersionUID:
  
  2098282423980597010L
  - Serialized Fields
    - sharedBufferSerializer
```
TypeSerializer<T> sharedBufferSerializer
```
      Deprecated.
    - eventSerializer
```
TypeSerializer<T> eventSerializer
```
      Deprecated.
- Class org.apache.flink.cep.nfa.NFAStateSerializer extends TypeSerializerSingleton<NFAState> implements Serializable
  
  serialVersionUID:
  
  2098282423980597010L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - versionSerializer
```
TypeSerializer<T> versionSerializer
```
      NOTE: this field should actually be final. The reason that it isn't final is due to backward compatible deserialization paths. See NFAStateSerializer.readObject(ObjectInputStream).
    - nodeIdSerializer
```
TypeSerializer<T> nodeIdSerializer
```
    - eventIdSerializer
```
TypeSerializer<T> eventIdSerializer
```
    - supportsPreviousTimestamp
```
boolean supportsPreviousTimestamp
```
- Class org.apache.flink.cep.nfa.SharedBuffer.SharedBufferSerializer extends TypeSerializer<SharedBuffer<V>> implements Serializable
  
  serialVersionUID:
  
  -3254176794680331560L
  - Serialized Fields
    - keySerializer
```
TypeSerializer<T> keySerializer
```
    - valueSerializer
```
TypeSerializer<T> valueSerializer
```
    - versionSerializer
```
TypeSerializer<T> versionSerializer
```
- Class org.apache.flink.cep.nfa.State extends Object implements Serializable
  
  serialVersionUID:
  
  6658700025989097781L
  - Serialized Fields
    - name
```
String name
```
    - stateType
```
State.StateType stateType
```
    - stateTransitions
```
Collection<E> stateTransitions
```
- Class org.apache.flink.cep.nfa.StateTransition extends Object implements Serializable
  
  serialVersionUID:
  
  -4825345749997891838L
  - Serialized Fields
    - action
```
StateTransitionAction action
```
    - sourceState
```
State<T> sourceState
```
    - targetState
```
State<T> targetState
```
    - condition
```
IterativeCondition<T> condition
```
Package org.apache.flink.cep.nfa.aftermatch
- Class org.apache.flink.cep.nfa.aftermatch.AfterMatchSkipStrategy extends Object implements Serializable
  
  serialVersionUID:
  
  -4048930333619068531L
- Class org.apache.flink.cep.nfa.aftermatch.NoSkipStrategy extends AfterMatchSkipStrategy implements Serializable
  
  serialVersionUID:
  
  -5843740153729531775L
- Class org.apache.flink.cep.nfa.aftermatch.SkipPastLastStrategy extends org.apache.flink.cep.nfa.aftermatch.SkipRelativeToWholeMatchStrategy implements Serializable
  
  serialVersionUID:
  
  -8450320065949093169L
- Class org.apache.flink.cep.nfa.aftermatch.SkipToFirstStrategy extends org.apache.flink.cep.nfa.aftermatch.SkipToElementStrategy implements Serializable
  
  serialVersionUID:
  
  7127107527654629026L
- Class org.apache.flink.cep.nfa.aftermatch.SkipToLastStrategy extends org.apache.flink.cep.nfa.aftermatch.SkipToElementStrategy implements Serializable
  
  serialVersionUID:
  
  7585116990619594531L
- Class org.apache.flink.cep.nfa.aftermatch.SkipToNextStrategy extends org.apache.flink.cep.nfa.aftermatch.SkipRelativeToWholeMatchStrategy implements Serializable
  
  serialVersionUID:
  
  -6490314998588752621L
Package org.apache.flink.cep.nfa.compiler
Package org.apache.flink.cep.nfa.sharedbuffer
- Class org.apache.flink.cep.nfa.sharedbuffer.EventId.EventIdSerializer extends TypeSerializerSingleton<EventId> implements Serializable
  
  serialVersionUID:
  
  -5685733582601394497L
- Class org.apache.flink.cep.nfa.sharedbuffer.Lockable.LockableTypeSerializer extends TypeSerializer<Lockable<E>> implements Serializable
  
  serialVersionUID:
  
  3298801058463337340L
  - Serialized Fields
    - elementSerializer
```
TypeSerializer<T> elementSerializer
```
- Class org.apache.flink.cep.nfa.sharedbuffer.NodeId.NodeIdSerializer extends TypeSerializerSingleton<NodeId> implements Serializable
  
  serialVersionUID:
  
  9209498028181378582L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - eventIdSerializer
```
TypeSerializer<T> eventIdSerializer
```
      NOTE: this field should actually be final. The reason that it isn't final is due to backward compatible deserialization paths. See NodeId.NodeIdSerializer.readObject(ObjectInputStream).
- Class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferEdge.SharedBufferEdgeSerializer extends TypeSerializerSingleton<SharedBufferEdge> implements Serializable
  
  serialVersionUID:
  
  -5122474955050663979L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - nodeIdSerializer
```
TypeSerializer<T> nodeIdSerializer
```
      NOTE: these serializer fields should actually be final. The reason that it isn't final is due to backward compatible deserialization paths. See SharedBufferEdge.SharedBufferEdgeSerializer.readObject(ObjectInputStream).
    - deweyNumberSerializer
```
TypeSerializer<T> deweyNumberSerializer
```
- Class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferNode.SharedBufferNodeSerializer extends TypeSerializerSingleton<SharedBufferNode> implements Serializable
  
  serialVersionUID:
  
  -6687780732295439832L
  - Serialized Fields
    - edgesSerializer
```
ListSerializer<T> edgesSerializer
```
      Deprecated.
- Class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferNodeSerializer extends TypeSerializerSingleton<SharedBufferNode> implements Serializable
  
  serialVersionUID:
  
  -6687780732295439832L
  - Serialized Fields
    - edgeSerializer
```
TypeSerializer<T> edgeSerializer
```
Package org.apache.flink.cep.operator
- Class org.apache.flink.cep.operator.CepOperator extends AbstractUdfStreamOperator<OUT,PatternProcessFunction<IN,OUT>> implements Serializable
  
  serialVersionUID:
  
  -4166778210774160757L
  - Serialized Fields
    - isProcessingTime
```
boolean isProcessingTime
```
    - inputSerializer
```
TypeSerializer<T> inputSerializer
```
    - nfaFactory
```
NFACompiler.NFAFactory<T> nfaFactory
```
    - comparator
```
EventComparator<T> comparator
```
      Comparator for secondary sorting. Primary sorting is always done on time.
    - lateDataOutputTag
```
OutputTag<T> lateDataOutputTag
```
      OutputTag to use for late arriving events. Elements with timestamp smaller than the current watermark will be emitted to this.
    - afterMatchSkipStrategy
```
AfterMatchSkipStrategy afterMatchSkipStrategy
```
      Strategy which element to skip after a match was found.
- Class org.apache.flink.cep.operator.StreamRecordComparator extends Object implements Serializable
  
  serialVersionUID:
  
  1581054988433915305L
Package org.apache.flink.cep.pattern
- Class org.apache.flink.cep.pattern.MalformedPatternException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  7751134834983361543L
Package org.apache.flink.cep.pattern.conditions
- Class org.apache.flink.cep.pattern.conditions.AndCondition extends IterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  -2471892317390197319L
  - Serialized Fields
    - left
```
IterativeCondition<T> left
```
      Deprecated.
    - right
```
IterativeCondition<T> right
```
      Deprecated.
- Class org.apache.flink.cep.pattern.conditions.IterativeCondition extends Object implements Serializable
  
  serialVersionUID:
  
  7067817235759351255L
- Class org.apache.flink.cep.pattern.conditions.NotCondition extends IterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  -2109562093871155005L
  - Serialized Fields
    - original
```
IterativeCondition<T> original
```
      Deprecated.
- Class org.apache.flink.cep.pattern.conditions.OrCondition extends IterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  2554610954278485106L
  - Serialized Fields
    - left
```
IterativeCondition<T> left
```
      Deprecated.
    - right
```
IterativeCondition<T> right
```
      Deprecated.
- Class org.apache.flink.cep.pattern.conditions.RichAndCondition extends RichCompositeIterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cep.pattern.conditions.RichCompositeIterativeCondition extends RichIterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nestedConditions
```
IterativeCondition<T>[] nestedConditions
```
- Class org.apache.flink.cep.pattern.conditions.RichIterativeCondition extends IterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cep.pattern.conditions.RichNotCondition extends RichCompositeIterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cep.pattern.conditions.RichOrCondition extends RichCompositeIterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cep.pattern.conditions.SimpleCondition extends IterativeCondition<T> implements Serializable
  
  serialVersionUID:
  
  4942618239408140245L
- Class org.apache.flink.cep.pattern.conditions.SubtypeCondition extends SimpleCondition<T> implements Serializable
  
  serialVersionUID:
  
  -2990017519957561355L
  - Serialized Fields
    - subtype
```
Class<T> subtype
```
      The subtype to filter for.
Package org.apache.flink.client.cli
- Class org.apache.flink.client.cli.CliArgsException extends Exception implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.client.deployment
- Class org.apache.flink.client.deployment.ClusterDeploymentException extends FlinkException implements Serializable
  
  serialVersionUID:
  
  -4327724979766139208L
- Class org.apache.flink.client.deployment.ClusterRetrieveException extends FlinkException implements Serializable
  
  serialVersionUID:
  
  7718062507419172318L
Package org.apache.flink.client.deployment.application
- Class org.apache.flink.client.deployment.application.ApplicationExecutionException extends FlinkException implements Serializable
- Class org.apache.flink.client.deployment.application.UnsuccessfulExecutionException extends JobExecutionException implements Serializable
  - Serialized Fields
    - status
```
ApplicationStatus status
```
Package org.apache.flink.client.program
- Class org.apache.flink.client.program.MutatedConfigurationException extends Exception implements Serializable
  
  serialVersionUID:
  
  -2417524218857151612L
- Class org.apache.flink.client.program.ProgramAbortException extends Error implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.client.program.ProgramInvocationException extends Exception implements Serializable
  
  serialVersionUID:
  
  -2417524218857151612L
- Class org.apache.flink.client.program.ProgramMissingJobException extends FlinkException implements Serializable
  
  serialVersionUID:
  
  -1964276369605091101L
- Class org.apache.flink.client.program.ProgramParametrizationException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  909054589029890262L
Package org.apache.flink.configuration
- Class org.apache.flink.configuration.Configuration extends ExecutionConfig.GlobalJobParameters implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - confData
```
HashMap<K,V> confData
```
      Stores the concrete key/value pairs of this configuration object.
- Class org.apache.flink.configuration.DelegatingConfiguration extends Configuration implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - backingConfig
```
Configuration backingConfig
```
    - prefix
```
String prefix
```
- Class org.apache.flink.configuration.IllegalConfigurationException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  695506964810499989L
- Class org.apache.flink.configuration.MemorySize extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - bytes
```
long bytes
```
      The memory size, in bytes.
- Class org.apache.flink.configuration.UnmodifiableConfiguration extends Configuration implements Serializable
  
  serialVersionUID:
  
  -8151292629158972280L
Package org.apache.flink.connector.aws.util
- Class org.apache.flink.connector.aws.util.AWSAuthenticationException extends RuntimeException implements Serializable
Package org.apache.flink.connector.base.sink
- Class org.apache.flink.connector.base.sink.AsyncSinkBase extends Object implements Serializable
  - Serialized Fields
    - elementConverter
```
ElementConverter<InputT,RequestEntryT> elementConverter
```
    - maxBatchSize
```
int maxBatchSize
```
    - maxInFlightRequests
```
int maxInFlightRequests
```
    - maxBufferedRequests
```
int maxBufferedRequests
```
    - maxBatchSizeInBytes
```
long maxBatchSizeInBytes
```
    - maxTimeInBufferMS
```
long maxTimeInBufferMS
```
    - maxRecordSizeInBytes
```
long maxRecordSizeInBytes
```
Package org.apache.flink.connector.base.sink.writer
- Class org.apache.flink.connector.base.sink.writer.BufferedRequestState extends Object implements Serializable
  - Serialized Fields
    - bufferedRequestEntries
```
List<E> bufferedRequestEntries
```
    - stateSize
```
long stateSize
```
Package org.apache.flink.connector.base.source.hybrid
- Class org.apache.flink.connector.base.source.hybrid.HybridSource extends Object implements Serializable
  - Serialized Fields
    - sources
```
List<E> sources
```
- Class org.apache.flink.connector.base.source.hybrid.HybridSource.HybridSourceBuilder extends Object implements Serializable
  - Serialized Fields
    - sources
```
List<E> sources
```
- Class org.apache.flink.connector.base.source.hybrid.SourceReaderFinishedEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - sourceIndex
```
int sourceIndex
```
- Class org.apache.flink.connector.base.source.hybrid.SwitchSourceEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - sourceIndex
```
int sourceIndex
```
    - source
```
Source<T,SplitT extends SourceSplit,EnumChkT> source
```
    - finalSource
```
boolean finalSource
```
Package org.apache.flink.connector.datagen.table.types
- Class org.apache.flink.connector.datagen.table.types.DataGeneratorMapper extends Object implements Serializable
  - Serialized Fields
    - generator
```
DataGenerator<T> generator
```
    - mapper
```
SerializableFunction<T,R> mapper
```
- Class org.apache.flink.connector.datagen.table.types.DecimalDataRandomGenerator extends Object implements Serializable
  - Serialized Fields
    - precision
```
int precision
```
    - scale
```
int scale
```
    - min
```
double min
```
    - max
```
double max
```
- Class org.apache.flink.connector.datagen.table.types.RowDataGenerator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldGenerators
```
DataGenerator<T>[] fieldGenerators
```
    - fieldNames
```
List<E> fieldNames
```
Package org.apache.flink.connector.elasticsearch.sink
- Class org.apache.flink.connector.elasticsearch.sink.ElasticsearchSink extends Object implements Serializable
  - Serialized Fields
    - hosts
```
List<E> hosts
```
    - emitter
```
ElasticsearchEmitter<T> emitter
```
    - buildBulkProcessorConfig
```
org.apache.flink.connector.elasticsearch.sink.BulkProcessorConfig buildBulkProcessorConfig
```
    - bulkProcessorBuilderFactory
```
org.apache.flink.connector.elasticsearch.sink.BulkProcessorBuilderFactory bulkProcessorBuilderFactory
```
    - networkClientConfig
```
org.apache.flink.connector.elasticsearch.sink.NetworkClientConfig networkClientConfig
```
    - deliveryGuarantee
```
DeliveryGuarantee deliveryGuarantee
```
- Class org.apache.flink.connector.elasticsearch.sink.MapElasticsearchEmitter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - index
```
String index
```
    - documentType
```
String documentType
```
    - idFieldName
```
String idFieldName
```
    - isDynamicIndex
```
boolean isDynamicIndex
```
Package org.apache.flink.connector.elasticsearch.table
- Class org.apache.flink.connector.elasticsearch.table.IndexGeneratorBase extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - index
```
String index
```
Package org.apache.flink.connector.file.sink
- Class org.apache.flink.connector.file.sink.FileSink extends Object implements Serializable
  - Serialized Fields
    - bucketsBuilder
```
org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,T extends org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,T>> bucketsBuilder
```
- Class org.apache.flink.connector.file.sink.FileSink.BulkFormatBuilder extends org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,T extends FileSink.BulkFormatBuilder<IN,T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - basePath
```
Path basePath
```
    - bucketCheckInterval
```
long bucketCheckInterval
```
    - writerFactory
```
BulkWriter.Factory<T> writerFactory
```
    - bucketFactory
```
FileWriterBucketFactory<IN> bucketFactory
```
    - bucketAssigner
```
BucketAssigner<IN,BucketID> bucketAssigner
```
    - rollingPolicy
```
CheckpointRollingPolicy<IN,BucketID> rollingPolicy
```
    - outputFileConfig
```
OutputFileConfig outputFileConfig
```
    - isCompactDisabledExplicitly
```
boolean isCompactDisabledExplicitly
```
    - compactStrategy
```
FileCompactStrategy compactStrategy
```
    - fileCompactor
```
FileCompactor fileCompactor
```
- Class org.apache.flink.connector.file.sink.FileSink.DefaultBulkFormatBuilder extends FileSink.BulkFormatBuilder<IN,FileSink.DefaultBulkFormatBuilder<IN>> implements Serializable
  
  serialVersionUID:
  
  7493169281036370228L
- Class org.apache.flink.connector.file.sink.FileSink.DefaultRowFormatBuilder extends FileSink.RowFormatBuilder<IN,FileSink.DefaultRowFormatBuilder<IN>> implements Serializable
  
  serialVersionUID:
  
  -8503344257202146718L
- Class org.apache.flink.connector.file.sink.FileSink.RowFormatBuilder extends org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,T extends FileSink.RowFormatBuilder<IN,T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - basePath
```
Path basePath
```
    - bucketCheckInterval
```
long bucketCheckInterval
```
    - encoder
```
Encoder<IN> encoder
```
    - bucketFactory
```
FileWriterBucketFactory<IN> bucketFactory
```
    - bucketAssigner
```
BucketAssigner<IN,BucketID> bucketAssigner
```
    - rollingPolicy
```
RollingPolicy<IN,BucketID> rollingPolicy
```
    - outputFileConfig
```
OutputFileConfig outputFileConfig
```
    - isCompactDisabledExplicitly
```
boolean isCompactDisabledExplicitly
```
    - compactStrategy
```
FileCompactStrategy compactStrategy
```
    - fileCompactor
```
FileCompactor fileCompactor
```
- Class org.apache.flink.connector.file.sink.FileSinkCommittable extends Object implements Serializable
  - Serialized Fields
    - bucketId
```
String bucketId
```
    - pendingFile
```
InProgressFileWriter.PendingFileRecoverable pendingFile
```
    - inProgressFileToCleanup
```
InProgressFileWriter.InProgressFileRecoverable inProgressFileToCleanup
```
    - compactedFileToCleanup
```
Path compactedFileToCleanup
```
- Class org.apache.flink.connector.file.sink.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 org.apache.flink.connector.file.sink.FileSinkProgram.KeyBucketAssigner extends Object implements Serializable
  
  serialVersionUID:
  
  987325769970523326L
Package org.apache.flink.connector.file.sink.compactor
- Class org.apache.flink.connector.file.sink.compactor.ConcatFileCompactor extends OutputStreamBasedFileCompactor implements Serializable
  - Serialized Fields
    - fileDelimiter
```
byte[] fileDelimiter
```
- Class org.apache.flink.connector.file.sink.compactor.DecoderBasedReader.Factory extends Object implements Serializable
  - Serialized Fields
    - decoderFactory
```
DecoderBasedReader.Decoder.Factory<T> decoderFactory
```
- Class org.apache.flink.connector.file.sink.compactor.FileCompactStrategy extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - sizeThreshold
```
long sizeThreshold
```
    - numCheckpointsBeforeCompaction
```
int numCheckpointsBeforeCompaction
```
    - numCompactThreads
```
int numCompactThreads
```
- Class org.apache.flink.connector.file.sink.compactor.IdenticalFileCompactor extends ConcatFileCompactor implements Serializable
- Class org.apache.flink.connector.file.sink.compactor.InputFormatBasedReader.Factory extends Object implements Serializable
  - Serialized Fields
    - inputFormatFactory
```
SerializableSupplierWithException<T,E extends Throwable> inputFormatFactory
```
- Class org.apache.flink.connector.file.sink.compactor.OutputStreamBasedFileCompactor extends Object implements Serializable
- Class org.apache.flink.connector.file.sink.compactor.RecordWiseFileCompactor extends Object implements Serializable
  - Serialized Fields
    - readerFactory
```
RecordWiseFileCompactor.Reader.Factory<T> readerFactory
```
- Class org.apache.flink.connector.file.sink.compactor.SimpleStringDecoder extends Object implements Serializable
  - Serialized Fields
    - reader
```
BufferedReader reader
```
Package org.apache.flink.connector.file.sink.compactor.operator
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinator extends AbstractStreamOperator<CompactorRequest> implements Serializable
  - Serialized Fields
    - strategy
```
FileCompactStrategy strategy
```
    - committableSerializer
```
SimpleVersionedSerializer<E> committableSerializer
```
    - packingRequests
```
Map<K,V> packingRequests
```
    - triggers
```
Map<K,V> triggers
```
    - remainingCommittableState
```
ListState<T> remainingCommittableState
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinatorFactory extends AbstractStreamOperatorFactory<CompactorRequest> implements Serializable
  - Serialized Fields
    - strategy
```
FileCompactStrategy strategy
```
    - committableSerializerSupplier
```
SerializableSupplierWithException<T,E extends Throwable> committableSerializerSupplier
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinatorStateHandler extends AbstractStreamOperator<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>> implements Serializable
  - Serialized Fields
    - committableSerializer
```
SimpleVersionedSerializer<E> committableSerializer
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinatorStateHandlerFactory extends AbstractStreamOperatorFactory<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>> implements Serializable
  - Serialized Fields
    - committableSerializerSupplier
```
SerializableSupplierWithException<T,E extends Throwable> committableSerializerSupplier
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorOperator extends AbstractStreamOperator<CommittableMessage<FileSinkCommittable>> implements Serializable
  - Serialized Fields
    - strategy
```
FileCompactStrategy strategy
```
    - committableSerializer
```
SimpleVersionedSerializer<E> committableSerializer
```
    - fileCompactor
```
FileCompactor fileCompactor
```
    - bucketWriter
```
BucketWriter<IN,BucketID> bucketWriter
```
    - collectingRequests
```
List<E> collectingRequests
```
    - checkpointRequests
```
TreeMap<K,V> checkpointRequests
```
    - compactingRequests
```
List<E> compactingRequests
```
    - remainingRequestsState
```
ListState<T> remainingRequestsState
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorFactory extends AbstractStreamOperatorFactory<CommittableMessage<FileSinkCommittable>> implements Serializable
  - Serialized Fields
    - strategy
```
FileCompactStrategy strategy
```
    - fileCompactor
```
FileCompactor fileCompactor
```
    - committableSerializerSupplier
```
SerializableSupplierWithException<T,E extends Throwable> committableSerializerSupplier
```
    - bucketWriterProvider
```
SerializableSupplierWithException<T,E extends Throwable> bucketWriterProvider
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandler extends AbstractStreamOperator<CommittableMessage<FileSinkCommittable>> implements Serializable
  - Serialized Fields
    - committableSerializer
```
SimpleVersionedSerializer<E> committableSerializer
```
    - bucketWriter
```
BucketWriter<IN,BucketID> bucketWriter
```
    - compactingRequests
```
List<E> compactingRequests
```
    - remainingRequestsState
```
SimpleVersionedListState<T> remainingRequestsState
```
    - stateRemaining
```
Iterable<T> stateRemaining
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandlerFactory extends AbstractStreamOperatorFactory<CommittableMessage<FileSinkCommittable>> implements Serializable
  - Serialized Fields
    - committableSerializerSupplier
```
SerializableSupplierWithException<T,E extends Throwable> committableSerializerSupplier
```
    - bucketWriterProvider
```
SerializableSupplierWithException<T,E extends Throwable> bucketWriterProvider
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest extends Object implements Serializable
  - Serialized Fields
    - bucketId
```
String bucketId
```
    - committableToCompact
```
List<E> committableToCompact
```
    - committableToPassthrough
```
List<E> committableToPassthrough
```
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorRequestTypeInfo extends TypeInformation<CompactorRequest> implements Serializable
  - Serialized Fields
    - committableSerializerSupplier
```
SerializableSupplierWithException<T,E extends Throwable> committableSerializerSupplier
```
Package org.apache.flink.connector.file.sink.writer
- Class org.apache.flink.connector.file.sink.writer.DefaultFileWriterBucketFactory extends Object implements Serializable
Package org.apache.flink.connector.file.src
- Class org.apache.flink.connector.file.src.AbstractFileSource extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - inputPaths
```
Path[] inputPaths
```
    - enumeratorFactory
```
FileEnumerator.Provider enumeratorFactory
```
    - assignerFactory
```
FileSplitAssigner.Provider assignerFactory
```
    - readerFormat
```
BulkFormat<T,SplitT extends FileSourceSplit> readerFormat
```
    - continuousEnumerationSettings
```
ContinuousEnumerationSettings continuousEnumerationSettings
```
- Class org.apache.flink.connector.file.src.ContinuousEnumerationSettings extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - discoveryInterval
```
java.time.Duration discoveryInterval
```
- Class org.apache.flink.connector.file.src.FileSource extends AbstractFileSource<T,FileSourceSplit> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.file.src.FileSourceSplit extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - id
```
String id
```
      The unique ID of the split. Unique within the scope of this source.
    - filePath
```
Path filePath
```
      The path of the file referenced by this split.
    - offset
```
long offset
```
      The position of the first byte in the file to process.
    - length
```
long length
```
      The number of bytes in the file to process.
    - fileModificationTime
```
long fileModificationTime
```
      The modification time of the file, from FileStatus.getModificationTime().
    - fileSize
```
long fileSize
```
      The file size in bytes, from FileStatus.getLen().
    - hostnames
```
String[] hostnames
```
      The names of the hosts storing this range of the file. Empty, if no host information is available.
    - readerPosition
```
CheckpointedPosition readerPosition
```
      The precise reader position in the split, to resume from.
Package org.apache.flink.connector.file.src.assigners
Package org.apache.flink.connector.file.src.enumerate
Package org.apache.flink.connector.file.src.impl
- Class org.apache.flink.connector.file.src.impl.FileRecordFormatAdapter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fileFormat
```
FileRecordFormat<T> fileFormat
```
      Deprecated.
- Class org.apache.flink.connector.file.src.impl.StreamFormatAdapter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - streamFormat
```
StreamFormat<T> streamFormat
```
Package org.apache.flink.connector.file.src.reader
- Class org.apache.flink.connector.file.src.reader.SimpleStreamFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.file.src.reader.TextLineFormat extends TextLineInputFormat implements Serializable
- Class org.apache.flink.connector.file.src.reader.TextLineInputFormat extends SimpleStreamFormat<String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - charsetName
```
String charsetName
```
Package org.apache.flink.connector.file.src.util
- Class org.apache.flink.connector.file.src.util.CheckpointedPosition extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - offset
```
long offset
```
    - recordsAfterOffset
```
long recordsAfterOffset
```
Package org.apache.flink.connector.file.table
- Class org.apache.flink.connector.file.table.DefaultPartTimeExtractor extends Object implements Serializable
  - Serialized Fields
    - extractorPattern
```
String extractorPattern
```
    - formatterPattern
```
String formatterPattern
```
- Class org.apache.flink.connector.file.table.DeserializationSchemaAdapter extends Object implements Serializable
  - Serialized Fields
    - deserializationSchema
```
DeserializationSchema<T> deserializationSchema
```
- Class org.apache.flink.connector.file.table.EmptyMetaStoreFactory extends Object implements Serializable
  - Serialized Fields
    - path
```
Path path
```
- Class org.apache.flink.connector.file.table.FileSystemOutputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fsFactory
```
FileSystemFactory fsFactory
```
    - msFactory
```
TableMetaStoreFactory msFactory
```
    - overwrite
```
boolean overwrite
```
    - isToLocal
```
boolean isToLocal
```
    - tmpPath
```
Path tmpPath
```
    - partitionColumns
```
String[] partitionColumns
```
    - dynamicGrouped
```
boolean dynamicGrouped
```
    - staticPartitions
```
LinkedHashMap<K,V> staticPartitions
```
    - computer
```
PartitionComputer<T> computer
```
    - formatFactory
```
OutputFormatFactory<T> formatFactory
```
    - outputFileConfig
```
OutputFileConfig outputFileConfig
```
    - identifier
```
ObjectIdentifier identifier
```
    - partitionCommitPolicyFactory
```
PartitionCommitPolicyFactory partitionCommitPolicyFactory
```
- Class org.apache.flink.connector.file.table.FileSystemTableSink.ProjectionBulkFactory extends Object implements Serializable
  - Serialized Fields
    - factory
```
BulkWriter.Factory<T> factory
```
    - computer
```
RowDataPartitionComputer computer
```
- Class org.apache.flink.connector.file.table.FileSystemTableSink.TableBucketAssigner extends Object implements Serializable
  - Serialized Fields
    - computer
```
PartitionComputer<T> computer
```
- Class org.apache.flink.connector.file.table.FileSystemTableSink.TableRollingPolicy extends CheckpointRollingPolicy<RowData,String> implements Serializable
  - Serialized Fields
    - rollOnCheckpoint
```
boolean rollOnCheckpoint
```
    - rollingFileSize
```
long rollingFileSize
```
    - rollingTimeInterval
```
long rollingTimeInterval
```
    - inactivityInterval
```
long inactivityInterval
```
- Class org.apache.flink.connector.file.table.LimitableBulkFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - format
```
BulkFormat<T,SplitT extends FileSourceSplit> format
```
    - limit
```
long limit
```
- Class org.apache.flink.connector.file.table.PartitionCommitPolicyFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - policyKind
```
String policyKind
```
    - customClass
```
String customClass
```
    - successFileName
```
String successFileName
```
- Class org.apache.flink.connector.file.table.RowDataPartitionComputer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - defaultPartValue
```
String defaultPartValue
```
    - partitionColumns
```
String[] partitionColumns
```
    - partitionIndexes
```
int[] partitionIndexes
```
    - partitionTypes
```
LogicalType[] partitionTypes
```
    - partitionFieldGetters
```
RowData.FieldGetter[] partitionFieldGetters
```
    - nonPartitionIndexes
```
int[] nonPartitionIndexes
```
    - nonPartitionTypes
```
LogicalType[] nonPartitionTypes
```
    - nonPartitionFieldGetters
```
RowData.FieldGetter[] nonPartitionFieldGetters
```
- Class org.apache.flink.connector.file.table.RowPartitionComputer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - defaultPartValue
```
String defaultPartValue
```
    - partitionColumns
```
String[] partitionColumns
```
    - nonPartitionIndexes
```
int[] nonPartitionIndexes
```
    - partitionIndexes
```
int[] partitionIndexes
```
- Class org.apache.flink.connector.file.table.SerializationSchemaAdapter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - serializationSchema
```
SerializationSchema<T> serializationSchema
```
Package org.apache.flink.connector.file.table.stream
- Class org.apache.flink.connector.file.table.stream.AbstractStreamingWriter extends AbstractStreamOperator<OUT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - bucketCheckInterval
```
long bucketCheckInterval
```
    - bucketsBuilder
```
StreamingFileSink.BucketsBuilder<IN,BucketID,T extends StreamingFileSink.BucketsBuilder<IN,BucketID,T>> bucketsBuilder
```
- Class org.apache.flink.connector.file.table.stream.PartitionCommitInfo extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - checkpointId
```
long checkpointId
```
    - taskId
```
int taskId
```
    - numberOfTasks
```
int numberOfTasks
```
    - partitions
```
List<E> partitions
```
- Class org.apache.flink.connector.file.table.stream.PartitionCommitter extends AbstractStreamOperator<Void> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - conf
```
Configuration conf
```
    - locationPath
```
Path locationPath
```
    - tableIdentifier
```
ObjectIdentifier tableIdentifier
```
    - partitionKeys
```
List<E> partitionKeys
```
    - metaStoreFactory
```
TableMetaStoreFactory metaStoreFactory
```
    - fsFactory
```
FileSystemFactory fsFactory
```
- Class org.apache.flink.connector.file.table.stream.StreamingFileWriter extends AbstractStreamingWriter<IN,PartitionCommitInfo> implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - partitionKeys
```
List<E> partitionKeys
```
    - conf
```
Configuration conf
```
Package org.apache.flink.connector.file.table.stream.compact
- Class org.apache.flink.connector.file.table.stream.compact.CompactCoordinator extends AbstractStreamOperator<CompactMessages.CoordinatorOutput> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fsFactory
```
SupplierWithException<R,E extends Throwable> fsFactory
```
    - targetFileSize
```
long targetFileSize
```
- Class org.apache.flink.connector.file.table.stream.compact.CompactFileWriter extends AbstractStreamingWriter<T,CompactMessages.CoordinatorInput> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.file.table.stream.compact.CompactMessages.CompactionUnit extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - unitId
```
int unitId
```
    - partition
```
String partition
```
    - pathStrings
```
String[] pathStrings
```
- Class org.apache.flink.connector.file.table.stream.compact.CompactMessages.EndCheckpoint extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - checkpointId
```
long checkpointId
```
    - taskId
```
int taskId
```
    - numberOfTasks
```
int numberOfTasks
```
- Class org.apache.flink.connector.file.table.stream.compact.CompactMessages.EndCompaction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - checkpointId
```
long checkpointId
```
- Class org.apache.flink.connector.file.table.stream.compact.CompactMessages.InputFile extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partition
```
String partition
```
    - file
```
Path file
```
- Class org.apache.flink.connector.file.table.stream.compact.CompactOperator extends AbstractStreamOperator<PartitionCommitInfo> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fsFactory
```
SupplierWithException<R,E extends Throwable> fsFactory
```
    - readerFactory
```
CompactReader.Factory<T> readerFactory
```
    - writerFactory
```
CompactWriter.Factory<T> writerFactory
```
Package org.apache.flink.connector.firehose.sink
- Class org.apache.flink.connector.firehose.sink.KinesisFirehoseSink extends AsyncSinkBase<InputT,software.amazon.awssdk.services.firehose.model.Record> implements Serializable
  - Serialized Fields
    - failOnError
```
boolean failOnError
```
    - deliveryStreamName
```
String deliveryStreamName
```
    - firehoseClientProperties
```
Properties firehoseClientProperties
```
- Class org.apache.flink.connector.firehose.sink.KinesisFirehoseSinkElementConverter extends Object implements Serializable
  - Serialized Fields
    - schemaOpened
```
boolean schemaOpened
```
    - serializationSchema
```
SerializationSchema<T> serializationSchema
```
      A serialization schema to specify how the input element should be serialized.
Package org.apache.flink.connector.hbase.options
- Class org.apache.flink.connector.hbase.options.HBaseWriteOptions extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - bufferFlushMaxSizeInBytes
```
long bufferFlushMaxSizeInBytes
```
    - bufferFlushMaxRows
```
long bufferFlushMaxRows
```
    - bufferFlushIntervalMillis
```
long bufferFlushIntervalMillis
```
    - parallelism
```
Integer parallelism
```
Package org.apache.flink.connector.hbase.sink
- Class org.apache.flink.connector.hbase.sink.HBaseSinkFunction extends RichSinkFunction<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hTableName
```
String hTableName
```
    - serializedConfig
```
byte[] serializedConfig
```
    - bufferFlushMaxSizeInBytes
```
long bufferFlushMaxSizeInBytes
```
    - bufferFlushMaxMutations
```
long bufferFlushMaxMutations
```
    - bufferFlushIntervalMillis
```
long bufferFlushIntervalMillis
```
    - mutationConverter
```
HBaseMutationConverter<T> mutationConverter
```
    - failureThrowable
```
AtomicReference<V> failureThrowable
```
      This is set from inside the BufferedMutator.ExceptionListener if a Throwable was thrown.
      Errors will be checked and rethrown before processing each input element, and when the sink is closed.
- Class org.apache.flink.connector.hbase.sink.RowDataToMutationConverter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - schema
```
HBaseTableSchema schema
```
    - nullStringLiteral
```
String nullStringLiteral
```
Package org.apache.flink.connector.hbase.source
- Class org.apache.flink.connector.hbase.source.HBaseRowDataLookupFunction extends LookupFunction implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hTableName
```
String hTableName
```
    - serializedConfig
```
byte[] serializedConfig
```
    - hbaseTableSchema
```
HBaseTableSchema hbaseTableSchema
```
    - nullStringLiteral
```
String nullStringLiteral
```
    - maxRetryTimes
```
int maxRetryTimes
```
- Class org.apache.flink.connector.hbase.source.TableInputSplit extends LocatableInputSplit implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableName
```
byte[] tableName
```
      The name of the table to retrieve data from.
    - startRow
```
byte[] startRow
```
      The start row of the split.
    - endRow
```
byte[] endRow
```
      The end row of the split.
Package org.apache.flink.connector.hbase.util
- Class org.apache.flink.connector.hbase.util.HBaseTableSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - familyMap
```
Map<K,V> familyMap
```
    - rowKeyInfo
```
org.apache.flink.connector.hbase.util.HBaseTableSchema.RowKeyInfo rowKeyInfo
```
    - charset
```
String charset
```
Package org.apache.flink.connector.hbase1.source
- Class org.apache.flink.connector.hbase1.source.AbstractTableInputFormat extends RichInputFormat<T,TableInputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - endReached
```
boolean endReached
```
    - resultScanner
```
org.apache.hadoop.hbase.client.ResultScanner resultScanner
```
      HBase iterator wrapper.
    - currentRow
```
byte[] currentRow
```
    - scannedRows
```
long scannedRows
```
    - serializedConfig
```
byte[] serializedConfig
```
- Class org.apache.flink.connector.hbase1.source.HBaseRowDataInputFormat extends AbstractTableInputFormat<RowData> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableName
```
String tableName
```
    - schema
```
HBaseTableSchema schema
```
    - nullStringLiteral
```
String nullStringLiteral
```
Package org.apache.flink.connector.hbase2.source
- Class org.apache.flink.connector.hbase2.source.AbstractTableInputFormat extends RichInputFormat<T,TableInputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - endReached
```
boolean endReached
```
    - resultScanner
```
org.apache.hadoop.hbase.client.ResultScanner resultScanner
```
      HBase iterator wrapper.
    - currentRow
```
byte[] currentRow
```
    - scannedRows
```
long scannedRows
```
    - serializedConfig
```
byte[] serializedConfig
```
- Class org.apache.flink.connector.hbase2.source.HBaseRowDataAsyncLookupFunction extends AsyncLookupFunction implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hTableName
```
String hTableName
```
    - serializedConfig
```
byte[] serializedConfig
```
    - hbaseTableSchema
```
HBaseTableSchema hbaseTableSchema
```
    - nullStringLiteral
```
String nullStringLiteral
```
    - maxRetryTimes
```
int maxRetryTimes
```
- Class org.apache.flink.connector.hbase2.source.HBaseRowDataInputFormat extends AbstractTableInputFormat<RowData> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableName
```
String tableName
```
    - schema
```
HBaseTableSchema schema
```
    - nullStringLiteral
```
String nullStringLiteral
```
Package org.apache.flink.connector.jdbc
- Class org.apache.flink.connector.jdbc.JdbcConnectionOptions extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - url
```
String url
```
    - driverName
```
String driverName
```
    - connectionCheckTimeoutSeconds
```
int connectionCheckTimeoutSeconds
```
    - username
```
String username
```
    - password
```
String password
```
- Class org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions extends Object implements Serializable
  - Serialized Fields
    - discoverAndRollbackOnRecovery
```
boolean discoverAndRollbackOnRecovery
```
    - maxCommitAttempts
```
int maxCommitAttempts
```
    - allowOutOfOrderCommits
```
boolean allowOutOfOrderCommits
```
    - timeoutSec
```
Integer timeoutSec
```
    - transactionPerConnection
```
boolean transactionPerConnection
```
- Class org.apache.flink.connector.jdbc.JdbcExecutionOptions extends Object implements Serializable
  - Serialized Fields
    - batchIntervalMs
```
long batchIntervalMs
```
    - batchSize
```
int batchSize
```
    - maxRetries
```
int maxRetries
```
- Class org.apache.flink.connector.jdbc.JdbcInputFormat extends RichInputFormat<Row,InputSplit> implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - connectionProvider
```
JdbcConnectionProvider connectionProvider
```
    - queryTemplate
```
String queryTemplate
```
    - resultSetType
```
int resultSetType
```
    - resultSetConcurrency
```
int resultSetConcurrency
```
    - rowTypeInfo
```
RowTypeInfo rowTypeInfo
```
    - fetchSize
```
int fetchSize
```
    - autoCommit
```
Boolean autoCommit
```
    - hasNext
```
boolean hasNext
```
    - parameterValues
```
Object[][] parameterValues
```
- Class org.apache.flink.connector.jdbc.JdbcRowOutputFormat extends JdbcOutputFormat<Row,Row,JdbcBatchStatementExecutor<Row>> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.connector.jdbc.converter
- Class org.apache.flink.connector.jdbc.converter.AbstractJdbcRowConverter extends Object implements Serializable
  - Serialized Fields
    - rowType
```
RowType rowType
```
    - toInternalConverters
```
AbstractJdbcRowConverter.JdbcDeserializationConverter[] toInternalConverters
```
    - toExternalConverters
```
AbstractJdbcRowConverter.JdbcSerializationConverter[] toExternalConverters
```
    - fieldTypes
```
LogicalType[] fieldTypes
```
Package org.apache.flink.connector.jdbc.dialect
- Class org.apache.flink.connector.jdbc.dialect.AbstractDialect extends Object implements Serializable
Package org.apache.flink.connector.jdbc.dialect.mysql
- Class org.apache.flink.connector.jdbc.dialect.mysql.MySqlDialect extends AbstractDialect implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.connector.jdbc.dialect.psql
- Class org.apache.flink.connector.jdbc.dialect.psql.PostgresDialect extends AbstractDialect implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.connector.jdbc.internal
- Class org.apache.flink.connector.jdbc.internal.GenericJdbcSinkFunction extends RichSinkFunction<T> implements Serializable
  - Serialized Fields
    - outputFormat
```
JdbcOutputFormat<In,JdbcIn,JdbcExec extends JdbcBatchStatementExecutor<JdbcIn>> outputFormat
```
- Class org.apache.flink.connector.jdbc.internal.JdbcOutputFormat extends RichOutputFormat<In> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - connectionProvider
```
JdbcConnectionProvider connectionProvider
```
    - serializer
```
TypeSerializer<T> serializer
```
    - executionOptions
```
JdbcExecutionOptions executionOptions
```
    - statementExecutorFactory
```
JdbcOutputFormat.StatementExecutorFactory<T extends JdbcBatchStatementExecutor<?>> statementExecutorFactory
```
    - jdbcRecordExtractor
```
JdbcOutputFormat.RecordExtractor<F,T> jdbcRecordExtractor
```
Package org.apache.flink.connector.jdbc.internal.connection
- Class org.apache.flink.connector.jdbc.internal.connection.SimpleJdbcConnectionProvider extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jdbcOptions
```
JdbcConnectionOptions jdbcOptions
```
Package org.apache.flink.connector.jdbc.internal.converter
- Class org.apache.flink.connector.jdbc.internal.converter.DerbyRowConverter extends AbstractJdbcRowConverter implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.jdbc.internal.converter.MySQLRowConverter extends AbstractJdbcRowConverter implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter extends AbstractJdbcRowConverter implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.jdbc.internal.converter.PostgresRowConverter extends AbstractJdbcRowConverter implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.connector.jdbc.internal.options
- Class org.apache.flink.connector.jdbc.internal.options.JdbcConnectorOptions extends JdbcConnectionOptions implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableName
```
String tableName
```
    - dialect
```
JdbcDialect dialect
```
    - parallelism
```
Integer parallelism
```
- Class org.apache.flink.connector.jdbc.internal.options.JdbcDmlOptions extends org.apache.flink.connector.jdbc.internal.options.JdbcTypedQueryOptions implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldNames
```
String[] fieldNames
```
    - keyFields
```
String[] keyFields
```
    - tableName
```
String tableName
```
    - dialect
```
JdbcDialect dialect
```
- Class org.apache.flink.connector.jdbc.internal.options.JdbcInsertOptions extends org.apache.flink.connector.jdbc.internal.options.JdbcTypedQueryOptions implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - query
```
String query
```
- Class org.apache.flink.connector.jdbc.internal.options.JdbcReadOptions extends Object implements Serializable
  - Serialized Fields
    - query
```
String query
```
    - partitionColumnName
```
String partitionColumnName
```
    - partitionLowerBound
```
Long partitionLowerBound
```
    - partitionUpperBound
```
Long partitionUpperBound
```
    - numPartitions
```
Integer numPartitions
```
    - fetchSize
```
int fetchSize
```
    - autoCommit
```
boolean autoCommit
```
Package org.apache.flink.connector.jdbc.table
- Class org.apache.flink.connector.jdbc.table.JdbcOutputFormatBuilder extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jdbcOptions
```
JdbcConnectorOptions jdbcOptions
```
    - executionOptions
```
JdbcExecutionOptions executionOptions
```
    - dmlOptions
```
JdbcDmlOptions dmlOptions
```
    - rowDataTypeInformation
```
TypeInformation<T> rowDataTypeInformation
```
    - fieldDataTypes
```
DataType[] fieldDataTypes
```
- Class org.apache.flink.connector.jdbc.table.JdbcRowDataInputFormat extends RichInputFormat<RowData,InputSplit> implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - connectionProvider
```
JdbcConnectionProvider connectionProvider
```
    - fetchSize
```
int fetchSize
```
    - autoCommit
```
Boolean autoCommit
```
    - parameterValues
```
Object[][] parameterValues
```
    - queryTemplate
```
String queryTemplate
```
    - resultSetType
```
int resultSetType
```
    - resultSetConcurrency
```
int resultSetConcurrency
```
    - rowConverter
```
JdbcRowConverter rowConverter
```
    - rowDataTypeInfo
```
TypeInformation<T> rowDataTypeInfo
```
- Class org.apache.flink.connector.jdbc.table.JdbcRowDataLookupFunction extends LookupFunction implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - query
```
String query
```
    - connectionProvider
```
JdbcConnectionProvider connectionProvider
```
    - keyNames
```
String[] keyNames
```
    - maxRetryTimes
```
int maxRetryTimes
```
    - jdbcRowConverter
```
JdbcRowConverter jdbcRowConverter
```
    - lookupKeyRowConverter
```
JdbcRowConverter lookupKeyRowConverter
```
Package org.apache.flink.connector.jdbc.xa
- Class org.apache.flink.connector.jdbc.xa.CheckpointAndXidSerializer extends TypeSerializer<CheckpointAndXid> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - xidSerializer
```
TypeSerializer<T> xidSerializer
```
- Class org.apache.flink.connector.jdbc.xa.JdbcXaSinkFunction extends AbstractRichFunction implements Serializable
  - Serialized Fields
    - xaFacade
```
XaFacade xaFacade
```
    - xaGroupOps
```
org.apache.flink.connector.jdbc.xa.XaGroupOps xaGroupOps
```
    - xidGenerator
```
XidGenerator xidGenerator
```
    - outputFormat
```
JdbcOutputFormat<In,JdbcIn,JdbcExec extends JdbcBatchStatementExecutor<JdbcIn>> outputFormat
```
    - stateHandler
```
org.apache.flink.connector.jdbc.xa.XaSinkStateHandler stateHandler
```
    - options
```
JdbcExactlyOnceOptions options
```
- Class org.apache.flink.connector.jdbc.xa.XaFacade.EmptyXaTransactionException extends FlinkRuntimeException implements Serializable
  - Serialized Fields
    - xid
```
Xid xid
```
- Class org.apache.flink.connector.jdbc.xa.XaFacade.TransientXaException extends FlinkRuntimeException implements Serializable
- Class org.apache.flink.connector.jdbc.xa.XaSinkStateSerializer extends TypeSerializer<org.apache.flink.connector.jdbc.xa.JdbcXaSinkFunctionState> implements Serializable
  - Serialized Fields
    - xidSerializer
```
TypeSerializer<T> xidSerializer
```
    - checkpointAndXidSerializer
```
TypeSerializer<T> checkpointAndXidSerializer
```
- Class org.apache.flink.connector.jdbc.xa.XidSerializer extends TypeSerializer<Xid> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.connector.kafka.sink
- Class org.apache.flink.connector.kafka.sink.KafkaSink extends Object implements Serializable
  - Serialized Fields
    - deliveryGuarantee
```
DeliveryGuarantee deliveryGuarantee
```
    - recordSerializer
```
KafkaRecordSerializationSchema<T> recordSerializer
```
    - kafkaProducerConfig
```
Properties kafkaProducerConfig
```
    - transactionalIdPrefix
```
String transactionalIdPrefix
```
Package org.apache.flink.connector.kafka.source
- Class org.apache.flink.connector.kafka.source.KafkaSource extends Object implements Serializable
  
  serialVersionUID:
  
  -8755372893283732098L
  - Serialized Fields
    - subscriber
```
KafkaSubscriber subscriber
```
    - startingOffsetsInitializer
```
OffsetsInitializer startingOffsetsInitializer
```
    - stoppingOffsetsInitializer
```
OffsetsInitializer stoppingOffsetsInitializer
```
    - boundedness
```
Boundedness boundedness
```
    - deserializationSchema
```
KafkaRecordDeserializationSchema<T> deserializationSchema
```
    - props
```
Properties props
```
Package org.apache.flink.connector.kafka.source.enumerator.initializer
- Class org.apache.flink.connector.kafka.source.enumerator.initializer.NoStoppingOffsetsInitializer extends Object implements Serializable
  
  serialVersionUID:
  
  4186323669290142732L
Package org.apache.flink.connector.kafka.source.enumerator.subscriber
Package org.apache.flink.connector.kafka.source.reader.deserializer
Package org.apache.flink.connector.kinesis.sink
- Class org.apache.flink.connector.kinesis.sink.KinesisStreamsSink extends AsyncSinkBase<InputT,software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry> implements Serializable
  - Serialized Fields
    - failOnError
```
boolean failOnError
```
    - streamName
```
String streamName
```
    - kinesisClientProperties
```
Properties kinesisClientProperties
```
- Class org.apache.flink.connector.kinesis.sink.KinesisStreamsSinkElementConverter extends Object implements Serializable
  - Serialized Fields
    - serializationSchema
```
SerializationSchema<T> serializationSchema
```
      A serialization schema to specify how the input element should be serialized.
    - partitionKeyGenerator
```
PartitionKeyGenerator<InputT> partitionKeyGenerator
```
      A partition key generator functional interface that produces a string from the input element.
    - schemaOpened
```
boolean schemaOpened
```
Package org.apache.flink.connector.kinesis.table
- Class org.apache.flink.connector.kinesis.table.FixedKinesisPartitionKeyGenerator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - indexOfThisSubtask
```
int indexOfThisSubtask
```
- Class org.apache.flink.connector.kinesis.table.RandomKinesisPartitionKeyGenerator extends Object implements Serializable
- Class org.apache.flink.connector.kinesis.table.RowDataFieldsKinesisPartitionKeyGenerator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - delimiter
```
String delimiter
```
      The character used to delimit field values in the concatenated partition key string.
    - fieldNames
```
List<E> fieldNames
```
      A list of field names used to extract the partition key for a record that will be written to a Kinesis stream.
    - dynamicFieldGetters
```
Map<K,V> dynamicFieldGetters
```
      A map of getter functions to dynamically extract the field values for all RowDataFieldsKinesisPartitionKeyGenerator.fieldNames from an input record.
    - keyBuffer
```
StringBuilder keyBuffer
```
      A buffer used to accumulate the concatenation of all field values that form the partition key.
    - staticFields
```
Map<K,V> staticFields
```
      A prefix of static field values to be used instead of the corresponding RowDataFieldsKinesisPartitionKeyGenerator.dynamicFieldGetters entries.
    - keyBufferStaticPrefixLength
```
int keyBufferStaticPrefixLength
```
      The length of the static prefix of the RowDataFieldsKinesisPartitionKeyGenerator.keyBuffer (derived from the values in RowDataFieldsKinesisPartitionKeyGenerator.staticFields).
    - fieldNamesStaticPrefixLength
```
int fieldNamesStaticPrefixLength
```
      The length of the prefix in RowDataFieldsKinesisPartitionKeyGenerator.fieldNames for which static field values are present in RowDataFieldsKinesisPartitionKeyGenerator.staticFields.
Package org.apache.flink.connector.pulsar.common.config
- Class org.apache.flink.connector.pulsar.common.config.PulsarConfiguration extends UnmodifiableConfiguration implements Serializable
  
  serialVersionUID:
  
  3050894147145572345L
Package org.apache.flink.connector.pulsar.common.schema
- Class org.apache.flink.connector.pulsar.common.schema.PulsarSchema extends Object implements Serializable
  
  serialVersionUID:
  
  -2561088131419607555L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream ois)
                 throws ClassNotFoundException,
                        IOException
```
      Throws:
      
      ClassNotFoundException
      
      IOException
    - writeObject
```
private void writeObject(ObjectOutputStream oos)
                  throws IOException
```
      Throws:
      
      IOException
- Class org.apache.flink.connector.pulsar.common.schema.PulsarSchemaTypeInformation extends TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  7284667318651333519L
  - Serialized Fields
    - schema
```
PulsarSchema<T> schema
```
- Class org.apache.flink.connector.pulsar.common.schema.PulsarSchemaTypeSerializer extends TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  7771153330969433085L
  - Serialized Fields
    - schema
```
PulsarSchema<T> schema
```
Package org.apache.flink.connector.pulsar.sink
- Class org.apache.flink.connector.pulsar.sink.PulsarSink extends Object implements Serializable
  
  serialVersionUID:
  
  4416714587951282119L
  - Serialized Fields
    - sinkConfiguration
```
SinkConfiguration sinkConfiguration
```
    - serializationSchema
```
PulsarSerializationSchema<IN> serializationSchema
```
    - metadataListener
```
TopicMetadataListener metadataListener
```
    - messageDelayer
```
MessageDelayer<IN> messageDelayer
```
    - topicRouter
```
TopicRouter<IN> topicRouter
```
Package org.apache.flink.connector.pulsar.sink.config
- Class org.apache.flink.connector.pulsar.sink.config.SinkConfiguration extends PulsarConfiguration implements Serializable
  
  serialVersionUID:
  
  4941360605051251153L
  - Serialized Fields
    - deliveryGuarantee
```
DeliveryGuarantee deliveryGuarantee
```
    - transactionTimeoutMillis
```
long transactionTimeoutMillis
```
    - topicMetadataRefreshInterval
```
long topicMetadataRefreshInterval
```
    - partitionSwitchSize
```
int partitionSwitchSize
```
    - messageKeyHash
```
MessageKeyHash messageKeyHash
```
    - enableSchemaEvolution
```
boolean enableSchemaEvolution
```
    - maxPendingMessages
```
int maxPendingMessages
```
    - maxRecommitTimes
```
int maxRecommitTimes
```
Package org.apache.flink.connector.pulsar.sink.writer.delayer
- Class org.apache.flink.connector.pulsar.sink.writer.delayer.FixedMessageDelayer extends Object implements Serializable
  
  serialVersionUID:
  
  -7550834520312097614L
  - Serialized Fields
    - delayDuration
```
long delayDuration
```
Package org.apache.flink.connector.pulsar.sink.writer.router
- Class org.apache.flink.connector.pulsar.sink.writer.router.KeyHashTopicRouter extends Object implements Serializable
  
  serialVersionUID:
  
  2475614648095079804L
  - Serialized Fields
    - messageKeyHash
```
MessageKeyHash messageKeyHash
```
- Class org.apache.flink.connector.pulsar.sink.writer.router.RoundRobinTopicRouter extends Object implements Serializable
  
  serialVersionUID:
  
  -1160533263474038206L
  - Serialized Fields
    - counter
```
AtomicLong counter
```
      The internal counter for counting the messages.
    - partitionSwitchSize
```
int partitionSwitchSize
```
      The size when we switch to another topic.
Package org.apache.flink.connector.pulsar.sink.writer.serializer
- Class org.apache.flink.connector.pulsar.sink.writer.serializer.PulsarSchemaWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  -2567052498398184194L
  - Serialized Fields
    - pulsarSchema
```
PulsarSchema<T> pulsarSchema
```
- Class org.apache.flink.connector.pulsar.sink.writer.serializer.PulsarSerializationSchemaWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  4948155843623161119L
  - Serialized Fields
    - serializationSchema
```
SerializationSchema<T> serializationSchema
```
Package org.apache.flink.connector.pulsar.sink.writer.topic
- Class org.apache.flink.connector.pulsar.sink.writer.topic.TopicMetadataListener extends Object implements Serializable
  
  serialVersionUID:
  
  6186948471557507522L
  - Serialized Fields
    - partitionedTopics
```
org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableList<E> partitionedTopics
```
    - topicMetadata
```
Map<K,V> topicMetadata
```
    - availableTopics
```
org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableList<E> availableTopics
```
Package org.apache.flink.connector.pulsar.source
- Class org.apache.flink.connector.pulsar.source.PulsarSource extends Object implements Serializable
  
  serialVersionUID:
  
  7773108631275567433L
  - Serialized Fields
    - sourceConfiguration
```
SourceConfiguration sourceConfiguration
```
      The configuration for pulsar source, we don't support the pulsar's configuration class directly.
    - subscriber
```
PulsarSubscriber subscriber
```
    - rangeGenerator
```
RangeGenerator rangeGenerator
```
    - startCursor
```
StartCursor startCursor
```
    - stopCursor
```
StopCursor stopCursor
```
    - boundedness
```
Boundedness boundedness
```
    - deserializationSchema
```
PulsarDeserializationSchema<T> deserializationSchema
```
      The pulsar deserialization schema used for deserializing message.
Package org.apache.flink.connector.pulsar.source.config
- Class org.apache.flink.connector.pulsar.source.config.SourceConfiguration extends PulsarConfiguration implements Serializable
  
  serialVersionUID:
  
  8488507275800787580L
  - Serialized Fields
    - messageQueueCapacity
```
int messageQueueCapacity
```
    - partitionDiscoveryIntervalMs
```
long partitionDiscoveryIntervalMs
```
    - enableAutoAcknowledgeMessage
```
boolean enableAutoAcknowledgeMessage
```
    - autoCommitCursorInterval
```
long autoCommitCursorInterval
```
    - transactionTimeoutMillis
```
long transactionTimeoutMillis
```
    - maxFetchTime
```
java.time.Duration maxFetchTime
```
    - maxFetchRecords
```
int maxFetchRecords
```
    - verifyInitialOffsets
```
CursorVerification verifyInitialOffsets
```
    - subscriptionName
```
String subscriptionName
```
    - subscriptionType
```
org.apache.pulsar.client.api.SubscriptionType subscriptionType
```
    - subscriptionMode
```
org.apache.pulsar.client.api.SubscriptionMode subscriptionMode
```
    - allowKeySharedOutOfOrderDelivery
```
boolean allowKeySharedOutOfOrderDelivery
```
Package org.apache.flink.connector.pulsar.source.enumerator.cursor
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.CursorPosition extends Object implements Serializable
  
  serialVersionUID:
  
  -802405183307684549L
  - Serialized Fields
    - type
```
CursorPosition.Type type
```
    - messageId
```
org.apache.pulsar.client.api.MessageId messageId
```
    - timestamp
```
Long timestamp
```
Package org.apache.flink.connector.pulsar.source.enumerator.cursor.start
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.start.MessageIdStartCursor extends Object implements Serializable
  
  serialVersionUID:
  
  -8057345435887170111L
  - Serialized Fields
    - messageId
```
org.apache.pulsar.client.api.MessageId messageId
```
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.start.TimestampStartCursor extends Object implements Serializable
  
  serialVersionUID:
  
  5170578885838095320L
  - Serialized Fields
    - timestamp
```
long timestamp
```
Package org.apache.flink.connector.pulsar.source.enumerator.cursor.stop
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.stop.EventTimestampStopCursor extends Object implements Serializable
  
  serialVersionUID:
  
  2391576769339369027L
  - Serialized Fields
    - timestamp
```
long timestamp
```
    - inclusive
```
boolean inclusive
```
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.stop.LatestMessageStopCursor extends Object implements Serializable
  
  serialVersionUID:
  
  1702059838323965723L
  - Serialized Fields
    - messageId
```
org.apache.pulsar.client.api.MessageId messageId
```
    - inclusive
```
boolean inclusive
```
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.stop.MessageIdStopCursor extends Object implements Serializable
  
  serialVersionUID:
  
  -3990454110809274542L
  - Serialized Fields
    - messageId
```
org.apache.pulsar.client.api.MessageId messageId
```
    - inclusive
```
boolean inclusive
```
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.stop.NeverStopCursor extends Object implements Serializable
  
  serialVersionUID:
  
  -3113601090292771786L
- Class org.apache.flink.connector.pulsar.source.enumerator.cursor.stop.PublishTimestampStopCursor extends Object implements Serializable
  
  serialVersionUID:
  
  4386276745339324527L
  - Serialized Fields
    - timestamp
```
long timestamp
```
    - inclusive
```
boolean inclusive
```
Package org.apache.flink.connector.pulsar.source.enumerator.subscriber
Package org.apache.flink.connector.pulsar.source.enumerator.subscriber.impl
- Class org.apache.flink.connector.pulsar.source.enumerator.subscriber.impl.BasePulsarSubscriber extends Object implements Serializable
  
  serialVersionUID:
  
  2053021503331058888L
- Class org.apache.flink.connector.pulsar.source.enumerator.subscriber.impl.TopicListSubscriber extends BasePulsarSubscriber implements Serializable
  
  serialVersionUID:
  
  6473918213832993116L
  - Serialized Fields
    - partitions
```
List<E> partitions
```
    - fullTopicNames
```
List<E> fullTopicNames
```
- Class org.apache.flink.connector.pulsar.source.enumerator.subscriber.impl.TopicPatternSubscriber extends BasePulsarSubscriber implements Serializable
  
  serialVersionUID:
  
  3307710093243745104L
  - Serialized Fields
    - topicPattern
```
Pattern topicPattern
```
    - subscriptionMode
```
org.apache.pulsar.client.api.RegexSubscriptionMode subscriptionMode
```
    - namespace
```
String namespace
```
Package org.apache.flink.connector.pulsar.source.enumerator.topic
- Class org.apache.flink.connector.pulsar.source.enumerator.topic.TopicPartition extends Object implements Serializable
  
  serialVersionUID:
  
  -1474354741550810953L
  - Serialized Fields
    - topic
```
String topic
```
      The topic name of the pulsar. It would be a full topic name. If you don't provide the tenant and namespace, we would add them automatically.
    - partitionId
```
int partitionId
```
      Index of partition for the topic. It would be a natural number for the partitioned topic with a non-key_shared subscription.
    - ranges
```
List<E> ranges
```
      The ranges for this topic, used for limiting consume scope. It would be a TopicRange.createFullRange() full range for all the subscription type except SubscriptionType.Key_Shared.
    - mode
```
RangeGenerator.KeySharedMode mode
```
      The key share mode for the SubscriptionType.Key_Shared. It will be RangeGenerator.KeySharedMode.JOIN for other subscriptions.
- Class org.apache.flink.connector.pulsar.source.enumerator.topic.TopicRange extends Object implements Serializable
  
  serialVersionUID:
  
  3176938692775594400L
  - Serialized Fields
    - start
```
int start
```
      The start of the range, default is zero.
    - end
```
int end
```
      The end of the range, included.
Package org.apache.flink.connector.pulsar.source.enumerator.topic.range
- Class org.apache.flink.connector.pulsar.source.enumerator.topic.range.FixedKeysRangeGenerator extends Object implements Serializable
  
  serialVersionUID:
  
  2372969466289052100L
  - Serialized Fields
    - ranges
```
List<E> ranges
```
    - sharedMode
```
RangeGenerator.KeySharedMode sharedMode
```
- Class org.apache.flink.connector.pulsar.source.enumerator.topic.range.FixedRangeGenerator extends Object implements Serializable
  
  serialVersionUID:
  
  -3895203007855538734L
  - Serialized Fields
    - ranges
```
List<E> ranges
```
    - sharedMode
```
RangeGenerator.KeySharedMode sharedMode
```
- Class org.apache.flink.connector.pulsar.source.enumerator.topic.range.FullRangeGenerator extends Object implements Serializable
  
  serialVersionUID:
  
  -4571731955155036216L
- Class org.apache.flink.connector.pulsar.source.enumerator.topic.range.SplitRangeGenerator extends Object implements Serializable
  
  serialVersionUID:
  
  -8682286436352905249L
  - Serialized Fields
    - start
```
int start
```
    - end
```
int end
```
Package org.apache.flink.connector.pulsar.source.reader.deserializer
- Class org.apache.flink.connector.pulsar.source.reader.deserializer.PulsarTypeInformationWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  6647084180084963022L
  - Serialized Fields
    - information
```
TypeInformation<T> information
```
    - serializer
```
TypeSerializer<T> serializer
```
Package org.apache.flink.connector.pulsar.source.split
- Class org.apache.flink.connector.pulsar.source.split.PulsarPartitionSplit extends Object implements Serializable
  
  serialVersionUID:
  
  -6857317360756062625L
  - Serialized Fields
    - partition
```
TopicPartition partition
```
    - stopCursor
```
StopCursor stopCursor
```
    - latestConsumedId
```
org.apache.pulsar.client.api.MessageId latestConsumedId
```
      Since this field in only used in PulsarOrderedSourceReader.snapshotState(long), it's no need to serialize this field into flink checkpoint state.
    - uncommittedTransactionId
```
org.apache.pulsar.client.api.transaction.TxnID uncommittedTransactionId
```
Package org.apache.flink.connector.testframe.container
- Class org.apache.flink.connector.testframe.container.ImageBuildException extends Exception implements Serializable
Package org.apache.flink.connector.testframe.source
- Class org.apache.flink.connector.testframe.source.FromElementsSource extends Object implements Serializable
  - Serialized Fields
    - boundedness
```
Boundedness boundedness
```
    - elements
```
List<E> elements
```
    - emittedElementsNum
```
Integer emittedElementsNum
```
Package org.apache.flink.connector.upserttest.sink
- Class org.apache.flink.connector.upserttest.sink.UpsertTestSink extends Object implements Serializable
  - Serialized Fields
    - outputFile
```
File outputFile
```
    - keySerializationSchema
```
SerializationSchema<T> keySerializationSchema
```
    - valueSerializationSchema
```
SerializationSchema<T> valueSerializationSchema
```
Package org.apache.flink.connectors.hive
- Class org.apache.flink.connectors.hive.CachedSerializedValue extends SerializedValue<T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connectors.hive.FileSystemLookupFunction extends TableFunction<RowData> implements Serializable
  - Serialized Fields
    - partitionFetcher
```
PartitionFetcher<P> partitionFetcher
```
    - fetcherContext
```
PartitionFetcher.Context<P> fetcherContext
```
    - partitionReader
```
PartitionReader<P,OUT> partitionReader
```
    - lookupFieldGetters
```
RowData.FieldGetter[] lookupFieldGetters
```
    - reloadInterval
```
java.time.Duration reloadInterval
```
    - serializer
```
TypeSerializer<T> serializer
```
    - rowType
```
RowType rowType
```
- Class org.apache.flink.connectors.hive.FlinkHiveException extends RuntimeException implements Serializable
- Class org.apache.flink.connectors.hive.HadoopFileSystemFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
- Class org.apache.flink.connectors.hive.HiveRowDataPartitionComputer extends RowDataPartitionComputer implements Serializable
  - Serialized Fields
    - partitionConverters
```
DataFormatConverters.DataFormatConverter<Internal,External>[] partitionConverters
```
    - hiveObjectConversions
```
HiveObjectConversion[] hiveObjectConversions
```
- Class org.apache.flink.connectors.hive.HiveRowPartitionComputer extends RowPartitionComputer implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partColConversions
```
HiveObjectConversion[] partColConversions
```
- Class org.apache.flink.connectors.hive.HiveSource extends AbstractFileSource<T,HiveSourceSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
    - partitionKeys
```
List<E> partitionKeys
```
    - hiveVersion
```
String hiveVersion
```
    - dynamicFilterPartitionKeys
```
List<E> dynamicFilterPartitionKeys
```
    - partitions
```
List<E> partitions
```
    - 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.HiveSourceDynamicFileEnumerator.Provider extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - table
```
String table
```
    - dynamicFilterPartitionKeys
```
List<E> dynamicFilterPartitionKeys
```
    - partitions
```
List<E> partitions
```
    - hiveVersion
```
String hiveVersion
```
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
- 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
```
    - fileSystemFactory
```
FileSystemFactory fileSystemFactory
```
    - hiveVersion
```
String hiveVersion
```
    - database
```
String database
```
    - tableName
```
String tableName
```
    - autoGatherStatistic
```
boolean autoGatherStatistic
```
    - successFileName
```
String successFileName
```
    - gatherStatsThreadNum
```
int gatherStatsThreadNum
```
    - executorService
```
ExecutorService executorService
```
- Class org.apache.flink.connectors.hive.HiveTablePartition extends Object implements Serializable
  
  serialVersionUID:
  
  4145470177119940673L
  - Serialized Fields
    - storageDescriptor
```
CachedSerializedValue<T> storageDescriptor
```
      Partition storage descriptor.
    - partitionSpec
```
Map<K,V> partitionSpec
```
      The map of partition key names and their values.
    - tableProps
```
Properties tableProps
```
- Class org.apache.flink.connectors.hive.HiveTableSource.HiveContinuousPartitionFetcherContext extends HivePartitionFetcherContextBase<org.apache.hadoop.hive.metastore.api.Partition> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - typeSerializer
```
TypeSerializer<T> typeSerializer
```
    - consumeStartOffset
```
Comparable<T> consumeStartOffset
```
- Class org.apache.flink.connectors.hive.JobConfWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
Package org.apache.flink.connectors.hive.read
- Class org.apache.flink.connectors.hive.read.HiveBulkFormatAdapter extends HiveInputFormat implements Serializable
- Class org.apache.flink.connectors.hive.read.HiveCompactReaderFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - sd
```
CachedSerializedValue<T> sd
```
    - properties
```
Properties properties
```
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
    - partitionKeys
```
List<E> partitionKeys
```
    - fieldNames
```
String[] fieldNames
```
    - fieldTypes
```
DataType[] fieldTypes
```
    - hiveVersion

Back to Flink Website

Serialized Form

Package com.google.protobuf

Class com.google.protobuf.Any extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

cachedUnpackValue

typeUrl_

value_

memoizedIsInitialized

Class com.google.protobuf.Api extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

name_

methods_

options_

version_

sourceContext_

mixins_

syntax_

memoizedIsInitialized

Class com.google.protobuf.BoolValue extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

value_

memoizedIsInitialized

Class com.google.protobuf.ByteString extends Object implements Serializable

Serialized Fields

hash

Class com.google.protobuf.BytesValue extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

value_

memoizedIsInitialized

Class com.google.protobuf.CodedOutputStream.OutOfSpaceException extends IOException implements Serializable

Class com.google.protobuf.DescriptorProtos.DescriptorProto extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

bitField0_

name_

field_

extension_

nestedType_

enumType_

extensionRange_

oneofDecl_

options_

reservedRange_

reservedName_

memoizedIsInitialized

Class com.google.protobuf.DescriptorProtos.DescriptorProto.ExtensionRange extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

bitField0_

start_

end_

options_

memoizedIsInitialized

Class com.google.protobuf.DescriptorProtos.DescriptorProto.ReservedRange extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

bitField0_

start_

end_

memoizedIsInitialized

Class com.google.protobuf.DescriptorProtos.EnumDescriptorProto extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

bitField0_

name_

value_

options_

reservedRange_

reservedName_

memoizedIsInitialized

Class com.google.protobuf.DescriptorProtos.EnumDescriptorProto.EnumReservedRange extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

bitField0_

start_

end_

memoizedIsInitialized

Class com.google.protobuf.DescriptorProtos.EnumOptions extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<com.google.protobuf.DescriptorProtos.EnumOptions> implements Serializable

Serialized Fields

bitField0_

allowAlias_

deprecated_

uninterpretedOption_

memoizedIsInitialized