org.apache.flink.table.operations

Class CreateTableASOperation

java.lang.Object

org.apache.flink.table.operations.CreateTableASOperation

All Implemented Interfaces:

ModifyOperation, Operation

@Internal
public class CreateTableASOperation
extends Object
implements ModifyOperation

Operation to describe a CREATE TABLE AS statement.

Constructor Summary

Constructors

Constructor and Description
CreateTableASOperation(CreateTableOperation createTableOperation, Map<String,String> sinkModifyStaticPartitions, QueryOperation sinkModifyQuery, boolean sinkModifyOverwrite)

Method Summary

Modifier and Type	Method and Description
<T> T	accept(ModifyOperationVisitor<T> visitor)
String	asSummaryString() Returns a string that summarizes this operation for printing to a console.
QueryOperation	getChild()
CreateTableOperation	getCreateTableOperation()
SinkModifyOperation	toSinkModifyOperation(CatalogManager catalogManager)
StagedSinkModifyOperation	toStagedSinkModifyOperation(ObjectIdentifier tableIdentifier, ResolvedCatalogTable catalogTable, Catalog catalog, DynamicTableSink dynamicTableSink)

Methods inherited from class java.lang.Object

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

Constructor Detail

CreateTableASOperation

public CreateTableASOperation(CreateTableOperation createTableOperation,
                              Map<String,String> sinkModifyStaticPartitions,
                              QueryOperation sinkModifyQuery,
                              boolean sinkModifyOverwrite)

Method Detail

getCreateTableOperation

public CreateTableOperation getCreateTableOperation()

toSinkModifyOperation

public SinkModifyOperation toSinkModifyOperation(CatalogManager catalogManager)

toStagedSinkModifyOperation

public StagedSinkModifyOperation toStagedSinkModifyOperation(ObjectIdentifier tableIdentifier,
                                                             ResolvedCatalogTable catalogTable,
                                                             Catalog catalog,
                                                             DynamicTableSink dynamicTableSink)

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

getChild

public QueryOperation getChild()

Specified by:

getChild in interface ModifyOperation

accept

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

Specified by:

accept in interface ModifyOperation