Modifier and Type | Method and Description |
---|---|
static Callable<ResultSet> |
OperationExecutorFactory.createGetCatalogsExecutor(SqlGatewayService service,
SessionHandle sessionHandle) |
static Callable<ResultSet> |
OperationExecutorFactory.createGetColumnsExecutor(SqlGatewayService service,
SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
String columnsName) |
static Callable<ResultSet> |
OperationExecutorFactory.createGetFunctionsExecutor(SqlGatewayService service,
SessionHandle sessionHandle,
String catalogName,
String databasePattern,
String functionNamePattern) |
static Callable<ResultSet> |
OperationExecutorFactory.createGetPrimaryKeys(SqlGatewayService service,
SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName) |
static Callable<ResultSet> |
OperationExecutorFactory.createGetSchemasExecutor(SqlGatewayService service,
SessionHandle sessionHandle,
String catalogName,
String schemaName) |
static Callable<ResultSet> |
OperationExecutorFactory.createGetTablesExecutor(SqlGatewayService service,
SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
Set<CatalogBaseTable.TableKind> tableKinds) |
static Callable<ResultSet> |
OperationExecutorFactory.createGetTableTypesExecutor() |
static Callable<ResultSet> |
OperationExecutorFactory.createGetTypeInfoExecutor() |
Modifier and Type | Method and Description |
---|---|
ResultSet |
SqlGatewayService.fetchResults(SessionHandle sessionHandle,
OperationHandle operationHandle,
FetchOrientation orientation,
int maxRows)
Fetch the results from the operation.
|
ResultSet |
SqlGatewayService.fetchResults(SessionHandle sessionHandle,
OperationHandle operationHandle,
long token,
int maxRows)
Fetch the results from the operation.
|
Modifier and Type | Method and Description |
---|---|
OperationHandle |
SqlGatewayService.submitOperation(SessionHandle sessionHandle,
Callable<ResultSet> executor)
Submit an operation and execute.
|
Modifier and Type | Field and Description |
---|---|
static ResultSet |
ResultSet.NOT_READY_RESULTS |
Modifier and Type | Method and Description |
---|---|
ResultSet |
FetchResultsResponseBody.getResults() |
Constructor and Description |
---|
FetchResultsResponseBody(ResultSet results,
String resultType,
String nextResultUri) |
Modifier and Type | Method and Description |
---|---|
ResultSet |
JsonResultSetDeserializer.deserialize(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser jsonParser,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
JsonResultSetSerializer.serialize(ResultSet resultSet,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator jsonGenerator,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.SerializerProvider serializerProvider) |
Modifier and Type | Method and Description |
---|---|
ResultSet |
SqlGatewayServiceImpl.fetchResults(SessionHandle sessionHandle,
OperationHandle operationHandle,
FetchOrientation orientation,
int maxRows) |
ResultSet |
SqlGatewayServiceImpl.fetchResults(SessionHandle sessionHandle,
OperationHandle operationHandle,
long token,
int maxRows) |
Modifier and Type | Method and Description |
---|---|
OperationHandle |
SqlGatewayServiceImpl.submitOperation(SessionHandle sessionHandle,
Callable<ResultSet> executor) |
Modifier and Type | Method and Description |
---|---|
ResultSet |
OperationManager.Operation.fetchResults(FetchOrientation orientation,
int maxRows) |
ResultSet |
OperationManager.Operation.fetchResults(long token,
int maxRows) |
ResultSet |
OperationManager.fetchResults(OperationHandle operationHandle,
FetchOrientation orientation,
int maxRows) |
ResultSet |
OperationManager.fetchResults(OperationHandle operationHandle,
long token,
int maxRows)
Get the results of the operation.
|
Modifier and Type | Method and Description |
---|---|
OperationHandle |
OperationManager.submitOperation(Callable<ResultSet> executor)
Submit the operation to the
OperationManager . |
Modifier and Type | Method and Description |
---|---|
ResultSet |
ResultFetcher.fetchResults(FetchOrientation orientation,
int maxFetchSize) |
ResultSet |
ResultFetcher.fetchResults(long token,
int maxFetchSize)
Fetch results from the result store.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.