org.apache.flink.table.planner.operations

类 InternalDataStreamQueryOperation<E>

java.lang.Object

org.apache.flink.table.planner.operations.InternalDataStreamQueryOperation<E>

所有已实现的接口:

org.apache.flink.table.operations.Operation, org.apache.flink.table.operations.QueryOperation

已过时。

@Internal
 @Deprecated
public class InternalDataStreamQueryOperation<E>
extends Object
implements org.apache.flink.table.operations.QueryOperation

Describes a relational operation that reads from a DataStream.

This is only used for testing.

This operation may expose only part, or change the order of the fields available in a CompositeType of the underlying DataStream. The getFieldIndices() describes the mapping between fields of the TableSchema to the CompositeType.

构造器概要

构造器

构造器和说明
InternalDataStreamQueryOperation(org.apache.flink.table.catalog.ObjectIdentifier identifier, org.apache.flink.streaming.api.datastream.DataStream<E> dataStream, int[] fieldIndices, org.apache.flink.table.catalog.ResolvedSchema resolvedSchema, boolean[] fieldNullables, org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic) 已过时。

方法概要

限定符和类型	方法和说明
<T> T	accept(org.apache.flink.table.operations.QueryOperationVisitor<T> visitor) 已过时。
String	asSummaryString() 已过时。
List<org.apache.flink.table.operations.QueryOperation>	getChildren() 已过时。
org.apache.flink.streaming.api.datastream.DataStream<E>	getDataStream() 已过时。
int[]	getFieldIndices() 已过时。
boolean[]	getFieldNullables() 已过时。
org.apache.flink.table.catalog.ObjectIdentifier	getIdentifier() 已过时。
org.apache.flink.table.catalog.ResolvedSchema	getResolvedSchema() 已过时。
org.apache.flink.table.planner.plan.stats.FlinkStatistic	getStatistic() 已过时。

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

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

从接口继承的方法 org.apache.flink.table.operations.QueryOperation

asSerializableString

构造器详细资料

InternalDataStreamQueryOperation

public InternalDataStreamQueryOperation(org.apache.flink.table.catalog.ObjectIdentifier identifier,
                                        org.apache.flink.streaming.api.datastream.DataStream<E> dataStream,
                                        int[] fieldIndices,
                                        org.apache.flink.table.catalog.ResolvedSchema resolvedSchema,
                                        boolean[] fieldNullables,
                                        org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic)

已过时。

方法详细资料

getDataStream

public org.apache.flink.streaming.api.datastream.DataStream<E> getDataStream()

已过时。

getFieldIndices

public int[] getFieldIndices()

已过时。

getResolvedSchema

public org.apache.flink.table.catalog.ResolvedSchema getResolvedSchema()

已过时。

指定者:

getResolvedSchema 在接口中 org.apache.flink.table.operations.QueryOperation

asSummaryString

public String asSummaryString()

已过时。

指定者:

asSummaryString 在接口中 org.apache.flink.table.operations.Operation

getChildren

public List<org.apache.flink.table.operations.QueryOperation> getChildren()

已过时。

指定者:

getChildren 在接口中 org.apache.flink.table.operations.QueryOperation

accept

public <T> T accept(org.apache.flink.table.operations.QueryOperationVisitor<T> visitor)

已过时。

指定者:

accept 在接口中 org.apache.flink.table.operations.QueryOperation

getIdentifier

public org.apache.flink.table.catalog.ObjectIdentifier getIdentifier()

已过时。

getFieldNullables

public boolean[] getFieldNullables()

已过时。

getStatistic

public org.apache.flink.table.planner.plan.stats.FlinkStatistic getStatistic()

已过时。