Serialized Form

Package org.apache.flink.streaming.api.checkpoint

Package org.apache.flink.streaming.api.connector.sink2

Class org.apache.flink.streaming.api.connector.sink2.CommittableMessageTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<CommittableMessage<CommT>> implements Serializable

Serialized Fields

committableSerializerFactory

org.apache.flink.util.function.SerializableSupplier<org.apache.flink.core.io.SimpleVersionedSerializer<CommT>> committableSerializerFactory

Class org.apache.flink.streaming.api.connector.sink2.GlobalCommitterOperator extends AbstractStreamOperator<Void> implements Serializable

Serialized Fields

commitOnInput

boolean commitOnInput

Depending on whether there is an upstream committer or it's connected to a writer, we may either wait for notifyCheckpointCompleted or not.

committableCollector

CommittableCollector<CommT> committableCollector

committableSerializer

org.apache.flink.core.io.SimpleVersionedSerializer<CommT> committableSerializer

committableSerializerFactory

org.apache.flink.util.function.SerializableSupplier<org.apache.flink.core.io.SimpleVersionedSerializer<CommT>> committableSerializerFactory

committer

org.apache.flink.api.connector.sink2.Committer<CommT> committer

committerFactory

org.apache.flink.util.function.SerializableSupplier<org.apache.flink.api.connector.sink2.Committer<CommT>> committerFactory

globalCommittableSerializer

org.apache.flink.core.io.SimpleVersionedSerializer<GlobalCommT> globalCommittableSerializer

globalCommitter

org.apache.flink.api.connector.sink.GlobalCommitter<CommT,GlobalCommT> globalCommitter

globalCommitterState

org.apache.flink.api.common.state.ListState<org.apache.flink.streaming.api.connector.sink2.GlobalCommittableWrapper<CommT,GlobalCommT>> globalCommitterState

lastCompletedCheckpointId

long lastCompletedCheckpointId

maxRetries

int maxRetries

metricGroup

org.apache.flink.metrics.groups.SinkCommitterMetricGroup metricGroup

sinkV1State

List<GlobalCommT> sinkV1State

Package org.apache.flink.streaming.api.datastream

Class org.apache.flink.streaming.api.datastream.CoGroupedStreams.UnionSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<CoGroupedStreams.TaggedUnion<T1,T2>> implements Serializable

serialVersionUID:

1L

Serialized Fields

oneSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<T1> oneSerializer

twoSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<T2> twoSerializer

Class org.apache.flink.streaming.api.datastream.UnsupportedTimeCharacteristicException extends org.apache.flink.util.FlinkRuntimeException implements Serializable

serialVersionUID:

-8109094930338075819L

Package org.apache.flink.streaming.api.environment

Class org.apache.flink.streaming.api.environment.CheckpointConfig extends Object implements Serializable

serialVersionUID:

-750378776078908147L

Serialized Fields

configuration

org.apache.flink.configuration.Configuration configuration

In the long run, this field should be somehow merged with the Configuration from StreamExecutionEnvironment.

Package org.apache.flink.streaming.api.functions

Class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor extends AscendingTimestampExtractor<T> implements Serializable

Class org.apache.flink.streaming.api.functions.IngestionTimeExtractor extends Object implements Serializable

serialVersionUID:

-4072216356049069301L

Serialized Fields

maxTimestamp

long maxTimestamp

Deprecated.

Class org.apache.flink.streaming.api.functions.KeyedProcessFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.ProcessFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

1L

Package org.apache.flink.streaming.api.functions.aggregation

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

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator extends AggregationFunction<T> implements Serializable

serialVersionUID:

1L

Serialized Fields

byAggregate

boolean byAggregate

comparator

Comparator comparator

fieldAccessor

FieldAccessor<T,Object> fieldAccessor

first

boolean first

Class org.apache.flink.streaming.api.functions.aggregation.Comparator extends Object implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.aggregation.SumAggregator extends AggregationFunction<T> implements Serializable

serialVersionUID:

1L

Serialized Fields

adder

SumFunction adder

fieldAccessor

FieldAccessor<T,Object> fieldAccessor

isTuple

boolean isTuple

serializer

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

Class org.apache.flink.streaming.api.functions.aggregation.SumFunction extends Object implements Serializable

serialVersionUID:

1L

Package org.apache.flink.streaming.api.functions.async

Class org.apache.flink.streaming.api.functions.async.RichAsyncFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

3858030061138121840L

Package org.apache.flink.streaming.api.functions.co

Class org.apache.flink.streaming.api.functions.co.BaseBroadcastProcessFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

-131631008887478610L

Class org.apache.flink.streaming.api.functions.co.BroadcastProcessFunction extends BaseBroadcastProcessFunction implements Serializable

serialVersionUID:

8352559162119034453L

Class org.apache.flink.streaming.api.functions.co.CoProcessFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.co.KeyedBroadcastProcessFunction extends BaseBroadcastProcessFunction implements Serializable

serialVersionUID:

-2584726797564976453L

Class org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.co.ProcessJoinFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

-2444626938039012398L

Class org.apache.flink.streaming.api.functions.co.RichCoFlatMapFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.co.RichCoMapFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

1L

Package org.apache.flink.streaming.api.functions.query

Class org.apache.flink.streaming.api.functions.query.QueryableAppendingStateOperator extends org.apache.flink.streaming.api.functions.query.AbstractQueryableStateOperator<org.apache.flink.api.common.state.AppendingState<IN,?>,IN> implements Serializable

Class org.apache.flink.streaming.api.functions.query.QueryableValueStateOperator extends org.apache.flink.streaming.api.functions.query.AbstractQueryableStateOperator<org.apache.flink.api.common.state.ValueState<IN>,IN> implements Serializable

Package org.apache.flink.streaming.api.functions.sink

Class org.apache.flink.streaming.api.functions.sink.DiscardingSink extends Object implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.sink.OutputFormatSinkFunction extends RichSinkFunction<IN> implements Serializable

serialVersionUID:

1L

Serialized Fields

cleanupCalled

boolean cleanupCalled

Deprecated.

format

org.apache.flink.api.common.io.OutputFormat<IN> format

Deprecated.

Class org.apache.flink.streaming.api.functions.sink.PrintSink extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

sinkIdentifier

String sinkIdentifier

stdErr

boolean stdErr

Class org.apache.flink.streaming.api.functions.sink.PrintSinkFunction extends RichSinkFunction<IN> implements Serializable

serialVersionUID:

1L

Serialized Fields

writer

org.apache.flink.api.common.functions.util.PrintSinkOutputWriter<IN> writer

Deprecated.

Class org.apache.flink.streaming.api.functions.sink.RichSinkFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.sink.SocketClientSink extends RichSinkFunction<IN> implements Serializable

serialVersionUID:

1L

Serialized Fields

autoFlush

boolean autoFlush

Deprecated.

hostName

String hostName

Deprecated.

isRunning

boolean isRunning

Deprecated.

lock

org.apache.flink.util.SerializableObject lock

Deprecated.

maxNumRetries

int maxNumRetries

Deprecated.

port

int port

Deprecated.

retries

int retries

Deprecated.

schema

org.apache.flink.api.common.serialization.SerializationSchema<IN> schema

Deprecated.

Class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction extends RichSinkFunction<IN> implements Serializable

Serialized Fields

clock

java.time.Clock clock

Deprecated.

currentTransactionHolder

TwoPhaseCommitSinkFunction.TransactionHolder<TXN> currentTransactionHolder

Deprecated.

Current Transaction Holder, including two states: 1. Normal Transaction: created when a new snapshot is taken during normal task running 2. null: After task/function is finished.

finished

boolean finished

Deprecated.

Whether this sink function as well as its task is finished.

ignoreFailuresAfterTransactionTimeout

boolean ignoreFailuresAfterTransactionTimeout

Deprecated.

If true, any exception thrown in TwoPhaseCommitSinkFunction.recoverAndCommit(Object) will be caught instead of propagated.

pendingCommitTransactions

LinkedHashMap<Long,TwoPhaseCommitSinkFunction.TransactionHolder<TXN>> pendingCommitTransactions

Deprecated.

stateDescriptor

org.apache.flink.api.common.state.ListStateDescriptor<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>> stateDescriptor

Deprecated.

transactionTimeout

long transactionTimeout

Deprecated.

Specifies the maximum time a transaction should remain open.

transactionTimeoutWarningRatio

double transactionTimeoutWarningRatio

Deprecated.

If a transaction's elapsed time reaches this percentage of the transactionTimeout, a warning message will be logged. Value must be in range [0,1]. Negative value disables warnings.

Class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction.StateSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>> implements Serializable

serialVersionUID:

1L

Serialized Fields

contextSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<CONTEXT> contextSerializer

supportNullPendingTransaction

boolean supportNullPendingTransaction

transactionSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<TXN> transactionSerializer

