Serialized Form

Package org.apache.flink.datastream.impl.operators

Class org.apache.flink.datastream.impl.operators.KeyedProcessOperator extends ProcessOperator<IN,OUT> implements Serializable

Serialized Fields

outKeySelector

org.apache.flink.api.java.functions.KeySelector<OUT,KEY> outKeySelector

Class org.apache.flink.datastream.impl.operators.KeyedTwoInputBroadcastProcessOperator extends TwoInputBroadcastProcessOperator<IN1,IN2,OUT> implements Serializable

Serialized Fields

outKeySelector

org.apache.flink.api.java.functions.KeySelector<OUT,KEY> outKeySelector

Class org.apache.flink.datastream.impl.operators.KeyedTwoInputNonBroadcastProcessOperator extends TwoInputNonBroadcastProcessOperator<IN1,IN2,OUT> implements Serializable

Serialized Fields

outKeySelector

org.apache.flink.api.java.functions.KeySelector<OUT,KEY> outKeySelector

Class org.apache.flink.datastream.impl.operators.KeyedTwoOutputProcessOperator extends TwoOutputProcessOperator<IN,OUT_MAIN,OUT_SIDE> implements Serializable

Serialized Fields

mainOutKeySelector

org.apache.flink.api.java.functions.KeySelector<OUT_MAIN,KEY> mainOutKeySelector

sideOutKeySelector

org.apache.flink.api.java.functions.KeySelector<OUT_SIDE,KEY> sideOutKeySelector

Class org.apache.flink.datastream.impl.operators.ProcessOperator extends org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator<OUT,org.apache.flink.datastream.api.function.OneInputStreamProcessFunction<IN,OUT>> implements Serializable

Class org.apache.flink.datastream.impl.operators.TwoInputBroadcastProcessOperator extends org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator<OUT,org.apache.flink.datastream.api.function.TwoInputBroadcastStreamProcessFunction<IN1,IN2,OUT>> implements Serializable

Class org.apache.flink.datastream.impl.operators.TwoInputNonBroadcastProcessOperator extends org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator<OUT,org.apache.flink.datastream.api.function.TwoInputNonBroadcastStreamProcessFunction<IN1,IN2,OUT>> implements Serializable

Class org.apache.flink.datastream.impl.operators.TwoOutputProcessOperator extends org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator<OUT_MAIN,org.apache.flink.datastream.api.function.TwoOutputStreamProcessFunction<IN,OUT_MAIN,OUT_SIDE>> implements Serializable

Serialized Fields

outputTag

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

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 extends Object,CommT extends Object,WriterStateT extends Object,GlobalCommT extends Object> sink

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

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

serialVersionUID:

4517845269225218313L

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

serialVersionUID:

4517845269225218313L