Package org.apache.flink.table.operations.materializedtable

Class FullAlterMaterializedTableOperation

java.lang.Object

org.apache.flink.table.operations.materializedtable.AlterMaterializedTableOperation

org.apache.flink.table.operations.materializedtable.AlterMaterializedTableChangeOperation

org.apache.flink.table.operations.materializedtable.FullAlterMaterializedTableOperation

All Implemented Interfaces:

AlterOperation, ExecutableOperation, MaterializedTableOperation, Operation

@Internal
public class FullAlterMaterializedTableOperation
extends AlterMaterializedTableChangeOperation

Operation for CREATE OR ALTER MATERIALIZED TABLE ... in case materialized table is present and full materialized table changes should be calculated.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.operations.ExecutableOperation

ExecutableOperation.Context

Field Summary

Fields inherited from class org.apache.flink.table.operations.materializedtable.AlterMaterializedTableOperation

tableIdentifier

Constructor Summary

Constructors

Constructor	Description
FullAlterMaterializedTableOperation(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier, Function<org.apache.flink.table.catalog.ResolvedCatalogMaterializedTable,List<org.apache.flink.table.catalog.TableChange>> tableChangeForTable, org.apache.flink.table.catalog.ResolvedCatalogMaterializedTable oldTable)

Method Summary

Modifier and Type	Method	Description
protected String	getOperationName()

Methods inherited from class org.apache.flink.table.operations.materializedtable.AlterMaterializedTableChangeOperation

asSummaryString, copyAsTableChangeOperation, execute, getHandlerWithChanges, getNewTable, getTableChanges

Methods inherited from class org.apache.flink.table.operations.materializedtable.AlterMaterializedTableOperation

getTableIdentifier

Methods inherited from class java.lang.Object

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

Constructor Detail

FullAlterMaterializedTableOperation

public FullAlterMaterializedTableOperation(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier,
                                           Function<org.apache.flink.table.catalog.ResolvedCatalogMaterializedTable,List<org.apache.flink.table.catalog.TableChange>> tableChangeForTable,
                                           org.apache.flink.table.catalog.ResolvedCatalogMaterializedTable oldTable)

Method Detail

getOperationName

protected String getOperationName()

Overrides:

getOperationName in class AlterMaterializedTableChangeOperation