streamcruncher.api
Class InputSession

java.lang.Object
  streamcruncher.api.InputSession

public class InputSession
extends java.lang.Object

Each Input Event Stream can have 1 instance, which should be used to notify the Kernel of Events that have been added and committed into the underlying Database. The Kernel does not check if there already is another instance of this Class for the same Input Event Stream. So, the user must take care to create only one instance per Stream. The instances are not Thread-safe. The session can be started and closed and re-started and so on any number of times.

Method Summary

void	close()
java.lang.String	getName()
void	start()
void	submitEvent(java.lang.Object[] event) Note: This operation works by assuming that there will be only one Thread invoking this method at a time.
void	submitEvents(java.lang.Object[][] events) Note: This operation works by assuming that there will be only one Thread invoking this method at a time.

Methods inherited from class java.lang.Object

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

Method Detail

getName

public java.lang.String getName()

start

public void start()
           throws StreamCruncherException

Throws:

StreamCruncherException

submitEvent

public void submitEvent(java.lang.Object[] event)

Note: This operation works by assuming that there will be only one Thread invoking this method at a time.

Parameters:

event - The Event-Id column must be non-null and unique.

submitEvents

public void submitEvents(java.lang.Object[][] events)

Note: This operation works by assuming that there will be only one Thread invoking this method at a time.

Parameters:

events - The Event-Id column must be non-null and unique.

close

public void close()
           throws StreamCruncherException

Throws:

StreamCruncherException