Class org.apache.flink.streaming.api.functions.sink.WriteFormat extends Object implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.sink.WriteFormatAsCsv extends WriteFormat<IN> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.sink.WriteFormatAsText extends WriteFormat<IN> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.sink.WriteSinkFunction extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

format

WriteFormat<IN> format

Deprecated.

path

String path

Deprecated.

tupleList

ArrayList<IN> tupleList

Deprecated.

Class org.apache.flink.streaming.api.functions.sink.WriteSinkFunctionByMillis extends WriteSinkFunction<IN> implements Serializable

serialVersionUID:

1L

Serialized Fields

lastTime

long lastTime

Deprecated.

millis

long millis

Deprecated.

Package org.apache.flink.streaming.api.functions.sink.filesystem

Class org.apache.flink.streaming.api.functions.sink.filesystem.DefaultBucketFactoryImpl extends Object implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig extends Object implements Serializable

Serialized Fields

partPrefix

String partPrefix

partSuffix

String partSuffix

Class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink extends RichSinkFunction<IN> implements Serializable

serialVersionUID:

1L

Serialized Fields

bucketCheckInterval

long bucketCheckInterval

Deprecated.

bucketsBuilder

StreamingFileSink.BucketsBuilder<IN,?,? extends StreamingFileSink.BucketsBuilder<IN,?,?>> bucketsBuilder

Deprecated.

Class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.BucketsBuilder extends Object implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.BulkFormatBuilder extends StreamingFileSink.BucketsBuilder<IN,BucketID,T extends StreamingFileSink.BulkFormatBuilder<IN,BucketID,T>> implements Serializable

serialVersionUID:

1L

Serialized Fields

basePath

org.apache.flink.core.fs.Path basePath

bucketAssigner

org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner<IN,BucketID> bucketAssigner

bucketCheckInterval

long bucketCheckInterval

bucketFactory

BucketFactory<IN,BucketID> bucketFactory

outputFileConfig

org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig

rollingPolicy

org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy<IN,BucketID> rollingPolicy

writerFactory

org.apache.flink.api.common.serialization.BulkWriter.Factory<IN> writerFactory

Class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.DefaultBulkFormatBuilder extends StreamingFileSink.BulkFormatBuilder<IN,String,StreamingFileSink.DefaultBulkFormatBuilder<IN>> implements Serializable

serialVersionUID:

7493169281036370228L

Class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.DefaultRowFormatBuilder extends StreamingFileSink.RowFormatBuilder<IN,String,StreamingFileSink.DefaultRowFormatBuilder<IN>> implements Serializable

serialVersionUID:

-8503344257202146718L

Class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.RowFormatBuilder extends StreamingFileSink.BucketsBuilder<IN,BucketID,T extends StreamingFileSink.RowFormatBuilder<IN,BucketID,T>> implements Serializable

serialVersionUID:

1L

Serialized Fields

basePath

org.apache.flink.core.fs.Path basePath

bucketAssigner

org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner<IN,BucketID> bucketAssigner

bucketCheckInterval

long bucketCheckInterval

bucketFactory

BucketFactory<IN,BucketID> bucketFactory

encoder

org.apache.flink.api.common.serialization.Encoder<IN> encoder

outputFileConfig

org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig

rollingPolicy

org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<IN,BucketID> rollingPolicy

Package org.apache.flink.streaming.api.functions.sink.v2

Class org.apache.flink.streaming.api.functions.sink.v2.DiscardingSink extends Object implements Serializable

serialVersionUID:

1L

Package org.apache.flink.streaming.api.functions.source

Class org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction extends RichSourceFunction<TimestampedFileInputSplit> implements Serializable

serialVersionUID:

1L

Serialized Fields

format

org.apache.flink.api.common.io.FileInputFormat<OUT> format

Deprecated.

The FileInputFormat to be read.

globalModificationTime

long globalModificationTime

Deprecated.

The maximum file modification time seen so far.

interval

long interval

Deprecated.

The interval between consecutive path scans.

isRunning

boolean isRunning

Deprecated.

path

String path

Deprecated.

The path to monitor.

readerParallelism

int readerParallelism

Deprecated.

The parallelism of the downstream readers.

watchType

FileProcessingMode watchType

Deprecated.

