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 |
WatermarkAssignerOperatorFactory
The factory of
WatermarkAssignerOperator . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.