C
- cluster id to which this result belongs topublic abstract class CollectStreamResult<C> extends BasicResult<C> implements DynamicResult<C>
DataStreamUtils.collect(DataStream)
.Modifier and Type | Field and Description |
---|---|
protected SqlExecutionException |
executionException |
protected Object |
resultLock |
clusterId, webInterfaceUrl
Constructor and Description |
---|
CollectStreamResult(RowTypeInfo outputType,
TableSchema tableSchema,
ExecutionConfig config,
InetAddress gatewayAddress,
int gatewayPort) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the retrieval and all involved threads.
|
TypeInformation<Row> |
getOutputType()
Returns the output type as defined by the query.
|
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(ProgramDeployer<C> deployer)
Starts the table program using the given deployer and monitors it's execution.
|
getClusterId, getWebInterfaceUrl, setClusterInformation
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isMaterialized
setClusterInformation
protected final Object resultLock
protected SqlExecutionException executionException
public CollectStreamResult(RowTypeInfo outputType, TableSchema tableSchema, ExecutionConfig config, InetAddress gatewayAddress, int gatewayPort)
public TypeInformation<Row> getOutputType()
DynamicResult
getOutputType
in interface DynamicResult<C>
public void startRetrieval(ProgramDeployer<C> deployer)
DynamicResult
startRetrieval
in interface DynamicResult<C>
public TableSink<?> getTableSink()
DynamicResult
getTableSink
in interface DynamicResult<C>
public void close()
DynamicResult
close
in interface DynamicResult<C>
protected <T> TypedResult<T> handleMissingResult()
protected boolean isRetrieving()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.