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

Packages that use ResultFetcher

Package	Description
org.apache.flink.table.gateway.service.application
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.application

Methods in org.apache.flink.table.gateway.service.application with parameters of type ResultFetcher

Modifier and Type	Method	Description
void	Printer.print(ResultFetcher result)

Constructors in org.apache.flink.table.gateway.service.application with parameters of type ResultFetcher

Constructor	Description
RowDataIterator(ResultFetcher fetcher)

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	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	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, String statement)
ResultFetcher	OperationExecutor.executeStatement(org.apache.flink.table.gateway.api.operation.OperationHandle handle, org.apache.flink.configuration.Configuration customConfig, 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	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	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	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)