Serialized Form (Flink : Java 1.20.1-cp2 API)

Package org.apache.flink.api.java
- Class org.apache.flink.api.java.Utils.ChecksumHashCode extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - checksum
      
      long checksum
    - count
      
      long count
- Class org.apache.flink.api.java.Utils.ChecksumHashCodeHelper extends org.apache.flink.api.common.io.RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - checksum
      
      long checksum
    - counter
      
      long counter
    - id
      
      String id
- Class org.apache.flink.api.java.Utils.CollectHelper extends org.apache.flink.api.common.io.RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - accumulator
      
      org.apache.flink.api.common.accumulators.SerializedListAccumulator<T> accumulator
    - id
      
      String id
    - serializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer
- Class org.apache.flink.api.java.Utils.CountHelper extends org.apache.flink.api.common.io.RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - counter
      
      long counter
    - id
      
      String id
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 org.apache.flink.api.common.functions.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<T> formatter
- Class org.apache.flink.api.java.functions.GroupReduceIterator extends org.apache.flink.api.common.functions.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
    - numSample
      
      int numSample
    - seed
      
      long seed
    - withReplacement
      
      boolean withReplacement
- Class org.apache.flink.api.java.functions.SampleInPartition extends org.apache.flink.api.common.functions.RichMapPartitionFunction<T,IntermediateSampleData<T>> implements Serializable
  - Serialized Fields
    - numSample
      
      int numSample
    - seed
      
      long seed
    - withReplacement
      
      boolean withReplacement
- Class org.apache.flink.api.java.functions.SampleWithFraction extends org.apache.flink.api.common.functions.RichMapPartitionFunction<T,T> implements Serializable
  - Serialized Fields
    - fraction
      
      double fraction
    - seed
      
      long seed
    - withReplacement
      
      boolean withReplacement
- 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.io
- Class org.apache.flink.api.java.io.BlockingShuffleOutputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - intermediateDataSetId
      
      org.apache.flink.util.AbstractID intermediateDataSetId
- Class org.apache.flink.api.java.io.CollectionInputFormat extends org.apache.flink.api.common.io.GenericInputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
      
      private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
      
      Deprecated.
      
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
      
      private void writeObject(ObjectOutputStream out) throws IOException
      
      Deprecated.
      
      Throws:
      
      IOException
  - Serialized Fields
    - serializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer
      
      Deprecated.
- Class org.apache.flink.api.java.io.CsvInputFormat extends org.apache.flink.api.common.io.GenericCsvInputFormat<OUT> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.io.CsvOutputFormat extends org.apache.flink.api.common.io.FileOutputFormat<T extends org.apache.flink.api.java.tuple.Tuple> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - allowNullValues
      
      boolean allowNullValues
      
      Deprecated.
    - charsetName
      
      String charsetName
      
      Deprecated.
    - fieldDelimiter
      
      String fieldDelimiter
      
      Deprecated.
    - quoteStrings
      
      boolean quoteStrings
      
      Deprecated.
    - recordDelimiter
      
      String recordDelimiter
      
      Deprecated.
- Class org.apache.flink.api.java.io.DiscardingOutputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.io.IteratorInputFormat extends org.apache.flink.api.common.io.GenericInputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - iterator
      
      Iterator<T> iterator
      
      Deprecated.
- Class org.apache.flink.api.java.io.LocalCollectionOutputFormat extends org.apache.flink.api.common.io.RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - id
      
      int id
      
      Deprecated.
    - typeSerializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer<T> typeSerializer
      
      Deprecated.
- Class org.apache.flink.api.java.io.ParallelIteratorInputFormat extends org.apache.flink.api.common.io.GenericInputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - source
      
      org.apache.flink.util.SplittableIterator<T> source
      
      Deprecated.
- Class org.apache.flink.api.java.io.PojoCsvInputFormat extends CsvInputFormat<OUT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - pojoFieldNames
      
      String[] pojoFieldNames
    - pojoTypeClass
      
      Class<OUT> pojoTypeClass
- Class org.apache.flink.api.java.io.PrimitiveInputFormat extends org.apache.flink.api.common.io.DelimitedInputFormat<OT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - primitiveClass
      
      Class<OT> primitiveClass
      
      Deprecated.
- Class org.apache.flink.api.java.io.PrintingOutputFormat extends org.apache.flink.api.common.io.RichOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - writer
      
      org.apache.flink.api.common.functions.util.PrintSinkOutputWriter<T> writer
      
      Deprecated.
