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.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) |