Package com.illumon.iris.db.tables.streaming

Class 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