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

public class QueryReplayer
extends Object
implements Serializable, StatusObserver

Query replay framework.

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

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

Class QueryReplayer