- Class org.apache.flink.api.java.io.RowCsvInputFormat extends CsvInputFormat<org.apache.flink.types.Row> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - arity
      
      int arity
      
      Deprecated.
    - emptyColumnAsNull
      
      boolean emptyColumnAsNull
      
      Deprecated.
    - fieldPosMap
      
      int[] fieldPosMap
      
      Deprecated.
    - fieldTypeInfos
      
      org.apache.flink.api.common.typeinfo.TypeInformation[] fieldTypeInfos
      
      Deprecated.
- 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 org.apache.flink.api.common.io.DelimitedInputFormat<String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - charsetName
      
      String charsetName
      
      Deprecated.
      
      The name of the charset to use for decoding.
- Class org.apache.flink.api.java.io.TextOutputFormat extends org.apache.flink.api.common.io.FileOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - charsetName
      
      String charsetName
      
      Deprecated.
- Class org.apache.flink.api.java.io.TextValueInputFormat extends org.apache.flink.api.common.io.DelimitedInputFormat<org.apache.flink.types.StringValue> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - charsetName
      
      String charsetName
      
      Deprecated.
    - skipInvalidLines
      
      boolean skipInvalidLines
      
      Deprecated.
- Class org.apache.flink.api.java.io.TupleCsvInputFormat extends CsvInputFormat<OUT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tupleSerializer
      
      org.apache.flink.api.java.typeutils.runtime.TupleSerializerBase<OUT> tupleSerializer
- Class org.apache.flink.api.java.io.TypeSerializerInputFormat extends org.apache.flink.api.common.io.BinaryInputFormat<T> implements Serializable
  
  serialVersionUID:
  
  2123068581665107480L
  - Serialized Fields
    - serializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer
      
      Deprecated.
- Class org.apache.flink.api.java.io.TypeSerializerOutputFormat extends org.apache.flink.api.common.io.BinaryOutputFormat<T> implements Serializable
  
  serialVersionUID:
  
  -6653022644629315158L
  - Serialized Fields
    - serializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer
      
      Deprecated.
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
      
      R extends org.apache.flink.api.java.tuple.Tuple outTuple
- Class org.apache.flink.api.java.operators.JoinOperator.DefaultJoin.WrappingFlatJoinFunction extends WrappingFunction<org.apache.flink.api.common.functions.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
      
      F extends org.apache.flink.api.common.functions.CombineFunction<IN,IN> & org.apache.flink.api.common.functions.GroupReduceFunction<IN,OUT> wrappedFunction
- Class org.apache.flink.api.java.operators.translation.KeyExtractingMapper extends org.apache.flink.api.common.functions.RichMapFunction<T,org.apache.flink.api.java.tuple.Tuple2<K,T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - keySelector
      
      org.apache.flink.api.java.functions.KeySelector<T,K> keySelector
    - tuple
      
      org.apache.flink.api.java.tuple.Tuple2<K,T> tuple
- Class org.apache.flink.api.java.operators.translation.KeyRemovingMapper extends org.apache.flink.api.common.functions.RichMapFunction<org.apache.flink.api.java.tuple.Tuple2<K,T>,T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.operators.translation.PlanFilterOperator.FlatMapFilter extends WrappingFunction<org.apache.flink.api.common.functions.FilterFunction<T>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.operators.translation.RichCombineToGroupCombineWrapper extends org.apache.flink.api.common.functions.RichGroupCombineFunction<IN,IN> implements Serializable
  - Serialized Fields
    - wrappedFunction
      
      F extends org.apache.flink.api.common.functions.RichGroupReduceFunction<IN,OUT> & org.apache.flink.api.common.functions.CombineFunction<IN,IN> wrappedFunction
- Class org.apache.flink.api.java.operators.translation.Tuple3UnwrappingIterator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - iterator
      
      Iterator<org.apache.flink.api.java.tuple.Tuple3<K1,K2,T>> iterator
    - iteratorAvailable
      
      boolean iteratorAvailable
    - lastGroupKey
      
      K1 lastGroupKey
    - lastSortKey
      
      K2 lastSortKey
