Class HyperGrpcClientExecutor
- java.lang.Object
-
- com.salesforce.datacloud.jdbc.core.HyperGrpcClientExecutor
-
- All Implemented Interfaces:
AutoCloseable
public class HyperGrpcClientExecutor extends Object implements AutoCloseable
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classHyperGrpcClientExecutor.HyperGrpcClientExecutorBuilder
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static HyperGrpcClientExecutor.HyperGrpcClientExecutorBuilderbuilder()voidclose()Iterator<ExecuteQueryResponse>executeAdaptiveQuery(String sql)Iterator<ExecuteQueryResponse>executeAsyncQuery(String sql)Iterator<ExecuteQueryResponse>executeQuery(String sql)QueryParamgetAdditionalQueryParams()Iterator<QueryInfo>getQueryInfo(String queryId)Iterator<QueryInfo>getQueryInfoStreaming(String queryId)Iterator<QueryResult>getQueryResult(String queryId, long chunkId, boolean omitSchema)static HyperGrpcClientExecutorof(@NonNull io.grpc.ManagedChannelBuilder<?> builder, @NonNull Properties properties)static HyperGrpcClientExecutorof(HyperGrpcClientExecutor.HyperGrpcClientExecutorBuilder builder, QueryParam additionalQueryParams, int queryTimeout)HyperGrpcClientExecutor.HyperGrpcClientExecutorBuildertoBuilder()
-
-
-
Method Detail
-
of
public static HyperGrpcClientExecutor of(@NonNull @NonNull io.grpc.ManagedChannelBuilder<?> builder, @NonNull @NonNull Properties properties) throws SQLException
- Throws:
SQLException
-
of
public static HyperGrpcClientExecutor of(HyperGrpcClientExecutor.HyperGrpcClientExecutorBuilder builder, QueryParam additionalQueryParams, int queryTimeout)
-
executeAdaptiveQuery
public Iterator<ExecuteQueryResponse> executeAdaptiveQuery(String sql) throws SQLException
- Throws:
SQLException
-
executeAsyncQuery
public Iterator<ExecuteQueryResponse> executeAsyncQuery(String sql) throws SQLException
- Throws:
SQLException
-
executeQuery
public Iterator<ExecuteQueryResponse> executeQuery(String sql) throws SQLException
- Throws:
SQLException
-
getQueryResult
public Iterator<QueryResult> getQueryResult(String queryId, long chunkId, boolean omitSchema)
-
close
public void close() throws Exception- Specified by:
closein interfaceAutoCloseable- Throws:
Exception
-
builder
public static HyperGrpcClientExecutor.HyperGrpcClientExecutorBuilder builder()
-
toBuilder
public HyperGrpcClientExecutor.HyperGrpcClientExecutorBuilder toBuilder()
-
getAdditionalQueryParams
public QueryParam getAdditionalQueryParams()
-
-