OUT
- The output type of the operatorStreamOperatorFactory
and it's
StreamOperatorFactory.createStreamOperator(org.apache.flink.streaming.runtime.tasks.StreamTask<?, ?>, org.apache.flink.streaming.api.graph.StreamConfig, org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<OUT>>)
and passing the required parameters to the
Operator's constructor in create method.@Deprecated @PublicEvolving public interface SetupableStreamOperator<OUT>
Modifier and Type | Method and Description |
---|---|
void |
setup(StreamTask<?,?> containingTask,
StreamConfig config,
Output<StreamRecord<OUT>> output)
Deprecated.
Initializes the operator.
|
void setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.