Which new data to process (see FileProcessingMode.

Class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator extends AbstractStreamOperator<OUT> implements Serializable

serialVersionUID:

1L

Serialized Fields

serializer

org.apache.flink.api.common.typeutils.TypeSerializer<OUT> serializer

Class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperatorFactory extends AbstractStreamOperatorFactory<OUT> implements Serializable

Serialized Fields

executionConfig

org.apache.flink.api.common.ExecutionConfig executionConfig

inputFormat

org.apache.flink.api.common.io.InputFormat<OUT,? super T extends TimestampedInputSplit> inputFormat

type

org.apache.flink.api.common.typeinfo.TypeInformation<OUT> type

Class org.apache.flink.streaming.api.functions.source.FileMonitoringFunction extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

interval

long interval

Deprecated.

isRunning

boolean isRunning

Deprecated.

modificationTimes

Map<String,Long> modificationTimes

Deprecated.

offsetOfFiles

Map<String,Long> offsetOfFiles

Deprecated.

path

String path

Deprecated.

watchType

FileMonitoringFunction.WatchType watchType

Deprecated.

Class org.apache.flink.streaming.api.functions.source.FileReadFunction extends Object implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.source.FromElementsFunction extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

elementsSerialized

byte[] elementsSerialized

Deprecated.

The actual data elements, in serialized form.

isRunning

boolean isRunning

Deprecated.

Flag to make the source cancelable.

numElements

int numElements

Deprecated.

The number of serialized elements.

numElementsEmitted

int numElementsEmitted

Deprecated.

The number of elements emitted already.

numElementsToSkip

int numElementsToSkip

Deprecated.

The number of elements to skip initially.

serializer

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

Deprecated.

The (de)serializer to be used for the data elements.

Class org.apache.flink.streaming.api.functions.source.FromIteratorFunction extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

isRunning

boolean isRunning

Deprecated.

iterator

Iterator<T> iterator

Deprecated.

Class org.apache.flink.streaming.api.functions.source.FromSplittableIteratorFunction extends RichParallelSourceFunction<T> implements Serializable

serialVersionUID:

1L

Serialized Fields

fullIterator

org.apache.flink.util.SplittableIterator<T> fullIterator

Deprecated.

isRunning

boolean isRunning

Deprecated.

Class org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction extends RichParallelSourceFunction<OUT> implements Serializable

serialVersionUID:

1L

Serialized Fields

format

org.apache.flink.api.common.io.InputFormat<OUT,org.apache.flink.core.io.InputSplit> format

Deprecated.

isRunning

boolean isRunning

Deprecated.

typeInfo

org.apache.flink.api.common.typeinfo.TypeInformation<OUT> typeInfo

Deprecated.

Class org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase extends RichSourceFunction<Type> implements Serializable

serialVersionUID:

-8689291992192955579L

Serialized Fields

idSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<UId> idSerializer

Deprecated.

Serializer used to serialize the IDs for checkpoints.

Class org.apache.flink.streaming.api.functions.source.MultipleIdsMessageAcknowledgingSourceBase extends MessageAcknowledgingSourceBase<Type,UId> implements Serializable

serialVersionUID:

42L

Class org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.source.RichSourceFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

delayBetweenRetries

long delayBetweenRetries

Deprecated.

delimiter

String delimiter

Deprecated.

hostname

String hostname

Deprecated.

isRunning

boolean isRunning

Deprecated.

maxNumRetries

long maxNumRetries

Deprecated.

port

int port

Deprecated.

Class org.apache.flink.streaming.api.functions.source.StatefulSequenceSource extends RichParallelSourceFunction<Long> implements Serializable

serialVersionUID:

1L

Serialized Fields

end

long end

Deprecated.

isRunning

boolean isRunning

Deprecated.

start

long start

Deprecated.

Class org.apache.flink.streaming.api.functions.source.TimestampedFileInputSplit extends org.apache.flink.core.fs.FileInputSplit implements Serializable

serialVersionUID:

-8153252402661556005L

Serialized Fields

modificationTime

long modificationTime

The modification time of the file this split belongs to.

splitState

Serializable splitState

The state of the split. This information is used when restoring from a checkpoint and allows to resume reading the underlying file from the point we left off.

Package org.apache.flink.streaming.api.functions.source.datagen

Class org.apache.flink.streaming.api.functions.source.datagen.DataGeneratorSource extends RichParallelSourceFunction<T> implements Serializable

serialVersionUID:

1L

Serialized Fields

generator

DataGenerator<T> generator

Deprecated.

numberOfRows

Long numberOfRows

Deprecated.

rowsPerSecond

long rowsPerSecond

Deprecated.

Class org.apache.flink.streaming.api.functions.source.datagen.RandomGenerator extends Object implements Serializable

Serialized Fields

nullRate

float nullRate

varLen

boolean varLen

Class org.apache.flink.streaming.api.functions.source.datagen.SequenceGenerator extends Object implements Serializable

Serialized Fields

end

long end

start

long start

Package org.apache.flink.streaming.api.functions.timestamps

Class org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

currentTimestamp

long currentTimestamp

Deprecated.

The current timestamp.

violationHandler

AscendingTimestampExtractor.MonotonyViolationHandler violationHandler

Deprecated.

Handler that is called when timestamp monotony is violated.

Class org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor.FailingHandler extends Object implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor.IgnoringHandler extends Object implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor.LoggingHandler extends Object implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.timestamps.BoundedOutOfOrdernessTimestampExtractor extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

currentMaxTimestamp

long currentMaxTimestamp

The current maximum timestamp seen so far.

lastEmittedWatermark

long lastEmittedWatermark

The timestamp of the last emitted watermark.

maxOutOfOrderness

long maxOutOfOrderness

The (fixed) interval between the maximum seen timestamp seen in the records and that of the watermark to be emitted.

Package org.apache.flink.streaming.api.functions.windowing

Class org.apache.flink.streaming.api.functions.windowing.AggregateApplyAllWindowFunction extends org.apache.flink.api.java.operators.translation.WrappingFunction<AllWindowFunction<V,R,W extends Window>> implements Serializable

serialVersionUID:

1L

Serialized Fields

aggFunction

org.apache.flink.api.common.functions.AggregateFunction<T,ACC,V> aggFunction

Class org.apache.flink.streaming.api.functions.windowing.AggregateApplyWindowFunction extends org.apache.flink.api.java.operators.translation.WrappingFunction<WindowFunction<V,R,K,W extends Window>> implements Serializable

serialVersionUID:

1L

Serialized Fields

aggFunction

org.apache.flink.api.common.functions.AggregateFunction<T,ACC,V> aggFunction

Class org.apache.flink.streaming.api.functions.windowing.InternalProcessApplyWindowContext extends ProcessWindowFunction.Context implements Serializable

Serialized Fields

context

ProcessWindowFunction.Context context

window

W extends Window window

Class org.apache.flink.streaming.api.functions.windowing.PassThroughAllWindowFunction extends Object implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.windowing.PassThroughWindowFunction extends Object implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.windowing.ProcessAllWindowFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction.Context extends Object implements Serializable

Class org.apache.flink.streaming.api.functions.windowing.ReduceApplyAllWindowFunction extends org.apache.flink.api.java.operators.translation.WrappingFunction<AllWindowFunction<T,R,W extends Window>> implements Serializable

serialVersionUID:

1L

Serialized Fields

reduceFunction

org.apache.flink.api.common.functions.ReduceFunction<T> reduceFunction

Class org.apache.flink.streaming.api.functions.windowing.ReduceApplyProcessAllWindowFunction extends ProcessAllWindowFunction<T,R,W extends Window> implements Serializable

serialVersionUID:

1L

Serialized Fields

reduceFunction

org.apache.flink.api.common.functions.ReduceFunction<T> reduceFunction

windowFunction

ProcessAllWindowFunction<T,R,W extends Window> windowFunction

Class org.apache.flink.streaming.api.functions.windowing.ReduceApplyProcessWindowFunction extends ProcessWindowFunction<T,R,K,W extends Window> implements Serializable

serialVersionUID:

1L

Serialized Fields

reduceFunction

org.apache.flink.api.common.functions.ReduceFunction<T> reduceFunction

windowFunction

ProcessWindowFunction<T,R,K,W extends Window> windowFunction

Class org.apache.flink.streaming.api.functions.windowing.ReduceApplyWindowFunction extends org.apache.flink.api.java.operators.translation.WrappingFunction<WindowFunction<T,R,K,W extends Window>> implements Serializable

serialVersionUID:

1L

Serialized Fields

reduceFunction

org.apache.flink.api.common.functions.ReduceFunction<T> reduceFunction

Class org.apache.flink.streaming.api.functions.windowing.RichAllWindowFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.windowing.RichProcessAllWindowFunction extends ProcessAllWindowFunction<IN,OUT,W extends Window> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.windowing.RichProcessWindowFunction extends ProcessWindowFunction<IN,OUT,KEY,W extends Window> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.windowing.RichWindowFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

serialVersionUID:

1L

Package org.apache.flink.streaming.api.functions.windowing.delta

Class org.apache.flink.streaming.api.functions.windowing.delta.CosineDistance extends ExtractionAwareDeltaFunction<DATA,double[]> implements Serializable

serialVersionUID:

-1217813582965151599L

Class org.apache.flink.streaming.api.functions.windowing.delta.EuclideanDistance extends ExtractionAwareDeltaFunction<DATA,double[]> implements Serializable

serialVersionUID:

3119432599634512359L

Class org.apache.flink.streaming.api.functions.windowing.delta.ExtractionAwareDeltaFunction extends Object implements Serializable

serialVersionUID:

6927486219702689554L

Serialized Fields

converter

Extractor<DATA,TO> converter

Package org.apache.flink.streaming.api.functions.windowing.delta.extractor

Class org.apache.flink.streaming.api.functions.windowing.delta.extractor.ArrayFromTuple extends Object implements Serializable

serialVersionUID:

-6076121226427616818L

Serialized Fields

order

int[] order

Class org.apache.flink.streaming.api.functions.windowing.delta.extractor.ConcatenatedExtract extends Object implements Serializable

serialVersionUID:

-7807197760725651752L

Serialized Fields

e1

Extractor<FROM,OVER> e1

e2

Extractor<OVER,TO> e2

Class org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldFromArray extends Object implements Serializable

serialVersionUID:

-5161386546695574359L

Serialized Fields

fieldId

int fieldId

Class org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldFromTuple extends Object implements Serializable

serialVersionUID:

-5161386546695574359L

Serialized Fields

fieldId

int fieldId

Class org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldsFromArray extends Object implements Serializable

serialVersionUID:

8075055384516397670L

Serialized Fields

clazz

Class<OUT> clazz

order

int[] order

Class org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldsFromTuple extends Object implements Serializable

serialVersionUID:

-2554079091050273761L

Serialized Fields

indexes

int[] indexes

Package org.apache.flink.streaming.api.graph

Class org.apache.flink.streaming.api.graph.NonChainedOutput extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

bufferTimeout

long bufferTimeout

Buffer flush timeout of this output.

consumerMaxParallelism

int consumerMaxParallelism

Max parallelism of the consumer vertex.

consumerParallelism

int consumerParallelism

Parallelism of the consumer vertex.

dataSetId

org.apache.flink.runtime.jobgraph.IntermediateDataSetID dataSetId

ID of the produced intermediate dataset.

isPersistentDataSet

boolean isPersistentDataSet

Whether this intermediate dataset is a persistent dataset or not.

outputTag

org.apache.flink.util.OutputTag<?> outputTag

The side-output tag (if any).

partitioner

StreamPartitioner<?> partitioner

The corresponding data partitioner.

partitionType

org.apache.flink.runtime.io.network.partition.ResultPartitionType partitionType

Target ResultPartitionType.

sourceNodeId

int sourceNodeId

ID of the producer StreamNode.

supportsUnalignedCheckpoints

boolean supportsUnalignedCheckpoints

Is unaligned checkpoint supported.

Class org.apache.flink.streaming.api.graph.StreamConfig extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

config

org.apache.flink.configuration.Configuration config

removedKeys

Set<String> removedKeys

In order to release memory during processing data, some keys are removed in StreamConfig.clearInitialConfigs(). Recording these keys here to prevent they are accessed after removing.

Class org.apache.flink.streaming.api.graph.StreamConfig.NetworkInputConfig extends Object implements Serializable

Serialized Fields

inputGateIndex

int inputGateIndex

inputRequirement

StreamConfig.InputRequirement inputRequirement

typeSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<?> typeSerializer

Class org.apache.flink.streaming.api.graph.StreamConfig.SourceInputConfig extends Object implements Serializable

Serialized Fields

inputEdge

StreamEdge inputEdge

Class org.apache.flink.streaming.api.graph.StreamEdge extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

bufferTimeout

long bufferTimeout

edgeId

String edgeId

exchangeMode

StreamExchangeMode exchangeMode

intermediateDatasetIdToProduce

org.apache.flink.runtime.jobgraph.IntermediateDataSetID intermediateDatasetIdToProduce

outputPartitioner

StreamPartitioner<?> outputPartitioner

The StreamPartitioner on this StreamEdge.

outputTag

org.apache.flink.util.OutputTag outputTag

The side-output tag (if any) of this StreamEdge.

sourceId

int sourceId

sourceOperatorName

String sourceOperatorName

The name of the operator in the source vertex.

supportsUnalignedCheckpoints

boolean supportsUnalignedCheckpoints

targetId

int targetId

targetOperatorName

String targetOperatorName

The name of the operator in the target vertex.

typeNumber

int typeNumber

The type number of the input for co-tasks.

uniqueId

int uniqueId

Note that this field doesn't have to be unique among all StreamEdges. It's enough if this field ensures that all logical instances of StreamEdge are unique, and StreamEdge.hashCode() are different and StreamEdge.equals(Object) returns false, for every possible pair of StreamEdge. Especially among two different StreamEdges that are connecting the same pair of nodes.

Package org.apache.flink.streaming.api.operators

Class org.apache.flink.streaming.api.operators.AbstractStreamOperator extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

chainingStrategy

ChainingStrategy chainingStrategy

Class org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory extends Object implements Serializable

Serialized Fields

chainingStrategy

ChainingStrategy chainingStrategy

Class org.apache.flink.streaming.api.operators.AbstractStreamOperatorV2 extends Object implements Serializable

Serialized Fields

cancelables

org.apache.flink.core.fs.CloseableRegistry cancelables

combinedWatermark

org.apache.flink.api.common.eventtime.IndexedCombinedWatermarkStatus combinedWatermark

config

StreamConfig config

executionConfig

org.apache.flink.api.common.ExecutionConfig executionConfig

lastRecordAttributes

RecordAttributes[] lastRecordAttributes

latencyStats

LatencyStats latencyStats

mailboxExecutor

org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor

metrics

org.apache.flink.runtime.metrics.groups.InternalOperatorMetricGroup metrics

Metric group for the operator.

output

Output<StreamRecord<OUT>> output

processingTimeService

ProcessingTimeService processingTimeService

runtimeContext

StreamingRuntimeContext runtimeContext

stateHandler

StreamOperatorStateHandler stateHandler

timeServiceManager

InternalTimeServiceManager<?> timeServiceManager

userCodeClassLoader

ClassLoader userCodeClassLoader

watermarkProcessor

MailboxWatermarkProcessor watermarkProcessor

Class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator extends AbstractStreamOperator<OUT> implements Serializable

serialVersionUID:

1L

Serialized Fields

userFunction

F extends org.apache.flink.api.common.functions.Function userFunction

The user function.

Class org.apache.flink.streaming.api.operators.BatchGroupedReduceOperator extends AbstractUdfStreamOperator<IN,org.apache.flink.api.common.functions.ReduceFunction<IN>> implements Serializable

serialVersionUID:

1L

Serialized Fields

serializer

org.apache.flink.api.common.typeutils.TypeSerializer<IN> serializer

timerService

InternalTimerService<org.apache.flink.runtime.state.VoidNamespace> timerService

Class org.apache.flink.streaming.api.operators.InputSelection extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

inputMask

long inputMask

Class org.apache.flink.streaming.api.operators.InternalTimersSnapshotReaderWriters.LegacyTimerSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<TimerHeapInternalTimer<K,N>> implements Serializable

serialVersionUID:

1119562170939152304L

Serialized Fields

keySerializer

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

namespaceSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer

Class org.apache.flink.streaming.api.operators.KeyedProcessOperator extends AbstractUdfStreamOperator<OUT,KeyedProcessFunction<K,IN,OUT>> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.operators.LegacyKeyedProcessOperator extends AbstractUdfStreamOperator<OUT,ProcessFunction<IN,OUT>> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.operators.MapPartitionOperator extends AbstractUdfStreamOperator<OUT,org.apache.flink.api.common.functions.MapPartitionFunction<IN,OUT>> implements Serializable

Serialized Fields

function

org.apache.flink.api.common.functions.MapPartitionFunction<IN,OUT> function

Class org.apache.flink.streaming.api.operators.OperatorAttributes extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

internalSorterSupported

boolean internalSorterSupported

outputOnlyAfterEndOfStream

boolean outputOnlyAfterEndOfStream

Class org.apache.flink.streaming.api.operators.PartitionAggregateOperator extends AbstractUdfStreamOperator<OUT,org.apache.flink.api.common.functions.AggregateFunction<IN,ACC,OUT>> implements Serializable

Serialized Fields

aggregateFunction

org.apache.flink.api.common.functions.AggregateFunction<IN,ACC,OUT> aggregateFunction

currentAccumulator

ACC currentAccumulator

Class org.apache.flink.streaming.api.operators.PartitionReduceOperator extends AbstractUdfStreamOperator<IN,org.apache.flink.api.common.functions.ReduceFunction<IN>> implements Serializable

Serialized Fields

currentRecord

IN currentRecord

reduceFunction

org.apache.flink.api.common.functions.ReduceFunction<IN> reduceFunction

Class org.apache.flink.streaming.api.operators.ProcessOperator extends AbstractUdfStreamOperator<OUT,ProcessFunction<IN,OUT>> implements Serializable

serialVersionUID:

1L

Serialized Fields

currentWatermark

long currentWatermark

We listen to this ourselves because we don't have an InternalTimerService.

Class org.apache.flink.streaming.api.operators.SimpleInputFormatOperatorFactory extends SimpleOperatorFactory<OUT> implements Serializable

Serialized Fields

operator

StreamSource<OUT,InputFormatSourceFunction<OUT>> operator

Class org.apache.flink.streaming.api.operators.SimpleOperatorFactory extends AbstractStreamOperatorFactory<OUT> implements Serializable

Serialized Fields

operator

StreamOperator<OUT> operator

Class org.apache.flink.streaming.api.operators.SimpleOutputFormatOperatorFactory extends SimpleOperatorFactory<OUT> implements Serializable

Serialized Fields

outputFormat

org.apache.flink.api.common.io.OutputFormat<IN> outputFormat

Class org.apache.flink.streaming.api.operators.SimpleUdfStreamOperatorFactory extends SimpleOperatorFactory<OUT> implements Serializable

Serialized Fields

operator

AbstractUdfStreamOperator<OUT,?> operator

Class org.apache.flink.streaming.api.operators.SourceOperator extends AbstractStreamOperator<OUT> implements Serializable

serialVersionUID:

1405537676017904695L

Serialized Fields

allowUnalignedSourceSplits

boolean allowUnalignedSourceSplits

availabilityHelper

org.apache.flink.streaming.api.operators.SourceOperator.SourceOperatorAvailabilityHelper availabilityHelper

canEmitBatchOfRecords

StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords

configuration

org.apache.flink.configuration.Configuration configuration

The Flink configuration.

currentlyPausedSplits

Set<String> currentlyPausedSplits

currentMainOutput

org.apache.flink.api.connector.source.ReaderOutput<OUT> currentMainOutput

currentMaxDesiredWatermark

long currentMaxDesiredWatermark

emitProgressiveWatermarks

boolean emitProgressiveWatermarks

Whether to emit intermediate watermarks or only one final watermark at the end of input.

eventTimeLogic

TimestampsAndWatermarks<OUT> eventTimeLogic

The event time and watermarking logic. Ideally this would be eagerly passed into this operator, but we currently need to instantiate this lazily, because the metric groups exist only later.

finished

CompletableFuture<Void> finished

idle

boolean idle

lastInvokedOutput

PushingAsyncDataInput.DataOutput<OUT> lastInvokedOutput

latencyMarkerEmitter

org.apache.flink.streaming.api.operators.LatencyMarkerEmitter<OUT> latencyMarkerEmitter

latestWatermark

long latestWatermark

localHostname

String localHostname

Host name of the machine where the operator runs, to support locality aware work assignment.

operatingMode

org.apache.flink.streaming.api.operators.SourceOperator.OperatingMode operatingMode

A mode to control the behaviour of the SourceOperator.emitNext(DataOutput) method.

operatorEventGateway

org.apache.flink.runtime.operators.coordination.OperatorEventGateway operatorEventGateway

The event gateway through which this operator talks to its coordinator.

readerFactory

org.apache.flink.util.function.FunctionWithException<org.apache.flink.api.connector.source.SourceReaderContext,org.apache.flink.api.connector.source.SourceReader<OUT,SplitT extends org.apache.flink.api.connector.source.SourceSplit>,Exception> readerFactory

The factory for the source reader. This is a workaround, because currently the SourceReader must be lazily initialized, which is mainly because the metrics groups that the reader relies on is lazily initialized.

readerState

org.apache.flink.api.common.state.ListState<SplitT extends org.apache.flink.api.connector.source.SourceSplit> readerState

The state that holds the currently assigned splits.

sourceMetricGroup

org.apache.flink.runtime.metrics.groups.InternalSourceReaderMetricGroup sourceMetricGroup

sourceReader

org.apache.flink.api.connector.source.SourceReader<OUT,SplitT extends org.apache.flink.api.connector.source.SourceSplit> sourceReader

The source reader that does most of the work.

splitCurrentWatermarks

Map<String,Long> splitCurrentWatermarks

splitSerializer

org.apache.flink.core.io.SimpleVersionedSerializer<SplitT extends org.apache.flink.api.connector.source.SourceSplit> splitSerializer

The serializer for the splits, applied to the split types before storing them in the reader state.

splitsToInitializeOutput

List<SplitT extends org.apache.flink.api.connector.source.SourceSplit> splitsToInitializeOutput

waitingForAlignmentFuture

CompletableFuture<Void> waitingForAlignmentFuture

Can be not completed only in SourceOperator.OperatingMode.WAITING_FOR_ALIGNMENT mode.

watermarkAlignmentParams

org.apache.flink.api.common.eventtime.WatermarkAlignmentParams watermarkAlignmentParams

watermarkStrategy

org.apache.flink.api.common.eventtime.WatermarkStrategy<OUT> watermarkStrategy

The factory for timestamps and watermark generators.

Class org.apache.flink.streaming.api.operators.SourceOperatorFactory extends AbstractStreamOperatorFactory<OUT> implements Serializable

serialVersionUID:

1L

Serialized Fields

coordinatorListeningID

String coordinatorListeningID

emitProgressiveWatermarks

boolean emitProgressiveWatermarks

Whether to emit intermediate watermarks or only one final watermark at the end of input.

numCoordinatorWorkerThread

int numCoordinatorWorkerThread

The number of worker thread for the source coordinator.

source

org.apache.flink.api.connector.source.Source<OUT,?,?> source

The Source to create the SourceOperator.

watermarkStrategy

org.apache.flink.api.common.eventtime.WatermarkStrategy<OUT> watermarkStrategy

The event time setup (timestamp assigners, watermark generators, etc.).

Class org.apache.flink.streaming.api.operators.StreamFilter extends AbstractUdfStreamOperator<IN,org.apache.flink.api.common.functions.FilterFunction<IN>> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.operators.StreamFlatMap extends AbstractUdfStreamOperator<OUT,org.apache.flink.api.common.functions.FlatMapFunction<IN,OUT>> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.operators.StreamGroupedReduceOperator extends AbstractUdfStreamOperator<IN,org.apache.flink.api.common.functions.ReduceFunction<IN>> implements Serializable

serialVersionUID:

1L

Serialized Fields

serializer

org.apache.flink.api.common.typeutils.TypeSerializer<IN> serializer

Class org.apache.flink.streaming.api.operators.StreamMap extends AbstractUdfStreamOperator<OUT,org.apache.flink.api.common.functions.MapFunction<IN,OUT>> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.operators.StreamProject extends AbstractStreamOperator<OUT extends org.apache.flink.api.java.tuple.Tuple> implements Serializable

serialVersionUID:

1L

Serialized Fields

fields

int[] fields

numFields

int numFields

outSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<OUT extends org.apache.flink.api.java.tuple.Tuple> outSerializer

Class org.apache.flink.streaming.api.operators.StreamSink extends AbstractUdfStreamOperator<Object,SinkFunction<IN>> implements Serializable

serialVersionUID:

1L

Serialized Fields

currentWatermark

long currentWatermark

We listen to this ourselves because we don't have an InternalTimerService.

Class org.apache.flink.streaming.api.operators.StreamSource extends AbstractUdfStreamOperator<OUT,SRC extends SourceFunction<OUT>> implements Serializable

serialVersionUID:

1L

Serialized Fields

emitProgressiveWatermarks

boolean emitProgressiveWatermarks

Deprecated.

Whether to emit intermediate watermarks or only one final watermark at the end of input.

Class org.apache.flink.streaming.api.operators.TimerSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<TimerHeapInternalTimer<K,N>> implements Serializable

serialVersionUID:

1L

Serialized Fields

immutableType

boolean immutableType

True iff the serialized type (and composite objects) are immutable.

keySerializer

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

Serializer for the key.

length

int length

The bytes written for one timer, or -1 if variable size.

namespaceSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer

Serializer for the namespace.

Package org.apache.flink.streaming.api.operators.async

Class org.apache.flink.streaming.api.operators.async.AsyncWaitOperator extends AbstractUdfStreamOperator<OUT,AsyncFunction<IN,OUT>> implements Serializable

serialVersionUID:

1L

Serialized Fields

asyncRetryStrategy

AsyncRetryStrategy<OUT> asyncRetryStrategy

AsyncRetryStrategy for the async function.

capacity

int capacity

Capacity of the stream element queue.

outputMode

AsyncDataStream.OutputMode outputMode

Output mode for this operator.

retryEnabled

boolean retryEnabled

If the retry strategy is not no_retry.

timeout

long timeout

Timeout for the async collectors.

Class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorFactory extends AbstractStreamOperatorFactory<OUT> implements Serializable

Serialized Fields

asyncFunction

AsyncFunction<IN,OUT> asyncFunction

asyncRetryStrategy

AsyncRetryStrategy<OUT> asyncRetryStrategy

capacity

int capacity

outputMode

AsyncDataStream.OutputMode outputMode

timeout

long timeout

Package org.apache.flink.streaming.api.operators.co

Class org.apache.flink.streaming.api.operators.co.BatchCoBroadcastWithKeyedOperator extends CoBroadcastWithKeyedOperator<KS,IN1,IN2,OUT> implements Serializable

serialVersionUID:

5926499536290284870L

Class org.apache.flink.streaming.api.operators.co.BatchCoBroadcastWithNonKeyedOperator extends CoBroadcastWithNonKeyedOperator<IN1,IN2,OUT> implements Serializable

serialVersionUID:

-1869740381935471752L

Class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperator extends AbstractUdfStreamOperator<OUT,KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT>> implements Serializable

serialVersionUID:

5926499536290284870L

Serialized Fields

broadcastStateDescriptors

List<org.apache.flink.api.common.state.MapStateDescriptor<?,?>> broadcastStateDescriptors

Class org.apache.flink.streaming.api.operators.co.CoBroadcastWithNonKeyedOperator extends AbstractUdfStreamOperator<OUT,BroadcastProcessFunction<IN1,IN2,OUT>> implements Serializable

serialVersionUID:

-1869740381935471752L

Serialized Fields

broadcastStateDescriptors

List<org.apache.flink.api.common.state.MapStateDescriptor<?,?>> broadcastStateDescriptors

currentWatermark

long currentWatermark

We listen to this ourselves because we don't have an InternalTimerService.

Class org.apache.flink.streaming.api.operators.co.CoProcessOperator extends AbstractUdfStreamOperator<OUT,CoProcessFunction<IN1,IN2,OUT>> implements Serializable

serialVersionUID:

1L

Serialized Fields

currentWatermark

long currentWatermark

We listen to this ourselves because we don't have an InternalTimerService.

Class org.apache.flink.streaming.api.operators.co.CoStreamFlatMap extends AbstractUdfStreamOperator<OUT,CoFlatMapFunction<IN1,IN2,OUT>> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.operators.co.CoStreamMap extends AbstractUdfStreamOperator<OUT,CoMapFunction<IN1,IN2,OUT>> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.operators.co.IntervalJoinOperator extends AbstractUdfStreamOperator<OUT,ProcessJoinFunction<T1,T2,OUT>> implements Serializable

serialVersionUID:

-5380774605111543454L

Serialized Fields

leftLateDataOutputTag

org.apache.flink.util.OutputTag<T1> leftLateDataOutputTag

leftTypeSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<T1> leftTypeSerializer

lowerBound

long lowerBound

rightLateDataOutputTag

org.apache.flink.util.OutputTag<T2> rightLateDataOutputTag

rightTypeSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<T2> rightTypeSerializer

upperBound

long upperBound

Class org.apache.flink.streaming.api.operators.co.IntervalJoinOperator.BufferEntrySerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<IntervalJoinOperator.BufferEntry<T>> implements Serializable

serialVersionUID:

-20197698803836236L

Serialized Fields

elementSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<T> elementSerializer

Class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator extends AbstractUdfStreamOperator<OUT,KeyedCoProcessFunction<K,IN1,IN2,OUT>> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.operators.co.LegacyKeyedCoProcessOperator extends AbstractUdfStreamOperator<OUT,CoProcessFunction<IN1,IN2,OUT>> implements Serializable

serialVersionUID:

1L

Package org.apache.flink.streaming.api.operators.collect

Class org.apache.flink.streaming.api.operators.collect.CollectCoordinationRequest extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

offset

long offset

version

String version

Class org.apache.flink.streaming.api.operators.collect.CollectCoordinationResponse extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

lastCheckpointedOffset

long lastCheckpointedOffset

serializedResults

List<byte[]> serializedResults

version

String version

Class org.apache.flink.streaming.api.operators.collect.CollectSinkAddressEvent extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

address

InetSocketAddress address

Class org.apache.flink.streaming.api.operators.collect.CollectSinkFunction extends RichSinkFunction<IN> implements Serializable

serialVersionUID:

1L

Serialized Fields

accumulatorName

String accumulatorName

bufferSizeLimitBytes

long bufferSizeLimitBytes

maxBytesPerBatch

long maxBytesPerBatch

serializer

org.apache.flink.api.common.typeutils.TypeSerializer<IN> serializer

Class org.apache.flink.streaming.api.operators.collect.CollectSinkOperator extends StreamSink<IN> implements Serializable

Serialized Fields

sinkFunction

CollectSinkFunction<IN> sinkFunction

Class org.apache.flink.streaming.api.operators.collect.CollectSinkOperatorCoordinator.Provider extends Object implements Serializable

Serialized Fields

operatorId

org.apache.flink.runtime.jobgraph.OperatorID operatorId

socketTimeout

int socketTimeout

Class org.apache.flink.streaming.api.operators.collect.CollectSinkOperatorFactory extends SimpleUdfStreamOperatorFactory<Object> implements Serializable

serialVersionUID:

1L

Serialized Fields

operator

CollectSinkOperator<IN> operator

socketTimeoutMillis

int socketTimeoutMillis

Package org.apache.flink.streaming.api.operators.sorted.state

Class org.apache.flink.streaming.api.operators.sorted.state.BatchExecutionCheckpointStorage extends Object implements Serializable

Class org.apache.flink.streaming.api.operators.sorted.state.BatchExecutionStateBackend extends Object implements Serializable

Package org.apache.flink.streaming.api.operators.sortpartition

Class org.apache.flink.streaming.api.operators.sortpartition.FixedLengthByteKeyAndValueComparator extends org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>> implements Serializable

Serialized Fields

keyReference

byte[] keyReference

serializedKeyLength

int serializedKeyLength

valueComparator

org.apache.flink.api.common.typeutils.TypeComparator<INPUT> valueComparator

valueReference

INPUT valueReference

Class org.apache.flink.streaming.api.operators.sortpartition.KeyedSortPartitionOperator extends AbstractStreamOperator<INPUT> implements Serializable

Serialized Fields

dataOutputSerializer

org.apache.flink.core.memory.DataOutputSerializer dataOutputSerializer

A buffer to save the serialized record key.

inputType

org.apache.flink.api.common.typeinfo.TypeInformation<INPUT> inputType

The type information of input records.

positionSortField

int positionSortField

The int field to indicate the sort key for records with tuple type, which will be -1 if it's not used.

recordKeySerializer

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

recordSorter

org.apache.flink.runtime.operators.sort.PushSorter<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>> recordSorter

The sorter to sort both key and record if the record is not sorted by KeySelector.

recordSorterForSelector

org.apache.flink.runtime.operators.sort.PushSorter<org.apache.flink.api.java.tuple.Tuple2<byte[],org.apache.flink.api.java.tuple.Tuple2<?,INPUT>>> recordSorterForSelector

The sorter to sort both key and record if the record is sorted by KeySelector.

sortFieldSelector

org.apache.flink.api.java.functions.KeySelector<INPUT,?> sortFieldSelector

The selector to create the sort key for records, which will be null if it's not used.

sortOrder

org.apache.flink.api.common.operators.Order sortOrder

The order to sort records.

stringSortField

String stringSortField

The string field to indicate the sort key for records with tuple or pojo type, which will be null if it's not used.

Class org.apache.flink.streaming.api.operators.sortpartition.SortPartitionOperator extends AbstractStreamOperator<INPUT> implements Serializable

Serialized Fields

inputType

org.apache.flink.api.common.typeinfo.TypeInformation<INPUT> inputType

The type information of input records.

positionSortField

int positionSortField

The int field to indicate the sort key for records with tuple type, which will be -1 if it's not used.

recordSorter

org.apache.flink.runtime.operators.sort.PushSorter<INPUT> recordSorter

The sorter to sort record if the record is not sorted by KeySelector.

recordSorterForKeySelector

org.apache.flink.runtime.operators.sort.PushSorter<org.apache.flink.api.java.tuple.Tuple2<?,INPUT>> recordSorterForKeySelector

The sorter to sort record if the record is sorted by KeySelector.

sortFieldSelector

org.apache.flink.api.java.functions.KeySelector<INPUT,?> sortFieldSelector

The selector to create the sort key for records, which will be null if it's not used.

sortOrder

org.apache.flink.api.common.operators.Order sortOrder

The order to sort records.

stringSortField

String stringSortField

The string field to indicate the sort key for records with tuple or pojo type, which will be null if it's not used.

Class org.apache.flink.streaming.api.operators.sortpartition.VariableLengthByteKeyAndValueComparator extends org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>> implements Serializable

Serialized Fields

keyReference

byte[] keyReference

valueComparator

org.apache.flink.api.common.typeutils.TypeComparator<INPUT> valueComparator

valueReference

INPUT valueReference

Package org.apache.flink.streaming.api.transformations

Class org.apache.flink.streaming.api.transformations.SinkV1Adapter extends Object implements Serializable

Serialized Fields

sink

org.apache.flink.api.connector.sink.Sink<InputT,CommT,WriterStateT,GlobalCommT> sink

Package org.apache.flink.streaming.api.windowing.assigners

Class org.apache.flink.streaming.api.windowing.assigners.DynamicEventTimeSessionWindows extends MergingWindowAssigner<T,TimeWindow> implements Serializable

serialVersionUID:

1L

Serialized Fields

sessionWindowTimeGapExtractor

SessionWindowTimeGapExtractor<T> sessionWindowTimeGapExtractor

Class org.apache.flink.streaming.api.windowing.assigners.DynamicProcessingTimeSessionWindows extends MergingWindowAssigner<T,TimeWindow> implements Serializable

serialVersionUID:

1L

Serialized Fields

sessionWindowTimeGapExtractor

SessionWindowTimeGapExtractor<T> sessionWindowTimeGapExtractor

Class org.apache.flink.streaming.api.windowing.assigners.EventTimeSessionWindows extends MergingWindowAssigner<Object,TimeWindow> implements Serializable

serialVersionUID:

1L

Serialized Fields

sessionTimeout

long sessionTimeout

Class org.apache.flink.streaming.api.windowing.assigners.GlobalWindows extends WindowAssigner<Object,GlobalWindow> implements Serializable

serialVersionUID:

1L

Serialized Fields

defaultTrigger

Trigger<Object,GlobalWindow> defaultTrigger

Class org.apache.flink.streaming.api.windowing.assigners.GlobalWindows.EndOfStreamTrigger extends Trigger<Object,GlobalWindow> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.windowing.assigners.GlobalWindows.NeverTrigger extends Trigger<Object,GlobalWindow> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.windowing.assigners.MergingWindowAssigner extends WindowAssigner<T,W extends Window> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.windowing.assigners.ProcessingTimeSessionWindows extends MergingWindowAssigner<Object,TimeWindow> implements Serializable

serialVersionUID:

1L

Serialized Fields

sessionTimeout

long sessionTimeout

Class org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows extends WindowAssigner<Object,TimeWindow> implements Serializable

serialVersionUID:

1L

Serialized Fields

offset

long offset

size

long size

slide

long slide

Class org.apache.flink.streaming.api.windowing.assigners.SlidingProcessingTimeWindows extends WindowAssigner<Object,TimeWindow> implements Serializable

serialVersionUID:

1L

Serialized Fields

offset

long offset

size

long size

slide

long slide

Class org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows extends WindowAssigner<Object,TimeWindow> implements Serializable

serialVersionUID:

1L

Serialized Fields

globalOffset

long globalOffset

size

long size

staggerOffset

Long staggerOffset

windowStagger

WindowStagger windowStagger

Class org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows extends WindowAssigner<Object,TimeWindow> implements Serializable

serialVersionUID:

1L

Serialized Fields

globalOffset

long globalOffset

size

long size

staggerOffset

Long staggerOffset

windowStagger

WindowStagger windowStagger

Class org.apache.flink.streaming.api.windowing.assigners.WindowAssigner extends Object implements Serializable

serialVersionUID:

1L

Package org.apache.flink.streaming.api.windowing.evictors

Class org.apache.flink.streaming.api.windowing.evictors.CountEvictor extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

doEvictAfter

boolean doEvictAfter

maxCount

long maxCount

Class org.apache.flink.streaming.api.windowing.evictors.DeltaEvictor extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

deltaFunction

DeltaFunction<T> deltaFunction

doEvictAfter

boolean doEvictAfter

threshold

double threshold

Class org.apache.flink.streaming.api.windowing.evictors.TimeEvictor extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

doEvictAfter

boolean doEvictAfter

windowSize

long windowSize

Package org.apache.flink.streaming.api.windowing.triggers

Class org.apache.flink.streaming.api.windowing.triggers.ContinuousEventTimeTrigger extends Trigger<Object,W extends Window> implements Serializable

serialVersionUID:

1L

Serialized Fields

interval

long interval

stateDesc

org.apache.flink.api.common.state.ReducingStateDescriptor<Long> stateDesc

When merging we take the lowest of all fire timestamps as the new fire timestamp.

Class org.apache.flink.streaming.api.windowing.triggers.ContinuousProcessingTimeTrigger extends Trigger<Object,W extends Window> implements Serializable

serialVersionUID:

1L

Serialized Fields

interval

long interval

stateDesc

org.apache.flink.api.common.state.ReducingStateDescriptor<Long> stateDesc

When merging we take the lowest of all fire timestamps as the new fire timestamp.

Class org.apache.flink.streaming.api.windowing.triggers.CountTrigger extends Trigger<Object,W extends Window> implements Serializable

serialVersionUID:

1L

Serialized Fields

maxCount

long maxCount

stateDesc

org.apache.flink.api.common.state.ReducingStateDescriptor<Long> stateDesc

Class org.apache.flink.streaming.api.windowing.triggers.DeltaTrigger extends Trigger<T,W extends Window> implements Serializable

serialVersionUID:

1L

Serialized Fields

deltaFunction

DeltaFunction<T> deltaFunction

stateDesc

org.apache.flink.api.common.state.ValueStateDescriptor<T> stateDesc

threshold

double threshold

Class org.apache.flink.streaming.api.windowing.triggers.EventTimeTrigger extends Trigger<Object,TimeWindow> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.windowing.triggers.ProcessingTimeoutTrigger extends Trigger<T,W extends Window> implements Serializable

serialVersionUID:

1L

Serialized Fields

interval

long interval

nestedTrigger

Trigger<T,W extends Window> nestedTrigger

resetTimerOnNewRecord

boolean resetTimerOnNewRecord

shouldClearOnTimeout

boolean shouldClearOnTimeout

timeoutStateDesc

org.apache.flink.api.common.state.ValueStateDescriptor<Long> timeoutStateDesc

Class org.apache.flink.streaming.api.windowing.triggers.ProcessingTimeTrigger extends Trigger<Object,TimeWindow> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.windowing.triggers.PurgingTrigger extends Trigger<T,W extends Window> implements Serializable

serialVersionUID:

1L

Serialized Fields

nestedTrigger

Trigger<T,W extends Window> nestedTrigger

Class org.apache.flink.streaming.api.windowing.triggers.Trigger extends Object implements Serializable

serialVersionUID:

-4104633972991191369L

Package org.apache.flink.streaming.api.windowing.windows

Class org.apache.flink.streaming.api.windowing.windows.GlobalWindow.Serializer extends org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton<GlobalWindow> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.windowing.windows.TimeWindow.Serializer extends org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton<TimeWindow> implements Serializable

serialVersionUID:

1L

Package org.apache.flink.streaming.experimental

Class org.apache.flink.streaming.experimental.CollectSink extends RichSinkFunction<IN> implements Serializable

serialVersionUID:

1L

Serialized Fields

hostIp

InetAddress hostIp

port

int port

serializer

org.apache.flink.api.common.typeutils.TypeSerializer<IN> serializer

Package org.apache.flink.streaming.runtime.operators

Class org.apache.flink.streaming.runtime.operators.CheckpointCommitter extends Object implements Serializable

Serialized Fields

jobId

String jobId

operatorId

String operatorId

Class org.apache.flink.streaming.runtime.operators.GenericWriteAheadSink extends AbstractStreamOperator<IN> implements Serializable

serialVersionUID:

1L

Serialized Fields

committer

CheckpointCommitter committer

id

String id

pendingCheckpoints

Set<org.apache.flink.streaming.runtime.operators.GenericWriteAheadSink.PendingCheckpoint> pendingCheckpoints

serializer

org.apache.flink.api.common.typeutils.TypeSerializer<IN> serializer

Class org.apache.flink.streaming.runtime.operators.TimestampsAndWatermarksOperator extends AbstractStreamOperator<T> implements Serializable

serialVersionUID:

1L

Serialized Fields

emitProgressiveWatermarks

boolean emitProgressiveWatermarks

Whether to emit intermediate watermarks or only one final watermark at the end of input.

watermarkStrategy

org.apache.flink.api.common.eventtime.WatermarkStrategy<T> watermarkStrategy

Package org.apache.flink.streaming.runtime.operators.asyncprocessing

Class org.apache.flink.streaming.runtime.operators.asyncprocessing.AbstractAsyncStateStreamOperator extends AbstractStreamOperator<OUT> implements Serializable

Serialized Fields

asyncExecutionController

org.apache.flink.runtime.asyncprocessing.AsyncExecutionController asyncExecutionController

currentProcessingContext

org.apache.flink.runtime.asyncprocessing.RecordContext currentProcessingContext

environment

org.apache.flink.runtime.execution.Environment environment

Class org.apache.flink.streaming.runtime.operators.asyncprocessing.AbstractAsyncStateStreamOperatorV2 extends AbstractStreamOperatorV2<OUT> implements Serializable

Serialized Fields

asyncExecutionController

org.apache.flink.runtime.asyncprocessing.AsyncExecutionController asyncExecutionController

currentProcessingContext

org.apache.flink.runtime.asyncprocessing.RecordContext currentProcessingContext

environment

org.apache.flink.runtime.execution.Environment environment

Class org.apache.flink.streaming.runtime.operators.asyncprocessing.AbstractAsyncStateUdfStreamOperator extends AbstractAsyncStateStreamOperator<OUT> implements Serializable

serialVersionUID:

1L

Serialized Fields

userFunction

F extends org.apache.flink.api.common.functions.Function userFunction

The user function.

Package org.apache.flink.streaming.runtime.operators.sink

Class org.apache.flink.streaming.runtime.operators.sink.CommitterOperatorFactory extends AbstractStreamOperatorFactory<CommittableMessage<CommT>> implements Serializable

Serialized Fields

isBatchMode

boolean isBatchMode

isCheckpointingEnabled

boolean isCheckpointingEnabled

sink

org.apache.flink.api.connector.sink2.SupportsCommitter<CommT> sink

Class org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperatorFactory extends AbstractStreamOperatorFactory<CommittableMessage<CommT>> implements Serializable

Serialized Fields

sink

org.apache.flink.api.connector.sink2.Sink<InputT> sink

Package org.apache.flink.streaming.runtime.operators.util

Class org.apache.flink.streaming.runtime.operators.util.AssignerWithPeriodicWatermarksAdapter.Strategy extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

wms

AssignerWithPeriodicWatermarks<T> wms

Class org.apache.flink.streaming.runtime.operators.util.AssignerWithPunctuatedWatermarksAdapter.Strategy extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

wms

AssignerWithPunctuatedWatermarks<T> wms

Package org.apache.flink.streaming.runtime.operators.windowing

Class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperator extends WindowOperator<K,IN,Iterable<IN>,OUT,W extends Window> implements Serializable

serialVersionUID:

1L

Serialized Fields

evictingWindowStateDescriptor

org.apache.flink.api.common.state.StateDescriptor<? extends org.apache.flink.api.common.state.ListState<StreamRecord<IN>>,?> evictingWindowStateDescriptor

evictor

Evictor<? super IN,? super W extends Window> evictor

Class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator extends AbstractUdfStreamOperator<OUT,InternalWindowFunction<ACC,OUT,K,W extends Window>> implements Serializable

serialVersionUID:

1L

Serialized Fields

allowedLateness

long allowedLateness

The allowed lateness for elements. This is used for:

• Deciding if an element should be dropped from a window due to lateness.
• Clearing the state of a window if the system time passes the window.maxTimestamp + allowedLateness landmark.

keySelector

org.apache.flink.api.java.functions.KeySelector<IN,K> keySelector

keySerializer

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

For serializing the key in checkpoints.

lateDataOutputTag

org.apache.flink.util.OutputTag<IN> lateDataOutputTag

OutputTag to use for late arriving events. Elements for which window.maxTimestamp + allowedLateness is smaller than the current watermark will be emitted to this.

trigger

Trigger<? super IN,? super W extends Window> trigger

windowAssigner

WindowAssigner<? super IN,W extends Window> windowAssigner

windowSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<W extends Window> windowSerializer

For serializing the window in checkpoints.

windowStateDescriptor

org.apache.flink.api.common.state.StateDescriptor<? extends org.apache.flink.api.common.state.AppendingState<IN,ACC>,?> windowStateDescriptor

Class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.WindowContext extends Object implements Serializable

Serialized Fields

window

W extends Window window

windowState

WindowOperator.AbstractPerWindowStateStore windowState

Package org.apache.flink.streaming.runtime.operators.windowing.functions

Class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalAggregateProcessAllWindowFunction extends org.apache.flink.api.java.operators.translation.WrappingFunction<ProcessAllWindowFunction<V,R,W extends Window>> implements Serializable

serialVersionUID:

1L

Serialized Fields

aggFunction

org.apache.flink.api.common.functions.AggregateFunction<T,ACC,V> aggFunction

Class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalAggregateProcessWindowFunction extends org.apache.flink.api.java.operators.translation.WrappingFunction<ProcessWindowFunction<V,R,K,W extends Window>> implements Serializable

serialVersionUID:

1L

Serialized Fields

aggFunction

org.apache.flink.api.common.functions.AggregateFunction<T,ACC,V> aggFunction

ctx

InternalProcessWindowContext<V,R,K,W extends Window> ctx

Class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalIterableAllWindowFunction extends org.apache.flink.api.java.operators.translation.WrappingFunction<AllWindowFunction<IN,OUT,W extends Window>> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalIterableProcessAllWindowFunction extends org.apache.flink.api.java.operators.translation.WrappingFunction<ProcessAllWindowFunction<IN,OUT,W extends Window>> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalIterableProcessWindowFunction extends org.apache.flink.api.java.operators.translation.WrappingFunction<ProcessWindowFunction<IN,OUT,KEY,W extends Window>> implements Serializable

serialVersionUID:

1L

Serialized Fields

ctx

InternalProcessWindowContext<IN,OUT,KEY,W extends Window> ctx

Class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalIterableWindowFunction extends org.apache.flink.api.java.operators.translation.WrappingFunction<WindowFunction<IN,OUT,KEY,W extends Window>> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalProcessWindowContext extends ProcessWindowFunction.Context implements Serializable

Serialized Fields

internalContext

InternalWindowFunction.InternalWindowContext internalContext

window

W extends Window window

Class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalSingleValueAllWindowFunction extends org.apache.flink.api.java.operators.translation.WrappingFunction<AllWindowFunction<IN,OUT,W extends Window>> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalSingleValueProcessAllWindowFunction extends org.apache.flink.api.java.operators.translation.WrappingFunction<ProcessAllWindowFunction<IN,OUT,W extends Window>> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalSingleValueProcessWindowFunction extends org.apache.flink.api.java.operators.translation.WrappingFunction<ProcessWindowFunction<IN,OUT,KEY,W extends Window>> implements Serializable

serialVersionUID:

1L

Serialized Fields

ctx

InternalProcessWindowContext<IN,OUT,KEY,W extends Window> ctx

Class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalSingleValueWindowFunction extends org.apache.flink.api.java.operators.translation.WrappingFunction<WindowFunction<IN,OUT,KEY,W extends Window>> implements Serializable

serialVersionUID:

1L

Package org.apache.flink.streaming.runtime.partitioner

Class org.apache.flink.streaming.runtime.partitioner.BroadcastPartitioner extends StreamPartitioner<T> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.runtime.partitioner.CustomPartitionerWrapper extends StreamPartitioner<T> implements Serializable

serialVersionUID:

1L

Serialized Fields

keySelector

org.apache.flink.api.java.functions.KeySelector<T,K> keySelector

partitioner

org.apache.flink.api.common.functions.Partitioner<K> partitioner

Class org.apache.flink.streaming.runtime.partitioner.ForwardForConsecutiveHashPartitioner extends ForwardPartitioner<T> implements Serializable

Serialized Fields

hashPartitioner

StreamPartitioner<T> hashPartitioner

Class org.apache.flink.streaming.runtime.partitioner.ForwardForUnspecifiedPartitioner extends ForwardPartitioner<T> implements Serializable

Class org.apache.flink.streaming.runtime.partitioner.ForwardPartitioner extends StreamPartitioner<T> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.runtime.partitioner.GlobalPartitioner extends StreamPartitioner<T> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner extends StreamPartitioner<T> implements Serializable

serialVersionUID:

1L

Serialized Fields

keySelector

org.apache.flink.api.java.functions.KeySelector<T,K> keySelector

maxParallelism

int maxParallelism

Class org.apache.flink.streaming.runtime.partitioner.RebalancePartitioner extends StreamPartitioner<T> implements Serializable

serialVersionUID:

1L

Serialized Fields

nextChannelToSendTo

int nextChannelToSendTo

Class org.apache.flink.streaming.runtime.partitioner.RescalePartitioner extends StreamPartitioner<T> implements Serializable

serialVersionUID:

1L

Serialized Fields

nextChannelToSendTo

int nextChannelToSendTo

Class org.apache.flink.streaming.runtime.partitioner.ShufflePartitioner extends StreamPartitioner<T> implements Serializable

serialVersionUID:

1L

Serialized Fields

random

Random random

Class org.apache.flink.streaming.runtime.partitioner.StreamPartitioner extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

numberOfChannels

int numberOfChannels

supportsUnalignedCheckpoint

boolean supportsUnalignedCheckpoint

By default, all partitioner except StreamPartitioner.isBroadcast() or StreamPartitioner.isPointwise() support unaligned checkpoints. However, transformations may disable unaligned checkpoints for specific cases.

Package org.apache.flink.streaming.runtime.streamrecord

Class org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<StreamElement> implements Serializable

serialVersionUID:

1L

Serialized Fields

typeSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<T> typeSerializer

Package org.apache.flink.streaming.runtime.tasks

Class org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException extends org.apache.flink.util.WrappingRuntimeException implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.runtime.tasks.StreamTaskException extends RuntimeException implements Serializable

serialVersionUID:

8392043527067472439L

Class org.apache.flink.streaming.runtime.tasks.TimerException extends org.apache.flink.runtime.taskmanager.AsynchronousException implements Serializable

serialVersionUID:

1L

Package org.apache.flink.streaming.runtime.tasks.mailbox

Class org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailbox.MailboxClosedException extends IllegalStateException implements Serializable

Package org.apache.flink.streaming.runtime.translators

Class org.apache.flink.streaming.runtime.translators.CacheTransformationTranslator.IdentityStreamOperator extends AbstractStreamOperator<T> implements Serializable

serialVersionUID:

4517845269225218313L

Class org.apache.flink.streaming.runtime.translators.CacheTransformationTranslator.NoOpStreamOperator extends AbstractStreamOperator<T> implements Serializable

serialVersionUID:

4517845269225218313L

Package org.apache.flink.streaming.util.keys

Class org.apache.flink.streaming.util.keys.KeySelectorUtil.ArrayKeySelector extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

fields

int[] fields

Class org.apache.flink.streaming.util.keys.KeySelectorUtil.ComparableKeySelector extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

comparator

org.apache.flink.api.common.typeutils.TypeComparator<IN> comparator

keyArray

Object[] keyArray

Reusable array to hold the key objects. Since this is initially empty (all positions are null), it does not have any serialization problems

keyLength

int keyLength

Class org.apache.flink.streaming.util.keys.KeySelectorUtil.OneKeySelector extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

comparator

org.apache.flink.api.common.typeutils.TypeComparator<IN> comparator

keyArray

Object[] keyArray

Reusable array to hold the key objects. Since this is initially empty (all positions are null), it does not have any serialization problems

Package org.apache.flink.streaming.util.retryable

Class org.apache.flink.streaming.util.retryable.AsyncRetryStrategies.ExponentialBackoffDelayRetryStrategy extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

exceptionPredicate

java.util.function.Predicate<Throwable> exceptionPredicate

initialDelay

long initialDelay

lastRetryDelay

long lastRetryDelay

maxAttempts

int maxAttempts

maxRetryDelay

long maxRetryDelay

multiplier

double multiplier

resultPredicate

java.util.function.Predicate<Collection<OUT>> resultPredicate

Class org.apache.flink.streaming.util.retryable.AsyncRetryStrategies.FixedDelayRetryStrategy extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

backoffTimeMillis

long backoffTimeMillis

exceptionPredicate

java.util.function.Predicate<Throwable> exceptionPredicate

maxAttempts

int maxAttempts

resultPredicate

java.util.function.Predicate<Collection<OUT>> resultPredicate

Package org.apache.flink.streaming.util.serialization

Class org.apache.flink.streaming.util.serialization.AbstractDeserializationSchema extends org.apache.flink.api.common.serialization.AbstractDeserializationSchema<T> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.util.serialization.SimpleStringSchema extends org.apache.flink.api.common.serialization.SimpleStringSchema implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.util.serialization.TypeInformationSerializationSchema extends org.apache.flink.api.common.serialization.TypeInformationSerializationSchema<T> implements Serializable

serialVersionUID:

-5359448468131559102L

Package org.apache.flink.streaming.util.typeutils

Class org.apache.flink.streaming.util.typeutils.FieldAccessor extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

fieldType

org.apache.flink.api.common.typeinfo.TypeInformation fieldType

Class org.apache.flink.streaming.util.typeutils.FieldAccessorFactory extends Object implements Serializable