- Class org.apache.flink.api.java.operators.translation.Tuple3WrappingCollector extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - outTuple
      
      org.apache.flink.api.java.tuple.Tuple3<K1,K2,IN> outTuple
    - tui
      
      Tuple3UnwrappingIterator<IN,K1,K2> tui
    - wrappedCollector
      
      org.apache.flink.util.Collector<org.apache.flink.api.java.tuple.Tuple3<K1,K2,IN>> wrappedCollector
- Class org.apache.flink.api.java.operators.translation.TupleLeftUnwrappingJoiner extends WrappingFunction<org.apache.flink.api.common.functions.FlatJoinFunction<I1,I2,OUT>> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.api.java.operators.translation.TupleRightUnwrappingJoiner extends WrappingFunction<org.apache.flink.api.common.functions.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
    - iterator
      
      Iterator<org.apache.flink.api.java.tuple.Tuple2<K,T>> iterator
    - iteratorAvailable
      
      boolean iteratorAvailable
    - lastKey
      
      K lastKey
- Class org.apache.flink.api.java.operators.translation.TupleUnwrappingJoiner extends WrappingFunction<org.apache.flink.api.common.functions.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
    - outTuple
      
      org.apache.flink.api.java.tuple.Tuple2<K,IN> outTuple
    - tui
      
      TupleUnwrappingIterator<IN,K> tui
    - wrappedCollector
      
      org.apache.flink.util.Collector<org.apache.flink.api.java.tuple.Tuple2<K,IN>> wrappedCollector
- Class org.apache.flink.api.java.operators.translation.TwoKeyExtractingMapper extends org.apache.flink.api.common.functions.RichMapFunction<T,org.apache.flink.api.java.tuple.Tuple3<K1,K2,T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - keySelector1
      
      org.apache.flink.api.java.functions.KeySelector<T,K1> keySelector1
    - keySelector2
      
      org.apache.flink.api.java.functions.KeySelector<T,K2> keySelector2
    - tuple
      
      org.apache.flink.api.java.tuple.Tuple3<K1,K2,T> tuple
- Class org.apache.flink.api.java.operators.translation.WrappingFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - wrappedFunction
      
      T extends org.apache.flink.api.common.functions.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
    - infinityCount
      
      long infinityCount
      
      Deprecated.
    - max
      
      T max
      
      Deprecated.
    - mean
      
      Double mean
      
      Deprecated.
    - min
      
      T min
      
      Deprecated.
    - nanCount
      
      long nanCount
      
      Deprecated.
    - nonMissingCount
      
      long nonMissingCount
      
      Deprecated.
    - nullCount
      
      long nullCount
      
      Deprecated.
    - standardDeviation
      
      Double standardDeviation
      
      Deprecated.
    - sum
      
      T sum
      
      Deprecated.
    - variance
      
      Double variance
      
      Deprecated.
Package org.apache.flink.api.java.summarize.aggregation
- Class org.apache.flink.api.java.summarize.aggregation.BooleanSummaryAggregator extends Object implements Serializable
  - Serialized Fields
    - falseCount
      
      long falseCount
    - nullCount
      
      long nullCount
    - trueCount
      
      long trueCount
- Class org.apache.flink.api.java.summarize.aggregation.CompensatedSum extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - delta
      
      double delta
    - value
      
      double value
- 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
    - infinityCount
      
      long infinityCount
    - 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
    - max
      
      Aggregator<T extends Number,T extends Number> max
    - mean
      
      CompensatedSum mean
    - min
      
      Aggregator<T extends Number,T extends Number> min
    - nanCount
      
      long nanCount
    - nonMissingCount
      
      long nonMissingCount
    - nullCount
      
      long nullCount
    - sum
      
      Aggregator<T extends Number,T extends Number> sum
- 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
    - emptyCount
      
      long emptyCount
    - maxStringLength
      
      int maxStringLength
    - meanLength
      
      CompensatedSum meanLength
    - minStringLength
      
      int minStringLength
    - nonNullCount
      
      long nonNullCount
    - nullCount
      
      long nullCount
