C
- cluster id to which this result belongs topublic interface DynamicResult<C>
Note: Make sure to call close() after the result is not needed anymore.
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.
|
boolean |
isMaterialized()
Returns whether this result is materialized such that snapshots can be taken or results
must be retrieved record-wise.
|
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.
|
void setClusterId(C clusterId)
boolean isMaterialized()
TypeInformation<Row> getOutputType()
void startRetrieval(Runnable program)
org.apache.flink.table.sinks.TableSink<?> getTableSink()
void close()
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.