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

Class QueryReplayer

java.lang.Object

com.illumon.iris.db.tables.streaming.QueryReplayer

All Implemented Interfaces:

StatusObserver, Serializable

public class QueryReplayer
extends Object
implements Serializable, StatusObserver

Query replay framework.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	QueryReplayer.TablePlayer

Nested classes/interfaces inherited from interface com.illumon.iris.db.tables.streaming.StatusObserver

StatusObserver.Listener

Constructor Summary

Constructors

Constructor	Description
QueryReplayer(Map<String,Object> tableMap)

Method Summary

Modifier and Type	Method	Description
StatusObserver	downloadTable(String tableName, String tableDestinationPath)
Set<String>	getTableNames()
void	handleIncoming(SocketChannel channel)
void	initAcceptor()
boolean	isDone()
void	listenDone(StatusObserver.Listener listener)
StatusObserver	listenToTable(String tableName, String iterationFormula)
static StatusObserver	replayTable(Table table, String iterationFormula)
void	setProcessorConnection(QueryProcessorConnection processorConnection)
boolean	waitDone(long timeout)

Methods inherited from class java.lang.Object

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

Constructor Details

QueryReplayer

public QueryReplayer(Map<String,Object> tableMap)

Method Details

initAcceptor

public void initAcceptor()

handleIncoming

public void handleIncoming(SocketChannel channel)
                    throws IOException

Throws:

IOException

isDone

public boolean isDone()

Specified by:

isDone in interface StatusObserver

waitDone

public boolean waitDone(long timeout)

Specified by:

waitDone in interface StatusObserver

listenDone

public void listenDone(StatusObserver.Listener listener)

Specified by:

listenDone in interface StatusObserver

setProcessorConnection

public void setProcessorConnection(QueryProcessorConnection processorConnection)

downloadTable

public StatusObserver downloadTable(String tableName,
 String tableDestinationPath)
                             throws IOException

Throws:

IOException

listenToTable

public StatusObserver listenToTable(String tableName,
 String iterationFormula)
                             throws IOException

Throws:

IOException

replayTable

public static StatusObserver replayTable(Table table,
 String iterationFormula)

getTableNames

public Set<String> getTableNames()