org.apache.flink.table.client.gateway.local.result

Class CollectStreamResult<C>

java.lang.Object

org.apache.flink.table.client.gateway.local.result.BasicResult<C>

org.apache.flink.table.client.gateway.local.result.CollectStreamResult<C>

Type Parameters:

C - cluster id to which this result belongs to

All Implemented Interfaces:

DynamicResult<C>, Result<C>

Direct Known Subclasses:

ChangelogCollectStreamResult, MaterializedCollectStreamResult

public abstract class CollectStreamResult<C>
extends BasicResult<C>
implements DynamicResult<C>

A result that works similarly to DataStreamUtils.collect(DataStream).

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicReference<SqlExecutionException>	executionException
protected Object	resultLock

Fields inherited from class org.apache.flink.table.client.gateway.local.result.BasicResult

clusterId, webInterfaceUrl

Constructor Summary

Constructors

Constructor and Description
CollectStreamResult(TableSchema tableSchema, ExecutionConfig config, InetAddress gatewayAddress, int gatewayPort, ClassLoader classLoader)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the retrieval and all involved threads.
TableSink<?>	getTableSink() Returns the table sink required by this result type.
protected <T> TypedResult<T>	handleMissingResult()
protected boolean	isRetrieving()
protected abstract void	processRecord(Tuple2<Boolean,Row> change)
void	startRetrieval(JobClient jobClient) Starts retrieving the result using the given JobClient and monitors it's execution.

Methods inherited from class org.apache.flink.table.client.gateway.local.result.BasicResult

getClusterId, getWebInterfaceUrl, setClusterInformation

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.client.gateway.local.result.DynamicResult

isMaterialized

Methods inherited from interface org.apache.flink.table.client.gateway.local.result.Result

setClusterInformation

Field Detail

resultLock

protected final Object resultLock

executionException

protected AtomicReference<SqlExecutionException> executionException

Constructor Detail

CollectStreamResult

public CollectStreamResult(TableSchema tableSchema,
                           ExecutionConfig config,
                           InetAddress gatewayAddress,
                           int gatewayPort,
                           ClassLoader classLoader)

Method Detail

startRetrieval

public void startRetrieval(JobClient jobClient)

Description copied from interface: DynamicResult

Starts retrieving the result using the given JobClient and monitors it's execution.

Specified by:

startRetrieval in interface DynamicResult<C>

getTableSink

public TableSink<?> getTableSink()

Description copied from interface: DynamicResult

Returns the table sink required by this result type.

Specified by:

getTableSink in interface DynamicResult<C>

close

public void close()

Description copied from interface: DynamicResult

Closes the retrieval and all involved threads.

Specified by:

close in interface DynamicResult<C>

handleMissingResult

protected <T> TypedResult<T> handleMissingResult()

isRetrieving

protected boolean isRetrieving()

processRecord

protected abstract void processRecord(Tuple2<Boolean,Row> change)