Modifier and Type | Method and Description |
---|---|
<O extends StreamOperator<OUT>> |
ContinuousFileReaderOperatorFactory.createStreamOperator(StreamOperatorParameters<OUT> parameters) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<OUT>> |
StreamOperatorFactory.createStreamOperator(StreamOperatorParameters<OUT> parameters)
Create the operator.
|
<T extends StreamOperator<OUT>> |
SourceOperatorFactory.createStreamOperator(StreamOperatorParameters<OUT> parameters) |
<T extends StreamOperator<OUT>> |
SimpleOperatorFactory.createStreamOperator(StreamOperatorParameters<OUT> parameters) |
<T extends StreamOperator<OUT>> |
CoordinatedOperatorFactory.createStreamOperator(StreamOperatorParameters<OUT> parameters)
The implementation should return an instance of
OperatorEventHandler . |
Constructor and Description |
---|
AbstractStreamOperatorV2(StreamOperatorParameters<OUT> parameters,
int numberOfInputs) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<OUT>> |
AsyncWaitOperatorFactory.createStreamOperator(StreamOperatorParameters<OUT> parameters) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<Object>> |
CollectSinkOperatorFactory.createStreamOperator(StreamOperatorParameters<Object> parameters) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<OUT>> |
CodeGenOperatorFactory.createStreamOperator(StreamOperatorParameters<OUT> parameters) |
Modifier and Type | Method and Description |
---|---|
StreamOperator |
WatermarkAssignerOperatorFactory.createStreamOperator(StreamOperatorParameters initializer) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.