Serialized Form (flink-avro 1.6.0 API)

Package org.apache.flink.api.java.typeutils
- Class org.apache.flink.api.java.typeutils.AvroTypeInfo extends org.apache.flink.api.java.typeutils.PojoTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase> implements Serializable
- Class org.apache.flink.api.java.typeutils.EitherTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Either<L,R>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - leftType
```
org.apache.flink.api.common.typeinfo.TypeInformation<T> leftType
```
    - rightType
```
org.apache.flink.api.common.typeinfo.TypeInformation<T> rightType
```
- Class org.apache.flink.api.java.typeutils.EnumTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<T extends Enum<T>> implements Serializable
  
  serialVersionUID:
  
  8936740290137178660L
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
- Class org.apache.flink.api.java.typeutils.GenericTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  -7959114120287706504L
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
- Class org.apache.flink.api.java.typeutils.ListTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<List<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - elementTypeInfo
```
org.apache.flink.api.common.typeinfo.TypeInformation<T> elementTypeInfo
```
- Class org.apache.flink.api.java.typeutils.MapTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<Map<K,V>> implements Serializable
  - Serialized Fields
    - keyTypeInfo
```
org.apache.flink.api.common.typeinfo.TypeInformation<T> keyTypeInfo
```
    - valueTypeInfo
```
org.apache.flink.api.common.typeinfo.TypeInformation<T> valueTypeInfo
```
- Class org.apache.flink.api.java.typeutils.MissingTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.api.common.functions.InvalidTypesException> implements Serializable
  
  serialVersionUID:
  
  -4212082837126702723L
  - Serialized Fields
    - functionName
```
String functionName
```
    - typeException
```
org.apache.flink.api.common.functions.InvalidTypesException typeException
```
- Class org.apache.flink.api.java.typeutils.MultisetTypeInfo extends org.apache.flink.api.java.typeutils.MapTypeInfo<T,Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.ObjectArrayTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - arrayType
```
Class<T> arrayType
```
    - componentInfo
```
org.apache.flink.api.common.typeinfo.TypeInformation<T> componentInfo
```
- Class org.apache.flink.api.java.typeutils.PojoField extends Object implements Serializable
  
  serialVersionUID:
  
  1975295846436559363L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream arg0)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream arg0)
                  throws IOException,
                         ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - type
```
org.apache.flink.api.common.typeinfo.TypeInformation<T> type
```
- Class org.apache.flink.api.java.typeutils.PojoTypeInfo extends org.apache.flink.api.common.typeutils.CompositeType<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fields
```
org.apache.flink.api.java.typeutils.PojoField[] fields
```
    - totalFields
```
int totalFields
```
- Class org.apache.flink.api.java.typeutils.RowTypeInfo extends org.apache.flink.api.java.typeutils.TupleTypeInfoBase<org.apache.flink.types.Row> implements Serializable
  
  serialVersionUID:
  
  9158518989896601963L
  - Serialized Fields
    - fieldNames
```
String[] fieldNames
```
    - comparatorOrders
```
boolean[] comparatorOrders
```
- Class org.apache.flink.api.java.typeutils.TupleTypeInfo extends org.apache.flink.api.java.typeutils.TupleTypeInfoBase<T extends org.apache.flink.api.java.tuple.Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldNames
```
String[] fieldNames
```
- Class org.apache.flink.api.java.typeutils.TupleTypeInfoBase extends org.apache.flink.api.common.typeutils.CompositeType<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - types
```
org.apache.flink.api.common.typeinfo.TypeInformation<T>[] types
```
    - totalFields
```
int totalFields
```
- Class org.apache.flink.api.java.typeutils.TypeExtractionException extends Exception implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.ValueTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<T extends org.apache.flink.types.Value> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
Package org.apache.flink.api.java.typeutils.runtime
- Class org.apache.flink.api.java.typeutils.runtime.AvroSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Deprecated.
      
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - type
```
Class<T> type
```
      Deprecated.
    - typeToInstantiate
```
Class<T> typeToInstantiate
```
      Deprecated.
    - kryoRegistrations
```
LinkedHashMap<K,V> kryoRegistrations
```
      Deprecated.
      
      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.
- Class org.apache.flink.api.java.typeutils.runtime.CopyableValueComparator extends org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.flink.types.CopyableValue<T> & Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream arg0)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - type
```
Class<T> type
```
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
org.apache.flink.api.common.typeutils.TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.java.typeutils.runtime.CopyableValueSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T extends org.apache.flink.types.CopyableValue<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - valueClass
```
Class<T> valueClass
```
- Class org.apache.flink.api.java.typeutils.runtime.EitherSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.types.Either<L,R>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - leftSerializer
```
org.apache.flink.api.common.typeutils.TypeSerializer<T> leftSerializer
```
    - rightSerializer
