Uses of Interface
com.ocient.util.CompletableFutures.SQLResult

Packages that use CompletableFutures.SQLResult

Package	Description
com.ocient.jdbc
com.ocient.util

Uses of CompletableFutures.SQLResult in com.ocient.jdbc

Fields in com.ocient.jdbc declared as CompletableFutures.SQLResult

Modifier and Type	Field	Description
static final CompletableFutures.SQLResult<Boolean>	XGResultSet.CONTINUE_ITERATION	Commonly used markers
static final CompletableFutures.SQLResult<Boolean>	XGResultSet.STOP_ITERATION

Fields in com.ocient.jdbc with type parameters of type CompletableFutures.SQLResult

Modifier and Type	Field	Description
static final CompletableFuture<CompletableFutures.SQLResult<Boolean>>	XGResultSet.CONTINUE_ITERATION_ASYNC
static final CompletableFuture<CompletableFutures.SQLResult<Boolean>>	XGResultSet.STOP_ITERATION_ASYNC

Methods in com.ocient.jdbc that return types with arguments of type CompletableFutures.SQLResult

Modifier and Type	Method	Description
CompletionStage<CompletableFutures.SQLResult<Void>>	XGConnection.awaitActivation()
CompletionStage<CompletableFutures.SQLResult<Void>>	XGResultSet.awaitClose()
CompletionStage<CompletableFutures.SQLResult<Void>>	XGConnection.closeAsync()
CompletionStage<CompletableFutures.SQLResult<Void>>	XGResultSet.closeAsync()
CompletionStage<CompletableFutures.SQLResult<Boolean>>	XGStatement.closeAsync()
CompletionStage<CompletableFutures.SQLResult<Boolean>>	XGStatement.closeResultSet()
CompletionStage<CompletableFutures.SQLResult<XGConnection>>	XGConnectionFactory.create(XGConnectionInfo info)	Returns a CompletionStage of CompletableFutures.SQLResult which completes when the connection is successfully established, or completes exceptionally if the connection cannot be established.
CompletionStage<CompletableFutures.SQLResult<List<ClientWireProtocol.Authenticator>>>	XGConnection.fetchAuthenticators()	Fetches all ClientWireProtocol.Authenticators
protected CompletionStage<CompletableFutures.SQLResult<Void>>	XGConnection.fetchServerVersion()	Asynchronously fetches the version of the server.
CompletionStage<CompletableFutures.SQLResult<Integer>>	XGStatement.fetchSystemMetadataInt(ClientWireProtocol.FetchSystemMetadata.SystemMetadataCall call)
CompletionStage<CompletableFutures.SQLResult<ResultSet>>	XGStatement.fetchSystemMetadataResultSet(ClientWireProtocol.FetchSystemMetadata.SystemMetadataCall call, String schema, String table, String col, boolean test, XGResultSet.Option... options)
CompletionStage<CompletableFutures.SQLResult<String>>	XGStatement.fetchSystemMetadataString(ClientWireProtocol.FetchSystemMetadata.SystemMetadataCall call)
CompletionStage<CompletableFutures.SQLResult<Void>>	XGConnection.forceExternalAsync(boolean force)
CompletionStage<CompletableFutures.SQLResult<XGConnection>>	XGConnection.forkConnectionAsync(XGConnectionInfo.Hint hint, boolean hint_bypassLoadBalancerOnHandshakeOnly)
static CompletionStage<CompletableFutures.SQLResult<XGResultSet>>	XGResultSet.initResultSet(XGConnection conn, int fetchSize, XGStatement stmt, int parallelism, XGConnectionFactory channelFactory, RowTransformerFactory rowTransformerFactory, SortMode sortMode, Map<String,Integer> streamProperties)	Initializes a new XGResultSet object and returns a CompletionStage that completes when the result set's metadata has been retrieved from the server and completes with an exceptional CompletableFutures.SQLResult on failure.
static CompletionStage<CompletableFutures.SQLResult<XGResultSet>>	XGResultSet.initResultSetMetadata(XGConnection conn, int fetchSize, XGStatement stmt, ClientWireProtocol.ResultSet data, XGResultSet.Option... options)	Initializes a new XGResultSet object and returns a CompletionStage that completes when the result set's metadata has been retrieved from the server and completes with an exceptional CompletableFutures.SQLResult on failure.
protected CompletionStage<CompletableFutures.SQLResult<Void>>	XGConnection.initTransport(String ip, int port)
protected CompletionStage<CompletableFutures.SQLResult<Void>>	XGConnection.initTransportAndBeginHandshake()
static CompletionStage<CompletableFutures.SQLResult<XGConnection>>	XGConnection.leaseConnection(XGConnectionInfo info)	Leases a connection to the database specified by info.
CompletionStage<CompletableFutures.SQLResult<Void>>	XGConnection.reconnect()
CompletionStage<CompletableFutures.SQLResult<Void>>	XGConnection.reconnect(boolean shouldRequestVersion)
CompletionStage<CompletableFutures.SQLResult<Void>>	XGConnection.redirect(String host, int port, boolean shouldRequestVersion)	Deprecated. As of 2.106, callers should close *this* instance and lease a *new* connection to the desired endpoint using XGConnection.leaseConnection(XGConnectionInfo) or invalid reference DriverManager#getConnection .
CompletionStage<CompletableFutures.SQLResult<Void>>	XGStatement.redirect(String host, int port)	Force a redirect to the provided endpoint.
CompletionStage<CompletableFutures.SQLResult<Void>>	XGConnection.refreshSession()
CompletionStage<CompletableFutures.SQLResult<Void>>	XGConnection.refreshToken()
protected CompletionStage<CompletableFutures.SQLResult<Void>>	XGConnection.reset(boolean forceParameterRefresh)
protected CompletionStage<CompletableFutures.SQLResult<Void>>	XGPreparedStatement.reset()
protected CompletionStage<CompletableFutures.SQLResult<Void>>	XGStatement.reset()
protected CompletionStage<CompletableFutures.SQLResult<Void>>	XGConnection.sendHeartbeat()	Sends a heartbeat message to test the connection with the server asynchronously.
CompletionStage<CompletableFutures.SQLResult<Integer>>	XGConnection.sendParameterMessage(ClientWireProtocol.SetParameter param)
CompletionStage<CompletableFutures.SQLResult<com.ocient.jdbc.XGConnection.Session.State>>	XGConnection.sendRefreshSession()
CompletionStage<CompletableFutures.SQLResult<com.ocient.jdbc.XGConnection.Session.State>>	XGConnection.sendRefreshToken(com.ocient.jdbc.XGConnection.Session.State oldState)
protected <Response> CompletionStage<CompletableFutures.SQLResult<Response>>	XGConnection.sendRequest(ClientWireProtocol.Request request, XGConnection.ResponseHandler<Response> responseHandler, Predicate<SQLWarning> warningHandler, XGConnection.ConfirmationSupplier<Response> confirmationSupplier)	Sends a request message to the remote server and waits for a response.
protected CompletionStage<CompletableFutures.SQLResult<Void>>	XGConnection.sendRequestWithoutResponse(ClientWireProtocol.Request request)	Sends a request message to the remote server byt does not wait for a response.
protected CompletionStage<CompletableFutures.SQLResult<ClientWireProtocol.ConfirmationResponse>>	XGConnection.sendRequestWithStandardResponse(ClientWireProtocol.Request request, Predicate<SQLWarning> warningHandler)	Sends a request message to the remote server and waits for a standard confirmation response.
CompletionStage<CompletableFutures.SQLResult<Integer>>	XGConnection.setMaxRowsHardLimit(Integer maxRows, boolean reset)
CompletionStage<CompletableFutures.SQLResult<Integer>>	XGConnection.setMaxTempDisk(Integer maxTempDisk, boolean reset)
CompletionStage<CompletableFutures.SQLResult<Integer>>	XGConnection.setMaxTime(Integer maxTime, boolean reset)
CompletionStage<CompletableFutures.SQLResult<Integer>>	XGConnection.setMemoryTracing(boolean memoryTracing, boolean reset)
CompletionStage<CompletableFutures.SQLResult<Integer>>	XGConnection.setParallelism(Integer parallelism, boolean reset)
CompletionStage<CompletableFutures.SQLResult<Integer>>	XGConnection.setPriority(Double priority, boolean reset)
CompletionStage<CompletableFutures.SQLResult<Integer>>	XGConnection.setPriorityAdjustFactor(Double priorityAdjustFactor, boolean reset)
CompletionStage<CompletableFutures.SQLResult<Integer>>	XGConnection.setPriorityAdjustTime(Integer priorityAdjustTime, boolean reset)
CompletionStage<CompletableFutures.SQLResult<Void>>	XGConnection.setSchemaAsync(String schema)
CompletionStage<CompletableFutures.SQLResult<Integer>>	XGConnection.setServiceClassName(String serviceClassName, boolean reset)

