org.apache.flink.table.operations

Class ScalaExternalQueryOperation<E>

java.lang.Object

org.apache.flink.table.operations.ScalaExternalQueryOperation<E>

Type Parameters:

E - External type of data stream

All Implemented Interfaces:

Operation, QueryOperation

@Internal
public final class ScalaExternalQueryOperation<E>
extends Object
implements QueryOperation

Describes a relational operation that reads from a DataStream.

It contains all information necessary to perform a stream-to-table conversion.

This class needs to be kept in sync with JavaExternalQueryOperation in the Java bridging module.

Constructor Summary

Constructors

Constructor and Description
ScalaExternalQueryOperation(ObjectIdentifier identifier, DataStream<E> dataStream, DataType physicalDataType, boolean isTopLevelRecord, ChangelogMode changelogMode, ResolvedSchema resolvedSchema)

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.
ChangelogMode	getChangelogMode()
List<QueryOperation>	getChildren()
DataStream<E>	getDataStream()
ObjectIdentifier	getIdentifier()
DataType	getPhysicalDataType()
ResolvedSchema	getResolvedSchema() Resolved schema of this operation.
boolean	isTopLevelRecord()

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

ScalaExternalQueryOperation

public ScalaExternalQueryOperation(ObjectIdentifier identifier,
                                   DataStream<E> dataStream,
                                   DataType physicalDataType,
                                   boolean isTopLevelRecord,
                                   ChangelogMode changelogMode,
                                   ResolvedSchema resolvedSchema)

Method Detail

getIdentifier

public ObjectIdentifier getIdentifier()

getDataStream

public DataStream<E> getDataStream()

getPhysicalDataType

public DataType getPhysicalDataType()

isTopLevelRecord

public boolean isTopLevelRecord()

getChangelogMode

public ChangelogMode getChangelogMode()

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

getResolvedSchema

public ResolvedSchema getResolvedSchema()

Description copied from interface: QueryOperation

Resolved schema of this operation.

Specified by:

getResolvedSchema in interface QueryOperation

accept

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

Specified by:

accept in interface QueryOperation