Package com.illumon.iris.controller.utils

Class PersistentQueryTableHelper.HelperPersistentQueryClient

java.lang.Object

com.illumon.iris.controller.utils.PersistentQueryTableHelper.HelperPersistentQueryClient

All Implemented Interfaces:

QueryProcessorConnection.DisconnectHandler

Enclosing class:

PersistentQueryTableHelper

public static class PersistentQueryTableHelper.HelperPersistentQueryClient
extends Object
implements QueryProcessorConnection.DisconnectHandler

A wrapper around a PersistentQueryClient that retrieves and subscribes to preemptive tables. The query writer must prepare the tables used by this class for subscription to by calling Table.preemptiveUpdatesTable(long) from within the persistent query script code.

Method Summary

Modifier and Type	Method	Description
PersistentQueryClient	getPersistentQueryClient()	Get the underlying PersistentQueryClient.
Table	getPreemptiveTable(String tableName)	Create a full subscription to the named table, suitable for further use within the local query engine.
Table	getUnsubscribedTable(String tableName)	Get a handle to a table from the persistent query.
void	onDisconnect()

Methods inherited from class java.lang.Object

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

Method Details

getPersistentQueryClient

public PersistentQueryClient getPersistentQueryClient()

Get the underlying PersistentQueryClient.

Returns:

the persistent query client

getPreemptiveTable

public Table getPreemptiveTable(String tableName)

Create a full subscription to the named table, suitable for further use within the local query engine. The remote table must be a PreemptiveUpdatesTable.

Parameters:

tableName - the table's name in the binding of the persistent query

Returns:

a local updating copy of the remote table

getUnsubscribedTable

public Table getUnsubscribedTable(String tableName)

Get a handle to a table from the persistent query.

Parameters:

tableName - the table's name in the binding of the persistent query

Returns:

a handle to the remote table

onDisconnect

public void onDisconnect()

Specified by:

onDisconnect in interface QueryProcessorConnection.DisconnectHandler