StreamTable

java.lang.Object

com.illumon.iris.db.tables.streaming.RemoteQueryStreamer

com.illumon.iris.db.tables.streaming.StreamTable

All Implemented Interfaces:: RemoteQuery<QueryReplayer>, Serializable

public class StreamTable
extends RemoteQueryStreamer

See Also:: Serialized Form

Method Summary

Modifier and Type	Method	Description
`static StatusObserver`	`downloadTable(RemoteQueryClient rqc, String nameSpace, String tableName, String groupingColumn, String sortColumn, String destinationPath, String... filters)`
`Map<String,Object>`	`getStreams(Database database)`
`static StatusObserver`	`streamTable(RemoteQueryClient rqc, RemoteQuery<Table> query, int memory, String groupingColumn, String sortColumn, Object feedHandler, String iterationFormula)`
`static StatusObserver`	`streamTable(RemoteQueryClient rqc, String nameSpace, String tableName, String groupingColumn, String sortColumn, Object feedHandler, String iterationFormula, String... filters)`

Methods inherited from class com.illumon.iris.db.tables.streaming.RemoteQueryStreamer

execute

Methods inherited from class java.lang.Object

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

Method Details
- getStreams
  
  public Map<String,Object> getStreams(Database database)
  
  Specified by:
  
  getStreams in class RemoteQueryStreamer
- downloadTable
  
  public static StatusObserver downloadTable(RemoteQueryClient rqc, String nameSpace, String tableName, String groupingColumn, String sortColumn, String destinationPath, String... filters) throws IOException
  
  Throws:
  
  IOException
- streamTable
  
  public static StatusObserver streamTable(RemoteQueryClient rqc, RemoteQuery<Table> query, int memory, String groupingColumn, String sortColumn, Object feedHandler, String iterationFormula) throws IOException
  
  Throws:
  
  IOException
- streamTable
  
  public static StatusObserver streamTable(RemoteQueryClient rqc, String nameSpace, String tableName, String groupingColumn, String sortColumn, Object feedHandler, String iterationFormula, String... filters) throws IOException
  
  Throws:
  
  IOException