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

Class ResultStore

java.lang.Object

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

public class ResultStore
extends Object

Maintains dynamic results.

Constructor Summary

Constructors

Constructor and Description
ResultStore(Configuration flinkConfig)

Method Summary

Modifier and Type	Method and Description
<T> DynamicResult<T>	createResult(Environment env, TableSchema schema, ExecutionConfig config) Creates a result.
<T> DynamicResult<T>	getResult(String resultId)
List<String>	getResults()
void	removeResult(String resultId)
void	storeResult(String resultId, DynamicResult result)

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultStore

public ResultStore(Configuration flinkConfig)

Method Detail

createResult

public <T> DynamicResult<T> createResult(Environment env,
                                         TableSchema schema,
                                         ExecutionConfig config)

Creates a result. Might start threads or opens sockets so every created result must be closed.

storeResult

public void storeResult(String resultId,
                        DynamicResult result)

getResult

public <T> DynamicResult<T> getResult(String resultId)

removeResult

public void removeResult(String resultId)

getResults

public List<String> getResults()