public class StreamOperatorFactoryUtil extends Object
Constructor and Description |
---|
StreamOperatorFactoryUtil() |
Modifier and Type | Method and Description |
---|---|
static <OUT,OP extends StreamOperator<OUT>> |
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.
|
public static <OUT,OP extends StreamOperator<OUT>> OP createOperator(StreamOperatorFactory<OUT> operatorFactory, StreamTask<OUT,?> containingTask, StreamConfig configuration, Output<StreamRecord<OUT>> output)
operatorFactory
- the operator factory.containingTask
- the containing task.configuration
- the configuration of the operator.output
- the output of the operator.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.