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

Interface SetupableStreamOperator<OUT>

Type Parameters:

OUT - The output type of the operator

All Known Implementing Classes:

AbstractStreamOperator, AbstractUdfStreamOperator, AsyncWaitOperator, BatchCoBroadcastWithKeyedOperator, BatchCoBroadcastWithNonKeyedOperator, BatchGroupedReduceOperator, CacheTransformationTranslator.IdentityStreamOperator, CacheTransformationTranslator.NoOpStreamOperator, CoBroadcastWithKeyedOperator, CoBroadcastWithNonKeyedOperator, CollectSinkOperator, ContinuousFileReaderOperator, CoProcessOperator, CoStreamFlatMap, CoStreamMap, EvictingWindowOperator, GenericWriteAheadSink, IntervalJoinOperator, KeyedCoProcessOperator, KeyedProcessOperator, LegacyKeyedCoProcessOperator, LegacyKeyedProcessOperator, ProcessOperator, QueryableAppendingStateOperator, QueryableValueStateOperator, SourceOperator, StreamFilter, StreamFlatMap, StreamGroupedReduceOperator, StreamMap, StreamProject, StreamSink, StreamSource, TimestampsAndWatermarksOperator, WindowOperator

@Deprecated
@PublicEvolving
public interface SetupableStreamOperator<OUT>

Deprecated.

This class is deprecated in favour of using StreamOperatorFactory and it's StreamOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT>) and passing the required parameters to the Operator's constructor in create method.

Stream operators can implement this interface if they need access to the context and the output.

Method Summary

Modifier and Type	Method	Description
ChainingStrategy	getChainingStrategy()	Deprecated.
void	setChainingStrategy(ChainingStrategy strategy)	Deprecated.
void	setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)	Deprecated. Initializes the operator.

Method Detail

setup

void setup(StreamTask<?,?> containingTask,
           StreamConfig config,
           Output<StreamRecord<OUT>> output)

Deprecated.

Initializes the operator. Sets access to the context and the output.

getChainingStrategy

ChainingStrategy getChainingStrategy()

Deprecated.

setChainingStrategy

void setChainingStrategy(ChainingStrategy strategy)

Deprecated.