Modifier and Type | Method and Description |
---|---|
<R> SingleOutputStreamOperator<R> |
DataStream.transform(String operatorName,
TypeInformation<R> outTypeInfo,
OneInputStreamOperatorFactory<T,R> operatorFactory)
Method for passing user defined operators created by the given factory along with the type
information that will transform the DataStream.
|
Modifier and Type | Class and Description |
---|---|
class |
ContinuousFileReaderOperatorFactory<OUT,T extends TimestampedInputSplit>
ContinuousFileReaderOperator factory. |
Modifier and Type | Class and Description |
---|---|
class |
AsyncWaitOperatorFactory<IN,OUT>
The factory of
AsyncWaitOperator . |
Modifier and Type | Class and Description |
---|---|
class |
BatchCommitterOperatorFactory<CommT>
A
StreamOperatorFactory for BatchCommitterOperator . |
class |
BatchGlobalCommitterOperatorFactory<CommT,GlobalCommT>
A
StreamOperatorFactory for BatchGlobalCommitterOperator . |
class |
StatefulSinkWriterOperatorFactory<InputT,CommT,WriterStateT>
A
StreamOperatorFactory for StatefulSinkWriterOperator . |
class |
StatelessSinkWriterOperatorFactory<InputT,CommT>
A
StreamOperatorFactory for StatelessSinkWriterOperator . |
class |
StreamingCommitterOperatorFactory<CommT>
A
StreamOperatorFactory for StreamingCommitterOperator . |
class |
StreamingGlobalCommitterOperatorFactory<CommT,GlobalCommT>
|
Modifier and Type | Class and Description |
---|---|
class |
WatermarkAssignerOperatorFactory
The factory of
WatermarkAssignerOperator . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.