public class CodeGenOperatorFactory<OUT> extends Object implements StreamOperatorFactory<OUT>
Constructor and Description |
---|
CodeGenOperatorFactory(GeneratedClass<? extends StreamOperator<OUT>> generatedClass) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<OUT>> |
createStreamOperator(StreamTask<?,?> containingTask,
StreamConfig config,
Output<StreamRecord<OUT>> output)
Create the operator.
|
ChainingStrategy |
getChainingStrategy()
Get the chaining strategy of operator factory.
|
GeneratedClass<? extends StreamOperator<OUT>> |
getGeneratedClass() |
boolean |
isOperatorSelectiveReading()
Test whether the operator is selective reading one.
|
void |
setChainingStrategy(ChainingStrategy strategy)
Set the chaining strategy for operator factory.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isInputTypeConfigurable, isOutputTypeConfigurable, isStreamSource, setInputType, setOutputType
public CodeGenOperatorFactory(GeneratedClass<? extends StreamOperator<OUT>> generatedClass)
public <T extends StreamOperator<OUT>> T createStreamOperator(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)
StreamOperatorFactory
createStreamOperator
in interface StreamOperatorFactory<OUT>
public void setChainingStrategy(ChainingStrategy strategy)
StreamOperatorFactory
setChainingStrategy
in interface StreamOperatorFactory<OUT>
public ChainingStrategy getChainingStrategy()
StreamOperatorFactory
getChainingStrategy
in interface StreamOperatorFactory<OUT>
public boolean isOperatorSelectiveReading()
StreamOperatorFactory
isOperatorSelectiveReading
in interface StreamOperatorFactory<OUT>
public GeneratedClass<? extends StreamOperator<OUT>> getGeneratedClass()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.