org.apache.flink.table.gateway.service.materializedtable

Class MaterializedTableManager

java.lang.Object

org.apache.flink.table.gateway.service.materializedtable.MaterializedTableManager

@Internal
public class MaterializedTableManager
extends Object

Manager is responsible for execute the MaterializedTableOperation.

Constructor Summary

Constructors

Constructor and Description
MaterializedTableManager(org.apache.flink.configuration.Configuration configuration, URLClassLoader userCodeClassLoader)

Method Summary

Modifier and Type	Method and Description
ResultFetcher	callMaterializedTableOperation(OperationExecutor operationExecutor, org.apache.flink.table.gateway.api.operation.OperationHandle handle, org.apache.flink.table.operations.materializedtable.MaterializedTableOperation op, String statement)
void	close()
protected static String	getInsertStatement(org.apache.flink.table.catalog.ObjectIdentifier materializedTableIdentifier, String definitionQuery, Map<String,String> dynamicOptions) Generate insert statement for materialized table.
protected static String	getRefreshStatement(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier, String definitionQuery, Map<String,String> partitionSpec, Map<String,String> dynamicOptions)
void	open()
ResultFetcher	refreshMaterializedTable(OperationExecutor operationExecutor, org.apache.flink.table.gateway.api.operation.OperationHandle handle, org.apache.flink.table.catalog.ObjectIdentifier materializedTableIdentifier, Map<String,String> staticPartitions, Map<String,String> dynamicOptions, boolean isPeriodic, String scheduleTime)

Methods inherited from class java.lang.Object

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

Constructor Detail

MaterializedTableManager

public MaterializedTableManager(org.apache.flink.configuration.Configuration configuration,
                                URLClassLoader userCodeClassLoader)

Method Detail

open

public void open()
          throws Exception

Throws:

Exception

close

public void close()
           throws Exception

Throws:

Exception

callMaterializedTableOperation

public ResultFetcher callMaterializedTableOperation(OperationExecutor operationExecutor,
                                                    org.apache.flink.table.gateway.api.operation.OperationHandle handle,
                                                    org.apache.flink.table.operations.materializedtable.MaterializedTableOperation op,
                                                    String statement)

refreshMaterializedTable

public ResultFetcher refreshMaterializedTable(OperationExecutor operationExecutor,
                                              org.apache.flink.table.gateway.api.operation.OperationHandle handle,
                                              org.apache.flink.table.catalog.ObjectIdentifier materializedTableIdentifier,
                                              Map<String,String> staticPartitions,
                                              Map<String,String> dynamicOptions,
                                              boolean isPeriodic,
                                              @Nullable
                                              String scheduleTime)

getRefreshStatement

@VisibleForTesting
protected static String getRefreshStatement(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier,
                                                               String definitionQuery,
                                                               Map<String,String> partitionSpec,
                                                               Map<String,String> dynamicOptions)

getInsertStatement

@VisibleForTesting
protected static String getInsertStatement(org.apache.flink.table.catalog.ObjectIdentifier materializedTableIdentifier,
                                                              String definitionQuery,
                                                              Map<String,String> dynamicOptions)

Generate insert statement for materialized table.