Uses of Class
org.apache.flink.table.gateway.service.result.ResultFetcher

Packages that use ResultFetcher

Package	Description
org.apache.flink.table.gateway.service.materializedtable
org.apache.flink.table.gateway.service.operation
org.apache.flink.table.gateway.service.result

Uses of ResultFetcher in org.apache.flink.table.gateway.service.materializedtable

Methods in org.apache.flink.table.gateway.service.materializedtable that return ResultFetcher

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)

Uses of ResultFetcher in org.apache.flink.table.gateway.service.operation

Methods in org.apache.flink.table.gateway.service.operation that return ResultFetcher

Modifier and Type	Method and Description
ResultFetcher	OperationExecutor.callDescribeJobOperation(org.apache.flink.table.api.internal.TableEnvironmentInternal tableEnv, org.apache.flink.table.gateway.api.operation.OperationHandle operationHandle, org.apache.flink.table.operations.command.DescribeJobOperation describeJobOperation)
ResultFetcher	OperationExecutor.callExecutableOperation(org.apache.flink.table.gateway.api.operation.OperationHandle handle, org.apache.flink.table.operations.ExecutableOperation op)
protected ResultFetcher	OperationExecutor.callRemoveJar(org.apache.flink.table.gateway.api.operation.OperationHandle operationHandle, String jarPath)
ResultFetcher	OperationExecutor.callShowJobsOperation(org.apache.flink.table.api.internal.TableEnvironmentInternal tableEnv, org.apache.flink.table.gateway.api.operation.OperationHandle operationHandle, org.apache.flink.table.operations.command.ShowJobsOperation showJobsOperation)
ResultFetcher	OperationExecutor.callStopJobOperation(org.apache.flink.table.api.internal.TableEnvironmentInternal tableEnv, org.apache.flink.table.gateway.api.operation.OperationHandle handle, org.apache.flink.table.operations.command.StopJobOperation stopJobOperation)
ResultFetcher	OperationExecutor.configureSession(org.apache.flink.table.gateway.api.operation.OperationHandle handle, String statement)
ResultFetcher	OperationExecutor.executeStatement(org.apache.flink.table.gateway.api.operation.OperationHandle handle, org.apache.flink.configuration.Configuration customConfig, String statement)
ResultFetcher	OperationExecutor.executeStatement(org.apache.flink.table.gateway.api.operation.OperationHandle handle, String statement)
ResultFetcher	OperationExecutor.getCompletionHints(org.apache.flink.table.gateway.api.operation.OperationHandle operationHandle, String statement, int position)
ResultFetcher	OperationExecutor.refreshMaterializedTable(org.apache.flink.table.gateway.api.operation.OperationHandle handle, String materializedTableIdentifier, boolean isPeriodic, String scheduleTime, Map<String,String> staticPartitions, Map<String,String> dynamicOptions)

Method parameters in org.apache.flink.table.gateway.service.operation with type arguments of type ResultFetcher

Modifier and Type	Method and Description
org.apache.flink.table.gateway.api.operation.OperationHandle	OperationManager.submitOperation(Function<org.apache.flink.table.gateway.api.operation.OperationHandle,ResultFetcher> fetcherSupplier) Submit the operation to the OperationManager.

Constructor parameters in org.apache.flink.table.gateway.service.operation with type arguments of type ResultFetcher

Constructor and Description
Operation(org.apache.flink.table.gateway.api.operation.OperationHandle operationHandle, Callable<ResultFetcher> resultSupplier)

Uses of ResultFetcher in org.apache.flink.table.gateway.service.result

Methods in org.apache.flink.table.gateway.service.result that return ResultFetcher

Modifier and Type	Method and Description
static ResultFetcher	ResultFetcher.fromResults(org.apache.flink.table.gateway.api.operation.OperationHandle operationHandle, org.apache.flink.table.catalog.ResolvedSchema resultSchema, List<org.apache.flink.table.data.RowData> results)
static ResultFetcher	ResultFetcher.fromResults(org.apache.flink.table.gateway.api.operation.OperationHandle operationHandle, org.apache.flink.table.catalog.ResolvedSchema resultSchema, List<org.apache.flink.table.data.RowData> results, org.apache.flink.api.common.JobID jobID, org.apache.flink.table.api.ResultKind resultKind)
static ResultFetcher	ResultFetcher.fromTableResult(org.apache.flink.table.gateway.api.operation.OperationHandle operationHandle, org.apache.flink.table.api.internal.TableResultInternal tableResult, boolean isQueryResult)
ResultFetcher	ResultFetcher.withResourceManager(org.apache.flink.table.resource.ResourceManager resourceManager)