Package org.apache.flink.table.runtime.generated

Class GeneratedOperator<C extends StreamOperator<?>>

java.lang.Object

org.apache.flink.table.runtime.generated.GeneratedClass<C>

org.apache.flink.table.runtime.generated.GeneratedOperator<C>

Type Parameters:

C - type of StreamOperator

All Implemented Interfaces:

Serializable

public class GeneratedOperator<C extends StreamOperator<?>>
extends GeneratedClass<C>

Describes a generated StreamOperator.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
GeneratedOperator(String className, String code, Object[] references, ReadableConfig conf)	Creates a GeneratedOperator.

Method Summary

Methods inherited from class org.apache.flink.table.runtime.generated.GeneratedClass

compile, getClass, getClassName, getCode, getReferences, newInstance, newInstance

Methods inherited from class java.lang.Object

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

Constructor Detail

GeneratedOperator

public GeneratedOperator(String className,
                         String code,
                         Object[] references,
                         ReadableConfig conf)

Creates a GeneratedOperator.

Parameters:

className - class name of the generated StreamOperator.

code - code of the generated StreamOperator.

references - referenced objects of the generated StreamOperator.

conf - configuration when generating StreamOperator.