Serialized Form

Package org.apache.flink.api.java.hadoop.common

Class org.apache.flink.api.java.hadoop.common.HadoopInputFormatCommonBase extends org.apache.flink.api.common.io.RichInputFormat<T,SPITTYPE extends org.apache.flink.core.io.InputSplit> implements Serializable

Class org.apache.flink.api.java.hadoop.common.HadoopOutputFormatCommonBase extends org.apache.flink.api.common.io.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,org.apache.flink.api.java.tuple.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

jobConf

org.apache.hadoop.mapred.JobConf jobConf

keyClass

Class<K> keyClass

mapredInputFormat

org.apache.hadoop.mapred.InputFormat<K,V> mapredInputFormat

valueClass

Class<V> valueClass

Class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormat extends HadoopOutputFormatBase<K,V,org.apache.flink.api.java.tuple.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 org.apache.flink.core.io.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<? extends org.apache.hadoop.mapred.InputSplit> splitType

Package org.apache.flink.api.java.hadoop.mapreduce

Class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat extends HadoopInputFormatBase<K,V,org.apache.flink.api.java.tuple.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

configuration

org.apache.hadoop.conf.Configuration configuration

fetched

boolean fetched

hasNext

boolean hasNext

keyClass

Class<K> keyClass

mapreduceInputFormat

org.apache.hadoop.mapreduce.InputFormat<K,V> mapreduceInputFormat

valueClass

Class<V> valueClass

Class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormat extends HadoopOutputFormatBase<K,V,org.apache.flink.api.java.tuple.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

org.apache.hadoop.conf.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 org.apache.flink.core.io.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<? extends org.apache.hadoop.mapreduce.InputSplit> splitType

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

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

serialVersionUID:

1L

Serialized Fields

leftType

org.apache.flink.api.common.typeinfo.TypeInformation<L extends Object> leftType

rightType

org.apache.flink.api.common.typeinfo.TypeInformation<R extends Object> 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 extends Enum<T>> typeClass

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

serialVersionUID:

-7959114120287706504L

Serialized Fields

typeClass

Class<T extends Object> typeClass

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

serialVersionUID:

1L

Serialized Fields

elementTypeInfo

org.apache.flink.api.common.typeinfo.TypeInformation<T extends Object> elementTypeInfo

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

Serialized Fields

keyTypeInfo

org.apache.flink.api.common.typeinfo.TypeInformation<K extends Object> keyTypeInfo

valueTypeInfo

org.apache.flink.api.common.typeinfo.TypeInformation<V extends Object> 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 extends Object,Integer> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.api.java.typeutils.NullableListTypeInfo extends org.apache.flink.api.java.typeutils.ListTypeInfo<T extends Object> implements Serializable

Class org.apache.flink.api.java.typeutils.NullableMapTypeInfo extends org.apache.flink.api.java.typeutils.MapTypeInfo<K extends Object,V extends Object> implements Serializable

Class org.apache.flink.api.java.typeutils.NullableSetTypeInfo extends org.apache.flink.api.java.typeutils.SetTypeInfo<T extends Object> implements Serializable

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

serialVersionUID:

1L

Serialized Fields

arrayType

Class<T extends Object> arrayType

componentInfo

org.apache.flink.api.common.typeinfo.TypeInformation<C extends Object> 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<?> type

Class org.apache.flink.api.java.typeutils.PojoTypeInfo extends org.apache.flink.api.common.typeutils.CompositeType<T extends Object> 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

comparatorOrders

boolean[] comparatorOrders

fieldNames

String[] fieldNames

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

serialVersionUID:

1L

Serialized Fields

elementTypeInfo

org.apache.flink.api.common.typeinfo.TypeInformation<T extends Object> elementTypeInfo

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 extends Object> implements Serializable

serialVersionUID:

1L

Serialized Fields

totalFields

int totalFields

types

org.apache.flink.api.common.typeinfo.TypeInformation<?>[] types

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 extends org.apache.flink.types.Value> type

Class org.apache.flink.api.java.typeutils.WritableTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<T extends org.apache.hadoop.io.Writable> implements Serializable

serialVersionUID:

1L

Serialized Fields

typeClass

Class<T extends org.apache.hadoop.io.Writable> typeClass

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

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

ascendingComparison

boolean ascendingComparison

comparators

org.apache.flink.api.common.typeutils.TypeComparator<?>[] comparators

type

Class<T extends org.apache.flink.types.CopyableValue<T> & Comparable<T>> type

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 extends org.apache.flink.types.CopyableValue<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 extends Object,R extends Object>> implements Serializable

serialVersionUID:

1L

Serialized Fields

leftSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<L extends Object> leftSerializer

rightSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<R extends Object> 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

comparators

org.apache.flink.api.common.typeutils.TypeComparator[] comparators

serializer

org.apache.flink.api.common.typeutils.TypeSerializer<T extends Comparable<T>> serializer

type

Class<T extends Comparable<T>> type

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

serialVersionUID:

5375110512910892655L

Serialized Fields

registeredClass

Class<?> registeredClass

serializableSerializerInstance

org.apache.flink.api.common.SerializableSerializer<? extends com.esotericsoftware.kryo.Serializer<?>> serializableSerializerInstance

serializerClass

Class<? extends com.esotericsoftware.kryo.Serializer<?>> serializerClass

serializerDefinitionType

org.apache.flink.api.java.typeutils.runtime.KryoRegistration.SerializerDefinitionType serializerDefinitionType

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

serialVersionUID:

3335569358214720033L

Serialized Fields

originalSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<T extends Object> originalSerializer

padding

byte[] padding

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

serialVersionUID:

1L

Serialized Fields

flatFields

int flatFields

nullReference

boolean nullReference

