its.app
Class SddReplay

java.lang.Object
  its.app.SddReplay

public class SddReplay

extends java.lang.Object

SddReplay is designed to SDD transmit a chunk of previously stored SDD-formed data, thus mimicking a 'live' SDD data stream. The basic idea is as follows: send the schema frame send the contents frame while data source is not exhausted get a 'row' or 'rows' of data from the source group all rows with the same timestamp to form a data frame F send F, and then optionally sleep the interval between timestamps in the data done NB This assumes that a 'timestamp' type field exists in the replay data. Infinite periodic replay is possible be setting the property loop : true (loop defaults to false). Replay time is incremented by an amount 'period' between iterations and this value is substituted for the original timestamp on output. The period defaults to 24 hours.

Constructor Summary

SddReplay(java.util.Properties p)

Method Summary

static void	main(java.lang.String[] args)
void	replay(long timeOffset)
void	setContentsFrame(java.lang.String s)
void	setDataHeader(java.lang.String s)
void	setDelay(long i)
void	setPort(int port)
void	setSchema(java.lang.String s)
void	setSpeed(int i)
void	setStartTime(int i)
void	setTimeDescriptor(java.lang.String dateFormat, int column)
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

SddReplay

public SddReplay(java.util.Properties p)
          throws java.lang.Exception

Method Detail

main

public static void main(java.lang.String[] args)

setTimeDescriptor

public void setTimeDescriptor(java.lang.String dateFormat,
                              int column)

setSpeed

public void setSpeed(int i)

setDelay

public void setDelay(long i)

setStartTime

public void setStartTime(int i)

setPort

public void setPort(int port)

setSchema

public void setSchema(java.lang.String s)

setContentsFrame

public void setContentsFrame(java.lang.String s)

setDataHeader

public void setDataHeader(java.lang.String s)

start

public void start()
           throws java.lang.Exception

Throws:

java.lang.Exception

replay

public void replay(long timeOffset)
            throws java.lang.Exception

Throws:

java.lang.Exception