| Modifier and Type | Method and Description |
|---|---|
OperationExecutor |
SessionContext.createOperationExecutor(org.apache.flink.configuration.Configuration executionConfig) |
| Modifier and Type | Method and Description |
|---|---|
ResultFetcher |
MaterializedTableManager.callMaterializedTableOperation(OperationExecutor operationExecutor,
org.apache.flink.table.gateway.api.operation.OperationHandle handle,
org.apache.flink.table.operations.materializedtable.MaterializedTableOperation op,
String statement) |
ResultFetcher |
MaterializedTableManager.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) |
| Modifier and Type | Method and Description |
|---|---|
OperationExecutor |
Session.createExecutor() |
OperationExecutor |
Session.createExecutor(org.apache.flink.configuration.Configuration executionConfig) |
Copyright © 2014–2025 The Apache Software Foundation. All rights reserved.