- Class org.apache.flink.api.java.summarize.aggregation.TupleSummaryAggregator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - columnAggregators
      
      Aggregator[] columnAggregators
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator extends Object implements Serializable
  - Serialized Fields
    - aggregator
      
      A extends Aggregator<PT,R> aggregator
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.BooleanValueSummaryAggregator extends ValueSummaryAggregator<org.apache.flink.types.BooleanValue,Boolean,BooleanColumnSummary,BooleanSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.DoubleValueSummaryAggregator extends ValueSummaryAggregator<org.apache.flink.types.DoubleValue,Double,NumericColumnSummary<Double>,DoubleSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.FloatValueSummaryAggregator extends ValueSummaryAggregator<org.apache.flink.types.FloatValue,Float,NumericColumnSummary<Float>,FloatSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.IntegerValueSummaryAggregator extends ValueSummaryAggregator<org.apache.flink.types.IntValue,Integer,NumericColumnSummary<Integer>,IntegerSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.LongValueSummaryAggregator extends ValueSummaryAggregator<org.apache.flink.types.LongValue,Long,NumericColumnSummary<Long>,LongSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.ShortValueSummaryAggregator extends ValueSummaryAggregator<org.apache.flink.types.ShortValue,Short,NumericColumnSummary<Short>,ShortSummaryAggregator> implements Serializable
- Class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.StringValueSummaryAggregator extends ValueSummaryAggregator<org.apache.flink.types.StringValue,String,StringColumnSummary,StringSummaryAggregator> implements Serializable
Package org.apache.flink.api.java.typeutils.runtime.kryo
- Class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T extends Object> implements Serializable
  
  serialVersionUID:
  
  3L
  - Serialization Methods
    - readObject
      
      private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
      
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - defaultSerializerClasses
      
      LinkedHashMap<Class<?>,Class<? extends com.esotericsoftware.kryo.Serializer<?>>> defaultSerializerClasses
    - defaultSerializers
      
      LinkedHashMap<Class<?>,org.apache.flink.api.common.ExecutionConfig.SerializableSerializer<?>> defaultSerializers
    - kryoRegistrations
      
      LinkedHashMap<String,org.apache.flink.api.java.typeutils.runtime.KryoRegistration> kryoRegistrations
    - registeredTypes
      
      LinkedHashSet<Class<?>> registeredTypes
    - registeredTypesWithSerializerClasses
      
      LinkedHashMap<Class<?>,Class<? extends com.esotericsoftware.kryo.Serializer<?>>> registeredTypesWithSerializerClasses
    - registeredTypesWithSerializers
      
      LinkedHashMap<Class<?>,org.apache.flink.api.common.ExecutionConfig.SerializableSerializer<?>> registeredTypesWithSerializers
    - type
      
      Class<T extends Object> type
- 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 extends Collection> type
- Class org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.SpecificInstanceCollectionSerializerForArrayList extends org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.SpecificInstanceCollectionSerializer<ArrayList> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.api.java.utils
- Class org.apache.flink.api.java.utils.AbstractParameterTool extends org.apache.flink.api.common.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<String,Collection<String>> 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<String,String> data

Serialized Form

Package org.apache.flink.api.java

Class org.apache.flink.api.java.Utils.ChecksumHashCode extends Object implements Serializable

Serialized Fields

checksum

count

Class org.apache.flink.api.java.Utils.ChecksumHashCodeHelper extends org.apache.flink.api.common.io.RichOutputFormat<T> implements Serializable

Serialized Fields

checksum

counter

id

Class org.apache.flink.api.java.Utils.CollectHelper extends org.apache.flink.api.common.io.RichOutputFormat<T> implements Serializable

Serialized Fields

accumulator

id

serializer

Class org.apache.flink.api.java.Utils.CountHelper extends org.apache.flink.api.common.io.RichOutputFormat<T> implements Serializable

Serialized Fields

counter

id

Package org.apache.flink.api.java.aggregation

Class org.apache.flink.api.java.aggregation.AggregationFunction extends Object implements Serializable

Class org.apache.flink.api.java.aggregation.MaxAggregationFunction extends AggregationFunction<T extends Comparable<T>> implements Serializable

Class org.apache.flink.api.java.aggregation.MaxAggregationFunction.MaxAggregationFunctionFactory extends Object implements Serializable

Class org.apache.flink.api.java.aggregation.MinAggregationFunction extends AggregationFunction<T extends Comparable<T>> implements Serializable

Class org.apache.flink.api.java.aggregation.MinAggregationFunction.MinAggregationFunctionFactory extends Object implements Serializable

Class org.apache.flink.api.java.aggregation.SumAggregationFunction extends AggregationFunction<T> implements Serializable

Class org.apache.flink.api.java.aggregation.SumAggregationFunction.SumAggregationFunctionFactory extends Object implements Serializable

