edu.umass.cs.sase.stream
Class StreamController

java.lang.Object
  extended by edu.umass.cs.sase.stream.StreamController

public class StreamController
extends java.lang.Object

This class wraps the stream, specifies how to generate or import stream.

Author:
haopeng

Constructor Summary
StreamController()
          Default constructor
StreamController(int size, java.lang.String eventType)
          Constructor, specified size and event type
 
Method Summary
 void generateABCEvents()
          Generates ABCEvents for the stream
 void generateNextStockEvents(int number)
          Generates another batch of stock events
 void generateStockEvents()
          Generates a series of stock events
 void generateStockEventsAsConfig()
          Generates a series of stock events
 void generateStockEventsAsConfigType()
          Generates a series of stock events
 void generateStockEventsWithIncreaseProbability()
          Generates a series of stock events
 Stream getMyStream()
           
 int getSize()
           
 void printStream()
          Outputs the events in the stream one by one in the console
 void setMyStream(Stream myStream)
           
 void setSize(int size)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

StreamController

public StreamController()
Default constructor


StreamController

public StreamController(int size,
                        java.lang.String eventType)
Constructor, specified size and event type

Parameters:
size -
eventType -
Method Detail

generateStockEventsAsConfig

public void generateStockEventsAsConfig()
Generates a series of stock events


generateStockEventsAsConfigType

public void generateStockEventsAsConfigType()
Generates a series of stock events


generateStockEventsWithIncreaseProbability

public void generateStockEventsWithIncreaseProbability()
Generates a series of stock events


generateStockEvents

public void generateStockEvents()
Generates a series of stock events


generateNextStockEvents

public void generateNextStockEvents(int number)
Generates another batch of stock events

Parameters:
number - the size of the stream

generateABCEvents

public void generateABCEvents()
Generates ABCEvents for the stream


getMyStream

public Stream getMyStream()
Returns:
the myStream

setMyStream

public void setMyStream(Stream myStream)
Parameters:
myStream - the myStream to set

getSize

public int getSize()
Returns:
the size

setSize

public void setSize(int size)
Parameters:
size - the size to set

printStream

public void printStream()
Outputs the events in the stream one by one in the console