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 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