Class org.apache.flink.api.java.aggregation.UnsupportedAggregationTypeException extends RuntimeException implements Serializable

Package org.apache.flink.api.java.functions

Class org.apache.flink.api.java.functions.FirstReducer extends Object implements Serializable

Serialized Fields

count

Class org.apache.flink.api.java.functions.FlatMapIterator extends org.apache.flink.api.common.functions.RichFlatMapFunction<IN,​OUT> implements Serializable

Class org.apache.flink.api.java.functions.FormattingMapper extends Object implements Serializable

Serialized Fields

formatter

Class org.apache.flink.api.java.functions.GroupReduceIterator extends org.apache.flink.api.common.functions.RichGroupReduceFunction<IN,​OUT> implements Serializable

Class org.apache.flink.api.java.functions.IdPartitioner extends Object implements Serializable

Class org.apache.flink.api.java.functions.NullByteKeySelector extends Object implements Serializable

Class org.apache.flink.api.java.functions.SampleInCoordinator extends Object implements Serializable

Serialized Fields

numSample

seed

withReplacement

Class org.apache.flink.api.java.functions.SampleInPartition extends org.apache.flink.api.common.functions.RichMapPartitionFunction<T,​IntermediateSampleData<T>> implements Serializable

Serialized Fields

numSample

seed

withReplacement

Class org.apache.flink.api.java.functions.SampleWithFraction extends org.apache.flink.api.common.functions.RichMapPartitionFunction<T,​T> implements Serializable

Serialized Fields

fraction

seed

withReplacement

Class org.apache.flink.api.java.functions.SelectByMaxFunction extends Object implements Serializable

Serialized Fields

fields

Class org.apache.flink.api.java.functions.SelectByMinFunction extends Object implements Serializable

Serialized Fields

fields

Package org.apache.flink.api.java.io

Class org.apache.flink.api.java.io.BlockingShuffleOutputFormat extends Object implements Serializable

Serialized Fields

intermediateDataSetId

Class org.apache.flink.api.java.io.CollectionInputFormat extends org.apache.flink.api.common.io.GenericInputFormat<T> implements Serializable

Serialization Methods

readObject

writeObject

Serialized Fields

serializer

Class org.apache.flink.api.java.io.CsvInputFormat extends org.apache.flink.api.common.io.GenericCsvInputFormat<OUT> implements Serializable

Class org.apache.flink.api.java.io.CsvOutputFormat extends org.apache.flink.api.common.io.FileOutputFormat<T extends org.apache.flink.api.java.tuple.Tuple> implements Serializable

Serialized Fields

allowNullValues

charsetName

fieldDelimiter

quoteStrings

recordDelimiter

Class org.apache.flink.api.java.io.DiscardingOutputFormat extends Object implements Serializable

Class org.apache.flink.api.java.functions.FlatMapIterator extends org.apache.flink.api.common.functions.RichFlatMapFunction<IN,OUT> implements Serializable

Class org.apache.flink.api.java.functions.GroupReduceIterator extends org.apache.flink.api.common.functions.RichGroupReduceFunction<IN,OUT> implements Serializable

Class org.apache.flink.api.java.functions.SampleInPartition extends org.apache.flink.api.common.functions.RichMapPartitionFunction<T,IntermediateSampleData<T>> implements Serializable

Class org.apache.flink.api.java.functions.SampleWithFraction extends org.apache.flink.api.common.functions.RichMapPartitionFunction<T,T> implements Serializable

Class org.apache.flink.api.java.operators.JoinOperator.DefaultJoin.WrappingFlatJoinFunction extends WrappingFunction<org.apache.flink.api.common.functions.JoinFunction<IN1,IN2,OUT>> implements Serializable

Class org.apache.flink.api.java.operators.translation.KeyExtractingMapper extends org.apache.flink.api.common.functions.RichMapFunction<T,org.apache.flink.api.java.tuple.Tuple2<K,T>> implements Serializable

Class org.apache.flink.api.java.operators.translation.KeyRemovingMapper extends org.apache.flink.api.common.functions.RichMapFunction<org.apache.flink.api.java.tuple.Tuple2<K,T>,T> implements Serializable

Class org.apache.flink.api.java.operators.translation.RichCombineToGroupCombineWrapper extends org.apache.flink.api.common.functions.RichGroupCombineFunction<IN,IN> implements Serializable