public class HyperGrpcClientExecutor extends Object implements AutoCloseable
| Modifier and Type | Class and Description |
|---|---|
static class |
HyperGrpcClientExecutor.HyperGrpcClientExecutorBuilder |
| Modifier and Type | Method and Description |
|---|---|
static HyperGrpcClientExecutor.HyperGrpcClientExecutorBuilder |
builder() |
void |
close() |
Iterator<ExecuteQueryResponse> |
executeAdaptiveQuery(String sql) |
Iterator<ExecuteQueryResponse> |
executeAsyncQuery(String sql) |
Iterator<ExecuteQueryResponse> |
executeQuery(String sql) |
QueryParam |
getAdditionalQueryParams() |
Iterator<QueryInfo> |
getQueryInfo(String queryId) |
Iterator<QueryInfo> |
getQueryInfoStreaming(String queryId) |
Iterator<QueryResult> |
getQueryResult(String queryId,
long chunkId,
boolean omitSchema) |
static HyperGrpcClientExecutor |
of(HyperGrpcClientExecutor.HyperGrpcClientExecutorBuilder builder,
QueryParam additionalQueryParams,
int queryTimeout) |
static HyperGrpcClientExecutor |
of(@NonNull io.grpc.ManagedChannelBuilder<?> builder,
@NonNull Properties properties) |
HyperGrpcClientExecutor.HyperGrpcClientExecutorBuilder |
toBuilder() |
public static HyperGrpcClientExecutor of(@NonNull @NonNull io.grpc.ManagedChannelBuilder<?> builder, @NonNull @NonNull Properties properties) throws SQLException
SQLExceptionpublic static HyperGrpcClientExecutor of(HyperGrpcClientExecutor.HyperGrpcClientExecutorBuilder builder, QueryParam additionalQueryParams, int queryTimeout)
public Iterator<ExecuteQueryResponse> executeAdaptiveQuery(String sql) throws SQLException
SQLExceptionpublic Iterator<ExecuteQueryResponse> executeAsyncQuery(String sql) throws SQLException
SQLExceptionpublic Iterator<ExecuteQueryResponse> executeQuery(String sql) throws SQLException
SQLExceptionpublic Iterator<QueryResult> getQueryResult(String queryId, long chunkId, boolean omitSchema)
public void close()
throws Exception
close in interface AutoCloseableExceptionpublic static HyperGrpcClientExecutor.HyperGrpcClientExecutorBuilder builder()
public HyperGrpcClientExecutor.HyperGrpcClientExecutorBuilder toBuilder()
public QueryParam getAdditionalQueryParams()
Copyright © 2025. All rights reserved.