org.apache.flink.table.gateway.service.operation

Class OperationManager.Operation

java.lang.Object

org.apache.flink.table.gateway.service.operation.OperationManager.Operation

All Implemented Interfaces:

AutoCloseable

Enclosing class:

OperationManager

@VisibleForTesting
public class OperationManager.Operation
extends Object
implements AutoCloseable

Operation to manage the execution, results and so on.

Constructor Summary

Constructors

Constructor and Description
Operation(OperationHandle operationHandle, Callable<ResultFetcher> resultSupplier)

Method Summary

Modifier and Type	Method and Description
void	awaitTermination()
void	cancel()
void	close()
ResultSet	fetchResults(FetchOrientation orientation, int maxRows)
ResultSet	fetchResults(long token, int maxRows)
OperationInfo	getOperationInfo()
ResolvedSchema	getResultSchema()
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Operation

public Operation(OperationHandle operationHandle,
                 Callable<ResultFetcher> resultSupplier)

Method Detail

run

public void run()

cancel

public void cancel()

close

public void close()

Specified by:

close in interface AutoCloseable

fetchResults

public ResultSet fetchResults(long token,
                              int maxRows)

fetchResults

public ResultSet fetchResults(FetchOrientation orientation,
                              int maxRows)

getResultSchema

public ResolvedSchema getResultSchema()
                               throws Exception

Throws:

Exception

getOperationInfo

public OperationInfo getOperationInfo()

awaitTermination

public void awaitTermination()
                      throws Exception

Throws:

Exception