org.apache.flink.table.planner.operations

Class DataStreamQueryOperation<E>

java.lang.Object

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

All Implemented Interfaces:

Operation, QueryOperation

@Internal
public class DataStreamQueryOperation<E>
extends Object
implements 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.

Constructor Summary

Constructors

Constructor and Description
DataStreamQueryOperation(ObjectIdentifier identifier, DataStream<E> dataStream, int[] fieldIndices, ResolvedSchema resolvedSchema, boolean[] fieldNullables, org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic)

Method Summary

Modifier and Type	Method and Description
<T> T	accept(QueryOperationVisitor<T> visitor)
String	asSummaryString() Returns a string that summarizes this operation for printing to a console.
List<QueryOperation>	getChildren()
DataStream<E>	getDataStream()
int[]	getFieldIndices()
boolean[]	getFieldNullables()
ObjectIdentifier	getIdentifier()
ResolvedSchema	getResolvedSchema() Resolved schema of this operation.
org.apache.flink.table.planner.plan.stats.FlinkStatistic	getStatistic()

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.table.operations.QueryOperation

asSerializableString

Constructor Detail

DataStreamQueryOperation

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

Method Detail

getDataStream

public DataStream<E> getDataStream()

getFieldIndices

public int[] getFieldIndices()

getResolvedSchema

public ResolvedSchema getResolvedSchema()

Description copied from interface: QueryOperation

Resolved schema of this operation.

Specified by:

getResolvedSchema in interface QueryOperation

asSummaryString

public String asSummaryString()

Description copied from interface: Operation

Returns a string that summarizes this operation for printing to a console. An implementation might skip very specific properties.

Specified by:

asSummaryString in interface Operation

Returns:

summary string of this operation for debugging purposes

getChildren

public List<QueryOperation> getChildren()

Specified by:

getChildren in interface QueryOperation

accept

public <T> T accept(QueryOperationVisitor<T> visitor)

Specified by:

accept in interface QueryOperation

getIdentifier

public ObjectIdentifier getIdentifier()

getFieldNullables

public boolean[] getFieldNullables()

getStatistic

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