Package | Description |
---|---|
org.apache.flink.table.client.gateway | |
org.apache.flink.table.client.gateway.local | |
org.apache.flink.table.client.gateway.local.result |
Modifier and Type | Method and Description |
---|---|
static <T> TypedResult<T> |
TypedResult.empty() |
static <T> TypedResult<T> |
TypedResult.endOfStream() |
static <T> TypedResult<T> |
TypedResult.payload(T payload) |
TypedResult<List<RowData>> |
Executor.retrieveResultChanges(String sessionId,
String resultId)
Asks for the next changelog results (non-blocking).
|
TypedResult<Integer> |
Executor.snapshotResult(String sessionId,
String resultId,
int pageSize)
Creates an immutable result snapshot of the running Flink job.
|
Modifier and Type | Method and Description |
---|---|
TypedResult<List<RowData>> |
LocalExecutor.retrieveResultChanges(String sessionId,
String resultId) |
TypedResult<Integer> |
LocalExecutor.snapshotResult(String sessionId,
String resultId,
int pageSize) |
Modifier and Type | Method and Description |
---|---|
protected <T> TypedResult<T> |
CollectResultBase.handleMissingResult() |
TypedResult<List<RowData>> |
ChangelogResult.retrieveChanges()
Retrieves the available result records.
|
TypedResult<List<RowData>> |
ChangelogCollectResult.retrieveChanges() |
TypedResult<Integer> |
MaterializedCollectResultBase.snapshot(int pageSize) |
TypedResult<Integer> |
MaterializedResult.snapshot(int pageSize)
Takes a snapshot of the current table and returns the number of pages for navigating through
the snapshot.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.