com.splicemachine.derby.impl.sql

Class LocalOlapClient

java.lang.Object

com.splicemachine.derby.impl.sql.LocalOlapClient

All Implemented Interfaces:

OlapClient

public class LocalOlapClient
extends java.lang.Object
implements OlapClient

Method Summary

Modifier and Type	Method and Description
<R extends OlapResult> R	execute(DistributedJob jobRequest) Synchronously execute the expected job.
static LocalOlapClient	getInstance()
void	shutdown()
<R extends OlapResult> org.spark_project.guava.util.concurrent.ListenableFuture<R>	submit(DistributedJob jobRequest) Submits a job for asynchronous execution.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getInstance

public static LocalOlapClient getInstance()

execute

public <R extends OlapResult> R execute(@Nonnull
                                        DistributedJob jobRequest)
                                 throws java.io.IOException,
                                        java.util.concurrent.TimeoutException

Description copied from interface: OlapClient

Synchronously execute the expected job. Handling Interruption If the calling thread is interrupted during the execution of this job, the thread's interrupt status will be set, and we will throw an IOException.

Specified by:

execute in interface OlapClient

Type Parameters:

R - the Type of OlapResult expected back from the server

Parameters:

jobRequest - the job to run. Cannot be null

Returns:

the result of this job.

Throws:

java.io.IOException - if something goes wrong communicating with the OlapServer

java.util.concurrent.TimeoutException - if the operations timed out and needs to be aborted

submit

public <R extends OlapResult> org.spark_project.guava.util.concurrent.ListenableFuture<R> submit(@Nonnull
                                                                                                 DistributedJob jobRequest)
                                                                                          throws java.io.IOException

Description copied from interface: OlapClient

Submits a job for asynchronous execution.

Specified by:

submit in interface OlapClient

Type Parameters:

R - the Type of OlapResult expected back from the server, which will be wrapped in a Future

Parameters:

jobRequest - the job to run. Cannot be null

Returns:

a cancellable Future that, when completed, contains the result of this job.

Throws:

java.io.IOException - if something goes wrong communicating with the OlapServer

shutdown

public void shutdown()

Specified by:

shutdown in interface OlapClient