```
org.apache.flink.api.common.typeutils.TypeSerializer<T> rightSerializer
```
- Class org.apache.flink.api.java.typeutils.runtime.GenericTypeComparator extends org.apache.flink.api.common.typeutils.TypeComparator<T extends Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ascending
```
boolean ascending
```
    - type
```
Class<T> type
```
    - serializer
```
org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer
```
    - comparators
```
org.apache.flink.api.common.typeutils.TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.java.typeutils.runtime.KryoRegistration extends Object implements Serializable
  
  serialVersionUID:
  
  5375110512910892655L
  - Serialized Fields
    - registeredClass
```
Class<T> registeredClass
```
    - serializerClass
```
Class<T> serializerClass
```
    - serializableSerializerInstance
```
org.apache.flink.api.common.ExecutionConfig.SerializableSerializer<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable> serializableSerializerInstance
```
    - serializerDefinitionType
```
org.apache.flink.api.java.typeutils.runtime.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.NullAwareComparator extends org.apache.flink.api.common.typeutils.TypeComparator<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - wrappedComparator
```
org.apache.flink.api.common.typeutils.TypeComparator<T> wrappedComparator
```
    - order
```
boolean order
```
    - flatFields
```
int flatFields
```
    - nullReference
```
boolean nullReference
```
- Class org.apache.flink.api.java.typeutils.runtime.PojoComparator extends org.apache.flink.api.common.typeutils.CompositeTypeComparator<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream arg0)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream arg0)
                  throws IOException,
                         ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - comparators
```
org.apache.flink.api.common.typeutils.TypeComparator<T>[] comparators
```
    - normalizedKeyLengths
```
int[] normalizedKeyLengths
```
    - numLeadingNormalizableKeys
```
int numLeadingNormalizableKeys
```
    - normalizableKeyPrefixLen
```
int normalizableKeyPrefixLen
```
    - invertNormKey
```
boolean invertNormKey
```
    - serializer
```
org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer
```
    - type
```
Class<T> type
```
- Class org.apache.flink.api.java.typeutils.runtime.PojoSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream arg0)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream arg0)
                  throws IOException,
                         ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
    - fieldSerializers
```
org.apache.flink.api.common.typeutils.TypeSerializer<T>[] fieldSerializers
```
    - numFields
```
int numFields
```
    - registeredClasses
```
LinkedHashMap<K,V> registeredClasses
```
    - registeredSerializers
```
org.apache.flink.api.common.typeutils.TypeSerializer<T>[] registeredSerializers
```
    - executionConfig
```
org.apache.flink.api.common.ExecutionConfig executionConfig
```
- Class org.apache.flink.api.java.typeutils.runtime.RowComparator extends org.apache.flink.api.common.typeutils.CompositeTypeComparator<org.apache.flink.types.Row> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - arity
```
int arity
```
    - keyPositions
```
int[] keyPositions
```
    - comparators
```
org.apache.flink.api.java.typeutils.runtime.NullAwareComparator<T>[] comparators
```
    - serializers
```
org.apache.flink.api.common.typeutils.TypeSerializer<T>[] serializers
```
    - normalizedKeyLengths
```
int[] normalizedKeyLengths
```
    - numLeadingNormalizableKeys
```
int numLeadingNormalizableKeys
```
    - normalizableKeyPrefixLen
```
int normalizableKeyPrefixLen
```
    - invertNormKey
```
boolean invertNormKey
```
    - nullMask1
```
boolean[] nullMask1
```
    - nullMask2
```
boolean[] nullMask2
```
- Class org.apache.flink.api.java.typeutils.runtime.RowSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.types.Row> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream arg0)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - fieldSerializers
```
org.apache.flink.api.common.typeutils.TypeSerializer<T>[] fieldSerializers
```
    - arity
