Modifier and Type | Method and Description |
---|---|
protected <R> SingleOutputStreamOperator<R> |
DataStream.doTransform(String operatorName,
TypeInformation<R> outTypeInfo,
StreamOperatorFactory<R> operatorFactory) |
protected <R> SingleOutputStreamOperator<R> |
KeyedStream.doTransform(String operatorName,
TypeInformation<R> outTypeInfo,
StreamOperatorFactory<R> operatorFactory) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperatorFactory<?>> |
StreamConfig.getStreamOperatorFactory(ClassLoader cl) |
Modifier and Type | Method and Description |
---|---|
StreamOperatorFactory<?> |
StreamNode.getOperatorFactory() |
Modifier and Type | Method and Description |
---|---|
Set<Tuple2<Integer,StreamOperatorFactory<?>>> |
StreamGraph.getAllOperatorFactory() |
Modifier and Type | Method and Description |
---|---|
<IN1,IN2,OUT> |
StreamGraph.addCoOperator(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<OUT> taskOperatorFactory,
TypeInformation<IN1> in1TypeInfo,
TypeInformation<IN2> in2TypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
protected StreamNode |
StreamGraph.addNode(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
Class<? extends AbstractInvokable> vertexClass,
StreamOperatorFactory<?> operatorFactory,
String operatorName) |
<IN,OUT> void |
StreamGraph.addOperator(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<IN> inTypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
<IN,OUT> void |
StreamGraph.addSink(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<IN> inTypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
<IN,OUT> void |
StreamGraph.addSource(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<IN> inTypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
void |
StreamConfig.setStreamOperatorFactory(StreamOperatorFactory<?> factory) |
Constructor and Description |
---|
StreamNode(Integer id,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<?> operatorFactory,
String operatorName,
List<OutputSelector<?>> outputSelector,
Class<? extends AbstractInvokable> jobVertexClass) |
Modifier and Type | Interface and Description |
---|---|
interface |
InputFormatOperatorFactory<OUT>
Input format source operator factory.
|
interface |
OneInputStreamOperatorFactory<IN,OUT>
A factory to create
OneInputStreamOperator . |
interface |
OutputFormatOperatorFactory<IN>
Interface for operator factories which create the sink operator containing an
OutputFormat . |
interface |
UdfStreamOperatorFactory<OUT>
Udf stream operator factory.
|
interface |
YieldingOperatorFactory<OUT>
An operator that needs access to the
MailboxExecutor to yield to downstream operators needs to be created
through a factory implementing this interface. |
Modifier and Type | Class and Description |
---|---|
class |
SimpleInputFormatOperatorFactory<OUT>
Input format source operator factory which just wrap existed
StreamSource . |
class |
SimpleOperatorFactory<OUT>
Simple factory which just wrap existed
StreamOperator . |
class |
SimpleOutputFormatOperatorFactory<IN>
A simple operator factory which create
StreamSink containing an OutputFormat . |
class |
SimpleUdfStreamOperatorFactory<OUT>
Udf stream operator factory which just wrap existed
AbstractUdfStreamOperator . |
Modifier and Type | Method and Description |
---|---|
static <OUT,OP extends StreamOperator<OUT>> |
StreamOperatorFactoryUtil.createOperator(StreamOperatorFactory<OUT> operatorFactory,
StreamTask<OUT,?> containingTask,
StreamConfig configuration,
Output<StreamRecord<OUT>> output)
Creates a new operator using a factory and makes sure that all special factory traits are properly handled.
|
Modifier and Type | Class and Description |
---|---|
class |
AsyncWaitOperatorFactory<IN,OUT>
The factory of
AsyncWaitOperator . |
Modifier and Type | Method and Description |
---|---|
StreamOperatorFactory<OUT> |
TwoInputTransformation.getOperatorFactory()
Returns the
StreamOperatorFactory of this Transformation. |
StreamOperatorFactory<T> |
SourceTransformation.getOperatorFactory()
Returns the
StreamOperatorFactory of this SourceTransformation . |
StreamOperatorFactory<OUT> |
OneInputTransformation.getOperatorFactory()
Returns the
StreamOperatorFactory of this Transformation. |
StreamOperatorFactory<Object> |
SinkTransformation.getOperatorFactory()
Returns the
StreamOperatorFactory of this SinkTransformation . |
Constructor and Description |
---|
OneInputTransformation(Transformation<IN> input,
String name,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<OUT> outputType,
int parallelism) |
SinkTransformation(Transformation<T> input,
String name,
StreamOperatorFactory<Object> operatorFactory,
int parallelism) |
SourceTransformation(String name,
StreamOperatorFactory<T> operatorFactory,
TypeInformation<T> outputType,
int parallelism) |
TwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
String name,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<OUT> outputType,
int parallelism) |
Modifier and Type | Class and Description |
---|---|
class |
CodeGenOperatorFactory<OUT>
Stream operator factory for code gen operator.
|
Modifier and Type | Class and Description |
---|---|
class |
WatermarkAssignerOperatorFactory
The factory of
WatermarkAssignerOperator . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.