Uses of Class
org.apache.flink.table.gateway.service.operation.OperationExecutor
-
-
Uses of OperationExecutor in org.apache.flink.table.gateway.service.context
Methods in org.apache.flink.table.gateway.service.context that return OperationExecutor Modifier and Type Method Description OperationExecutorSessionContext. createOperationExecutor(org.apache.flink.configuration.Configuration executionConfig) -
Uses of OperationExecutor in org.apache.flink.table.gateway.service.materializedtable
Methods in org.apache.flink.table.gateway.service.materializedtable with parameters of type OperationExecutor Modifier and Type Method Description ResultFetcherMaterializedTableManager. callMaterializedTableOperation(OperationExecutor operationExecutor, org.apache.flink.table.gateway.api.operation.OperationHandle handle, org.apache.flink.table.operations.materializedtable.MaterializedTableOperation op, String statement)ResultFetcherMaterializedTableManager. 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) -
Uses of OperationExecutor in org.apache.flink.table.gateway.service.session
Methods in org.apache.flink.table.gateway.service.session that return OperationExecutor Modifier and Type Method Description OperationExecutorSession. createExecutor()OperationExecutorSession. createExecutor(org.apache.flink.configuration.Configuration executionConfig)
-