OUT
- The output type of the operator@Internal public class SimpleUdfStreamOperatorFactory<OUT> extends SimpleOperatorFactory<OUT> implements UdfStreamOperatorFactory<OUT>
AbstractUdfStreamOperator
.chainingStrategy, processingTimeService
Constructor and Description |
---|
SimpleUdfStreamOperatorFactory(AbstractUdfStreamOperator<OUT,?> operator) |
Modifier and Type | Method and Description |
---|---|
Function |
getUserFunction() |
String |
getUserFunctionClassName() |
createStreamOperator, getOperator, getStreamOperatorClass, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, of, setChainingStrategy, setInputType, setOutputType
getChainingStrategy, setProcessingTimeService
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createStreamOperator, getChainingStrategy, getStreamOperatorClass, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType
public SimpleUdfStreamOperatorFactory(AbstractUdfStreamOperator<OUT,?> operator)
public Function getUserFunction()
getUserFunction
in interface UdfStreamOperatorFactory<OUT>
public String getUserFunctionClassName()
getUserFunctionClassName
in interface UdfStreamOperatorFactory<OUT>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.