org.apache.flink.streaming.api.operators

Class SimpleUdfStreamOperatorFactory<OUT>

java.lang.Object

org.apache.flink.streaming.api.operators.SimpleOperatorFactory<OUT>

org.apache.flink.streaming.api.operators.SimpleUdfStreamOperatorFactory<OUT>

Type Parameters:

OUT - The output type of the operator

All Implemented Interfaces:

Serializable, StreamOperatorFactory<OUT>, UdfStreamOperatorFactory<OUT>

@Internal
public class SimpleUdfStreamOperatorFactory<OUT>
extends SimpleOperatorFactory<OUT>
implements UdfStreamOperatorFactory<OUT>

Udf stream operator factory which just wrap existed AbstractUdfStreamOperator.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SimpleUdfStreamOperatorFactory(AbstractUdfStreamOperator<OUT,?> operator)

Method Summary

Modifier and Type	Method and Description
Function	getUserFunction()
String	getUserFunctionClassName()

Methods inherited from class org.apache.flink.streaming.api.operators.SimpleOperatorFactory

createStreamOperator, getChainingStrategy, getOperator, getStreamOperatorClass, isInputTypeConfigurable, isOutputTypeConfigurable, isStreamSource, of, setChainingStrategy, setInputType, setOutputType

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperatorFactory

createStreamOperator, getChainingStrategy, getStreamOperatorClass, isInputTypeConfigurable, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType

Constructor Detail

SimpleUdfStreamOperatorFactory

public SimpleUdfStreamOperatorFactory(AbstractUdfStreamOperator<OUT,?> operator)

Method Detail

getUserFunction

public Function getUserFunction()

Specified by:

getUserFunction in interface UdfStreamOperatorFactory<OUT>

Returns:

user define function.

getUserFunctionClassName

public String getUserFunctionClassName()

Specified by:

getUserFunctionClassName in interface UdfStreamOperatorFactory<OUT>

Returns:

user define function class name.