```
int arity
```
- Class org.apache.flink.api.java.typeutils.runtime.RuntimeComparatorFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - comparator
```
org.apache.flink.api.common.typeutils.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
```
org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer
```
    - firstSerializer
```
boolean firstSerializer
```
    - clazz
```
Class<T> clazz
```
- Class org.apache.flink.api.java.typeutils.runtime.Tuple0Serializer extends org.apache.flink.api.java.typeutils.runtime.TupleSerializer<org.apache.flink.api.java.tuple.Tuple0> implements Serializable
  
  serialVersionUID:
  
  1278813169022975971L
- Class org.apache.flink.api.java.typeutils.runtime.TupleComparator extends org.apache.flink.api.java.typeutils.runtime.TupleComparatorBase<T extends org.apache.flink.api.java.tuple.Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.TupleComparatorBase extends org.apache.flink.api.common.typeutils.CompositeTypeComparator<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - keyPositions
```
int[] keyPositions
```
    - comparators
```
org.apache.flink.api.common.typeutils.TypeComparator<T>[] comparators
```
    - normalizedKeyLengths
```
int[] normalizedKeyLengths
```
    - numLeadingNormalizableKeys
```
int numLeadingNormalizableKeys
```
    - normalizableKeyPrefixLen
```
int normalizableKeyPrefixLen
```
    - invertNormKey
```
boolean invertNormKey
```
    - serializers
```
org.apache.flink.api.common.typeutils.TypeSerializer<T>[] serializers
```
- Class org.apache.flink.api.java.typeutils.runtime.TupleSerializer extends org.apache.flink.api.java.typeutils.runtime.TupleSerializerBase<T extends org.apache.flink.api.java.tuple.Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.typeutils.runtime.TupleSerializerBase extends org.apache.flink.api.common.typeutils.TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tupleClass
```
Class<T> tupleClass
```
    - fieldSerializers
```
org.apache.flink.api.common.typeutils.TypeSerializer<T>[] fieldSerializers
```
    - arity
```
int arity
```
    - length
```
int length
```
- Class org.apache.flink.api.java.typeutils.runtime.ValueComparator extends org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.flink.types.Value & Comparable<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
    - ascendingComparison
```
boolean ascendingComparison
```
    - comparators
```
org.apache.flink.api.common.typeutils.TypeComparator<T>[] comparators
```
- Class org.apache.flink.api.java.typeutils.runtime.ValueSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T extends org.apache.flink.types.Value> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream arg0)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - type
```
Class<T> type
```
    - kryoRegistrations
```
LinkedHashMap<K,V> kryoRegistrations
```
Package org.apache.flink.formats.avro
- Class org.apache.flink.formats.avro.AvroDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  -6766681879020862312L
  - Serialized Fields
    - recordClazz
```
Class<T> recordClazz
```
      Class to deserialize to.
    - schemaString
```
String schemaString
```
      Schema in case of GenericRecord for serialization purpose.
- Class org.apache.flink.formats.avro.AvroInputFormat extends org.apache.flink.api.common.io.FileInputFormat<E> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - avroValueType
```
Class<T> avroValueType
```
    - reuseAvroValue
```
boolean reuseAvroValue
```
    - lastSync
```
long lastSync
```
- Class org.apache.flink.formats.avro.AvroOutputFormat extends org.apache.flink.api.common.io.FileOutputFormat<E> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - avroValueType
```
Class<T> avroValueType
```
- Class org.apache.flink.formats.avro.AvroRowDeserializationSchema extends org.apache.flink.api.common.serialization.AbstractDeserializationSchema<org.apache.flink.types.Row> implements Serializable
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream inputStream)
                 throws ClassNotFoundException,
                        IOException
```
      Throws:
      
      ClassNotFoundException
      
      IOException
    - writeObject
```
private void writeObject(ObjectOutputStream outputStream)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - recordClazz
```
Class<T> recordClazz
```
      Avro record class for deserialization. Might be null if record class is not available.
    - schemaString
```
String schemaString
```
      Schema string for deserialization.
- Class org.apache.flink.formats.avro.AvroRowSerializationSchema extends Object implements Serializable
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream inputStream)
                 throws ClassNotFoundException,
                        IOException
```
      Throws:
      
      ClassNotFoundException
      
      IOException
    - writeObject
```
private void writeObject(ObjectOutputStream outputStream)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - recordClazz
```
Class<T> recordClazz
```
      Avro record class for serialization. Might be null if record class is not available.
    - schemaString
```
String schemaString
```
      Schema string for deserialization.
- Class org.apache.flink.formats.avro.RegistryAvroDeserializationSchema extends AvroDeserializationSchema<T> implements Serializable
  
  serialVersionUID:
  
  -884738268437806062L
  - Serialized Fields
    - schemaCoderProvider
```
SchemaCoder.SchemaCoderProvider schemaCoderProvider
```
      Provider for schema coder. Used for initializing in each task.
Package org.apache.flink.formats.avro.typeutils
- Class org.apache.flink.formats.avro.typeutils.AvroSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
      The class of the type that is serialized by this serializer.
    - schemaString
```
String schemaString
```
- Class org.apache.flink.formats.avro.typeutils.AvroTypeInfo extends org.apache.flink.api.java.typeutils.PojoTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - useBackwardsCompatibleSerializer
```
boolean useBackwardsCompatibleSerializer
```
- Class org.apache.flink.formats.avro.typeutils.BackwardsCompatibleAvroSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - type
```
Class<T> type
```
      The type to serialize.
    - serializer
```
org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer
```
      The type serializer currently used. Avro by default.
- Class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.avro.generic.GenericRecord> implements Serializable
  
  serialVersionUID:
  
  4141977586453820650L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream ois)
                 throws ClassNotFoundException,
                        IOException
```
      Throws:
      
      ClassNotFoundException
      
      IOException
    - writeObject
