C
- cluster id to which this result belongs topublic abstract class CollectStreamResult<C> extends Object implements DynamicResult<C>
DataStreamUtils.collect(DataStream)
.Modifier and Type | Field and Description |
---|---|
protected SqlExecutionException |
executionException |
protected Object |
resultLock |
Constructor and Description |
---|
CollectStreamResult(TypeInformation<Row> outputType,
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.
|
org.apache.flink.table.sinks.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 |
setClusterId(C clusterId)
Sets the cluster id of the cluster this result comes from.
|
void |
startRetrieval(Runnable program)
Starts the table program using the given runnable and monitors it's execution.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isMaterialized
protected final Object resultLock
protected SqlExecutionException executionException
public CollectStreamResult(TypeInformation<Row> outputType, ExecutionConfig config, InetAddress gatewayAddress, int gatewayPort)
public void setClusterId(C clusterId)
DynamicResult
setClusterId
in interface DynamicResult<C>
public TypeInformation<Row> getOutputType()
DynamicResult
getOutputType
in interface DynamicResult<C>
public void startRetrieval(Runnable program)
DynamicResult
startRetrieval
in interface DynamicResult<C>
public org.apache.flink.table.sinks.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–2019 The Apache Software Foundation. All rights reserved.