org.apache.flink.table.operations

Class SourceQueryOperation

java.lang.Object

org.apache.flink.table.operations.SourceQueryOperation

All Implemented Interfaces:

Operation, QueryOperation

@Internal
public class SourceQueryOperation
extends Object
implements QueryOperation

Describes a query operation from a ContextResolvedTable.

The source table is described by getContextResolvedTable(), and in general is used for every source which implementation is defined with DynamicTableSource. DataStream sources are handled by ExternalQueryOperation.

Constructor Summary

Constructors

Constructor and Description
SourceQueryOperation(ContextResolvedTable contextResolvedTable)
SourceQueryOperation(ContextResolvedTable contextResolvedTable, Map<String,String> dynamicOptions)

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()
ContextResolvedTable	getContextResolvedTable()
Map<String,String>	getDynamicOptions()
ResolvedSchema	getResolvedSchema() Resolved schema of this operation.

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

SourceQueryOperation

public SourceQueryOperation(ContextResolvedTable contextResolvedTable)

SourceQueryOperation

public SourceQueryOperation(ContextResolvedTable contextResolvedTable,
                            @Nullable
                            Map<String,String> dynamicOptions)

Method Detail

getContextResolvedTable

public ContextResolvedTable getContextResolvedTable()

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

getDynamicOptions

@Nullable
public Map<String,String> getDynamicOptions()