Package com.illumon.iris.db.tables.remote

Class RemoteTableQuery

java.lang.Object

com.illumon.iris.db.tables.remotequery.ContextAwareRemoteQuery<Inflatable<Table>>

com.illumon.iris.db.tables.remote.RemoteTableQuery

All Implemented Interfaces:

RemoteQuery<Inflatable<Table>>, Serializable

public class RemoteTableQuery
extends ContextAwareRemoteQuery<Inflatable<Table>>

Provides a mechanism for adapting remote queries that return tables into remote queries that return proxy-able table handles for remote clients to use.

See Also:

Serialized Form

ApiNote:

All of the getRemoteTableProxy(com.illumon.iris.db.tables.remotequery.QueryProcessorConnection, com.illumon.iris.db.tables.remotequery.RemoteQuery<com.illumon.iris.db.tables.Table>) methods will enclose their inner query execution in an anonymous LivenessScope in order to ensure that only the final result is retained, and that only by the deflatable result.

Constructor Summary

Constructors

Constructor	Description
RemoteTableQuery(RemoteQuery<Table> innerQuery)

Method Summary

Modifier and Type	Method	Description
Inflatable<Table>	execute(Database database)	Execute a query on a remote host.
static Table	getRemoteTableProxy(QueryProcessorConnection connection, RemoteQuery<Table> tableQuery)
static Table	getRemoteTableProxy(QueryProcessorConnection connection, RemoteQuery<Table> tableQuery, boolean concurrent)
static Table	getRemoteTableProxy(RemoteQueryClient client, RemoteQuery<Table> tableQuery)

Methods inherited from class com.illumon.iris.db.tables.remotequery.ContextAwareRemoteQuery

getClient, getLog, getRemoteQueryProcessor, getUserContext, initializeContext, initializeContext

Methods inherited from class java.lang.Object

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

Constructor Details

RemoteTableQuery

public RemoteTableQuery(RemoteQuery<Table> innerQuery)

Method Details

execute

public Inflatable<Table> execute(Database database)

Description copied from interface: RemoteQuery

Execute a query on a remote host.

Parameters:

database - database to use for execution.

Returns:

result of the query.

getRemoteTableProxy

public static Table getRemoteTableProxy(QueryProcessorConnection connection, RemoteQuery<Table> tableQuery)

getRemoteTableProxy

public static Table getRemoteTableProxy(QueryProcessorConnection connection, RemoteQuery<Table> tableQuery, boolean concurrent)

getRemoteTableProxy

public static Table getRemoteTableProxy(RemoteQueryClient client, RemoteQuery<Table> tableQuery) throws IOException

Throws:

IOException