org.apache.flink.table.planner.plan.nodes.exec.utils

类 TransformationMetadata

java.lang.Object

org.apache.flink.table.planner.plan.nodes.exec.utils.TransformationMetadata

public class TransformationMetadata
extends Object

This POJO is meant to hold some metadata information about operators, which usually needs to be passed to "factory" methods for Transformation.

构造器概要

构造器

构造器和说明
TransformationMetadata(String name, String desc) Used by BatchExecNode, as they don't require the uid.
TransformationMetadata(String uid, String name, String desc) Used by StreamExecNode, as they require the uid.

方法概要

限定符和类型	方法和说明
<T extends org.apache.flink.api.dag.Transformation<?>> T	fill(T transformation) Fill a transformation with this meta.
String	getDescription()
String	getName()
String	getUid()

从类继承的方法 java.lang.Object

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

构造器详细资料

TransformationMetadata

public TransformationMetadata(String name,
                              String desc)

Used by BatchExecNode, as they don't require the uid.

TransformationMetadata

public TransformationMetadata(String uid,
                              String name,
                              String desc)

Used by StreamExecNode, as they require the uid.

方法详细资料

getUid

@Nullable
public String getUid()

getName

public String getName()

getDescription

public String getDescription()

fill

public <T extends org.apache.flink.api.dag.Transformation<?>> T fill(T transformation)

Fill a transformation with this meta.