Uses of CompletableFutures.SQLResult in com.ocient.util

Methods in com.ocient.util that return CompletableFutures.SQLResult

Modifier and Type	Method	Description
static <T> CompletableFutures.SQLResult<T>	CompletableFutures.blockingGetSQLResult(CompletionStage<CompletableFutures.SQLResult<T>> stage)	Blocks until the specified CompletionStage completes and returns its result as a CompletableFutures.SQLResult instance.
static <T> CompletableFutures.SQLResult<T>	CompletableFutures.SQLResult.fail(SQLException e)	Creates a new instance of SQLResult that represents a failed execution of a SQL query.
static <T> CompletableFutures.SQLResult<T>	CompletableFutures.SQLResult.failOrMarshal(Throwable throwable)	Returns a new Result object that represents a failed operation with the given SQLException.
default <U> CompletableFutures.SQLResult<U>	CompletableFutures.SQLResult.flatMapSuccess(Function<? super T,? extends CompletableFutures.SQLResult<U>> fn)	Maps the success value of this SQLResult to the CompletableFutures.SQLResult type returned from the given function.
default <U> CompletableFutures.SQLResult<U>	CompletableFutures.SQLResult.mapSuccess(Function<? super T,? extends U> fn)
static <T> CompletableFutures.SQLResult<T>	CompletableFutures.SQLResult.success(T item)	Creates a new instance of SQLResult that represents a successful execution of a SQL query.
static CompletableFutures.SQLResult<Void>	CompletableFutures.SQLResult.voidResult()	Returns a CompletableFutures.SQLResult that represents a successful execution of a SQL query that does not produce a result.