order

boolean order

wrappedComparator

org.apache.flink.api.common.typeutils.TypeComparator<T extends Object> wrappedComparator

Class org.apache.flink.api.java.typeutils.runtime.PojoComparator extends org.apache.flink.api.common.typeutils.CompositeTypeComparator<T extends Object> 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<Object>[] comparators

invertNormKey

boolean invertNormKey

normalizableKeyPrefixLen

int normalizableKeyPrefixLen

normalizedKeyLengths

int[] normalizedKeyLengths

numLeadingNormalizableKeys

int numLeadingNormalizableKeys

serializer

org.apache.flink.api.common.typeutils.TypeSerializer<T extends Object> serializer

type

Class<T extends Object> type

Class org.apache.flink.api.java.typeutils.runtime.PojoSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T extends Object> 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 extends Object> clazz

fieldSerializers

org.apache.flink.api.common.typeutils.TypeSerializer<Object>[] fieldSerializers

numFields

int numFields

registeredClasses

LinkedHashMap<Class<?>,Integer> registeredClasses

registeredSerializers

org.apache.flink.api.common.typeutils.TypeSerializer<?>[] registeredSerializers

serializerConfig

org.apache.flink.api.common.serialization.SerializerConfig serializerConfig

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:

2L

Serialized Fields

arity

int arity

comparators

org.apache.flink.api.java.typeutils.runtime.NullAwareComparator<Object>[] comparators

invertNormKey

boolean invertNormKey

keyPositions

int[] keyPositions

mask1

boolean[] mask1

mask2

boolean[] mask2

normalizableKeyPrefixLen

int normalizableKeyPrefixLen

normalizedKeyLengths

int[] normalizedKeyLengths

numLeadingNormalizableKeys

int numLeadingNormalizableKeys

serializers

org.apache.flink.api.common.typeutils.TypeSerializer<Object>[] serializers

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

arity

int arity

fieldSerializers

org.apache.flink.api.common.typeutils.TypeSerializer<Object>[] fieldSerializers

positionByName

LinkedHashMap<String,Integer> positionByName

rowKindOffset

int rowKindOffset

supportsRowKind

boolean supportsRowKind

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 extends Object> 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

clazz

Class<T extends Object> clazz

serializer

org.apache.flink.api.common.typeutils.TypeSerializer<T extends Object> serializer

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 extends Object> implements Serializable

serialVersionUID:

1L

Serialized Fields

comparators

org.apache.flink.api.common.typeutils.TypeComparator[] comparators

invertNormKey

boolean invertNormKey

keyPositions

int[] keyPositions

normalizableKeyPrefixLen

int normalizableKeyPrefixLen

normalizedKeyLengths

int[] normalizedKeyLengths

numLeadingNormalizableKeys

int numLeadingNormalizableKeys

serializers

org.apache.flink.api.common.typeutils.TypeSerializer[] 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 extends Object> implements Serializable

serialVersionUID:

1L

Serialized Fields

arity

int arity

fieldSerializers

org.apache.flink.api.common.typeutils.TypeSerializer<Object>[] fieldSerializers

length

int length

tupleClass

Class<T extends Object> tupleClass

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

ascendingComparison

boolean ascendingComparison

comparators

org.apache.flink.api.common.typeutils.TypeComparator[] comparators

type

Class<T extends org.apache.flink.types.Value & Comparable<T>> type

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

kryoRegistrations

LinkedHashMap<String,org.apache.flink.api.java.typeutils.runtime.KryoRegistration> kryoRegistrations

type

Class<T extends org.apache.flink.types.Value> type

Class org.apache.flink.api.java.typeutils.runtime.WritableComparator extends org.apache.flink.api.common.typeutils.TypeComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>> implements Serializable

serialVersionUID:

1L

Serialized Fields

ascendingComparison

boolean ascendingComparison

comparators

org.apache.flink.api.common.typeutils.TypeComparator[] comparators

type

Class<T extends org.apache.hadoop.io.Writable & Comparable<T>> type

Class org.apache.flink.api.java.typeutils.runtime.WritableSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T extends org.apache.hadoop.io.Writable> implements Serializable

serialVersionUID:

1L

Serialized Fields

typeClass

Class<T extends org.apache.hadoop.io.Writable> typeClass

Package org.apache.flink.hadoopcompatibility.mapred

Class org.apache.flink.hadoopcompatibility.mapred.HadoopMapFunction extends org.apache.flink.api.common.functions.RichFlatMapFunction<org.apache.flink.api.java.tuple.Tuple2<KEYIN,VALUEIN>,org.apache.flink.api.java.tuple.Tuple2<KEYOUT,VALUEOUT>> implements Serializable

serialVersionUID:

1L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Custom serialization methods.

Throws:

IOException

See Also:

http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html

Class org.apache.flink.hadoopcompatibility.mapred.HadoopReducerWrappedFunction extends org.apache.flink.streaming.api.functions.windowing.RichWindowFunction<org.apache.flink.api.java.tuple.Tuple2<KEYIN,VALUEIN>,org.apache.flink.api.java.tuple.Tuple2<KEYOUT,VALUEOUT>,KEYIN,org.apache.flink.streaming.api.windowing.windows.GlobalWindow> implements Serializable

serialVersionUID:

1L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Custom serialization methods.

Throws:

IOException

See Also:

http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html

Package org.apache.flink.hadoopcompatibility.mapred.wrapper

Class org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopTupleUnwrappingIterator extends org.apache.flink.api.common.operators.util.TupleUnwrappingIterator<VALUE,KEY> implements Serializable

serialVersionUID:

1L

Serialized Fields

keySerializer

org.apache.flink.api.common.typeutils.TypeSerializer<KEY> keySerializer