```
private void writeObject(ObjectOutputStream oos)
                  throws IOException
```
      Throws:
      
      IOException
Package org.apache.flink.formats.avro.utils
- Class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.AvroSchemaSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.avro.Schema> implements Serializable
  
  serialVersionUID:
  
  1L

Serialized Form

Package org.apache.flink.api.java.typeutils

Class org.apache.flink.api.java.typeutils.AvroTypeInfo extends org.apache.flink.api.java.typeutils.PojoTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase> implements Serializable

Class org.apache.flink.api.java.typeutils.EitherTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Either<L,R>> implements Serializable

Serialized Fields

leftType

rightType

Class org.apache.flink.api.java.typeutils.EnumTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<T extends Enum<T>> implements Serializable

Serialized Fields

typeClass

Class org.apache.flink.api.java.typeutils.GenericTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<T> implements Serializable

Serialized Fields

typeClass

Class org.apache.flink.api.java.typeutils.ListTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<List<T>> implements Serializable

Serialized Fields

elementTypeInfo

Class org.apache.flink.api.java.typeutils.MapTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<Map<K,V>> implements Serializable

Serialized Fields

keyTypeInfo

valueTypeInfo

Class org.apache.flink.api.java.typeutils.MissingTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.api.common.functions.InvalidTypesException> implements Serializable

Serialized Fields

functionName

typeException

Class org.apache.flink.api.java.typeutils.MultisetTypeInfo extends org.apache.flink.api.java.typeutils.MapTypeInfo<T,Integer> implements Serializable

Class org.apache.flink.api.java.typeutils.ObjectArrayTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<T> implements Serializable

Serialized Fields

arrayType

componentInfo

Class org.apache.flink.api.java.typeutils.PojoField extends Object implements Serializable

Serialization Methods

readObject

writeObject

Serialized Fields

type

Class org.apache.flink.api.java.typeutils.PojoTypeInfo extends org.apache.flink.api.common.typeutils.CompositeType<T> implements Serializable

Serialized Fields

fields

totalFields

Class org.apache.flink.api.java.typeutils.RowTypeInfo extends org.apache.flink.api.java.typeutils.TupleTypeInfoBase<org.apache.flink.types.Row> implements Serializable

Serialized Fields

fieldNames

comparatorOrders

Class org.apache.flink.api.java.typeutils.TupleTypeInfo extends org.apache.flink.api.java.typeutils.TupleTypeInfoBase<T extends org.apache.flink.api.java.tuple.Tuple> implements Serializable

Serialized Fields

fieldNames

Class org.apache.flink.api.java.typeutils.TupleTypeInfoBase extends org.apache.flink.api.common.typeutils.CompositeType<T> implements Serializable

Serialized Fields

types

totalFields

Class org.apache.flink.api.java.typeutils.TypeExtractionException extends Exception implements Serializable

Class org.apache.flink.api.java.typeutils.ValueTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<T extends org.apache.flink.types.Value> implements Serializable

Serialized Fields

type

Package org.apache.flink.api.java.typeutils.runtime

Class org.apache.flink.api.java.typeutils.runtime.AvroSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T> implements Serializable

Serialization Methods

readObject

Serialized Fields

type

typeToInstantiate

kryoRegistrations

Class org.apache.flink.api.java.typeutils.runtime.CopyableValueComparator extends org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.flink.types.CopyableValue<T> & Comparable<T>> implements Serializable

Serialization Methods

readObject

Serialized Fields

type

ascendingComparison

comparators

Class org.apache.flink.api.java.typeutils.runtime.CopyableValueSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T extends org.apache.flink.types.CopyableValue<T>> implements Serializable

Serialized Fields

valueClass

Class org.apache.flink.api.java.typeutils.runtime.EitherSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.types.Either<L,R>> implements Serializable

Serialized Fields

leftSerializer

rightSerializer

Class org.apache.flink.api.java.typeutils.runtime.GenericTypeComparator extends org.apache.flink.api.common.typeutils.TypeComparator<T extends Comparable<T>> implements Serializable

Serialized Fields

ascending

type