Methods in com.ocient.util that return types with arguments of type CompletableFutures.SQLResult

Modifier and Type	Method	Description
static <T> CompletionStage<CompletableFutures.SQLResult<T>>	CompletableFutures.SQLResult.failAsync(SQLException e)	Creates a new completed stage that represents a failed execution of a SQL query.
static <T> CompletionStage<CompletableFutures.SQLResult<T>>	CompletableFutures.SQLResult.failOrMarshalAsync(Throwable throwable)	Returns a new completed stage that represents a failed operation with the given SQLException.
default <U> CompletionStage<CompletableFutures.SQLResult<U>>	CompletableFutures.SQLResult.mapSuccessAsync(Function<? super T,? extends CompletionStage<CompletableFutures.SQLResult<U>>> fn)	Maps the success value of this Result to a new completed stage of a different CompletableFutures.SQLResult type by applying the given function.
CompletionStage<com.ibm.asyncutil.util.Either<com.ibm.asyncutil.iteration.AsyncIterator.End,CompletableFutures.SQLResult<List<Row>>>>	Iterators.LazyFanInPriorityQueue.nextStage()
default CompletionStage<CompletableFutures.SQLResult<T>>	CompletableFutures.SQLResult.recoverAsync(Function<? super SQLException,? extends CompletionStage<CompletableFutures.SQLResult<T>>> fn)	Maps the error value of this SQLResult to a new completion stage that completes with a new SQLResult by applying the given function.
static <T> CompletionStage<CompletableFutures.SQLResult<T>>	CompletableFutures.SQLResult.successAsync(T item)	Creates a new completed stage that represents a successful execution of a SQL query.
static CompletionStage<CompletableFutures.SQLResult<Void>>	CompletableFutures.SQLResult.voidFuture()	Returns a CompletionStage that completes successfully with a CompletableFutures.SQLResult that represents a successful execution of a SQL query that does not produce a result.

Methods in com.ocient.util with parameters of type CompletableFutures.SQLResult

Modifier and Type	Method	Description
boolean	Iterators.LazyFanInPriorityQueue.send(int streamIndex, CompletableFutures.SQLResult<RowBatch> batchOrEx, QueuePermit permit)	Sends an item to the specified stream index.

Method parameters in com.ocient.util with type arguments of type CompletableFutures.SQLResult

Modifier and Type	Method	Description
static <T> CompletableFutures.SQLResult<T>	CompletableFutures.blockingGetSQLResult(CompletionStage<CompletableFutures.SQLResult<T>> stage)	Blocks until the specified CompletionStage completes and returns its result as a CompletableFutures.SQLResult instance.
default <U> CompletableFutures.SQLResult<U>	CompletableFutures.SQLResult.flatMapSuccess(Function<? super T,? extends CompletableFutures.SQLResult<U>> fn)	Maps the success value of this SQLResult to the CompletableFutures.SQLResult type returned from the given function.
default <U> CompletionStage<CompletableFutures.SQLResult<U>>	CompletableFutures.SQLResult.mapSuccessAsync(Function<? super T,? extends CompletionStage<CompletableFutures.SQLResult<U>>> fn)	Maps the success value of this Result to a new completed stage of a different CompletableFutures.SQLResult type by applying the given function.
default CompletionStage<CompletableFutures.SQLResult<T>>	CompletableFutures.SQLResult.recoverAsync(Function<? super SQLException,? extends CompletionStage<CompletableFutures.SQLResult<T>>> fn)	Maps the error value of this SQLResult to a new completion stage that completes with a new SQLResult by applying the given function.

Constructor parameters in com.ocient.util with type arguments of type CompletableFutures.SQLResult

Modifier	Constructor	Description
	LazyFanInPriorityQueue(int width, int capacity, SortMode sortMode, String queryId, Consumer<CompletableFutures.SQLResult<RowBatch>> onAdd, BiConsumer<CompletableFutures.SQLResult<RowBatch>,QueuePermit> onRemove, Executor executor)	Constructs a LazyFanInPriorityQueue with the specified parameters.
	LazyFanInPriorityQueue(int width, int capacity, SortMode sortMode, String queryId, Consumer<CompletableFutures.SQLResult<RowBatch>> onAdd, BiConsumer<CompletableFutures.SQLResult<RowBatch>,QueuePermit> onRemove, Executor executor)	Constructs a LazyFanInPriorityQueue with the specified parameters.