Package com.streambase.sb.unittest

Interface Enqueuer

public interface Enqueuer

An Enqueuer is used for enqueueing tuples onto a stream.

Since:

6.6

Method Summary

Modifier and Type	Method	Description
void	enqueue(Tuple tuple)	Enqueue Tuple to the stream
void	enqueue(Tuple... tuples)	Enqueue multiple tuples to the stream
<T> void	enqueue(TupleMaker<T> tupleMaker, List<T> t)	Create multiple tuples using a TupleMaker and then enqueue them.
<T> void	enqueue(TupleMaker<T> tupleMaker, T t)	Create a tuple using a TupleMaker and then enqueue it.
<T> void	enqueue(TupleMaker<T> tupleMaker, T... t)	Create multiple tuples using a TupleMaker and then enqueue them.
void	enqueue(List<Tuple> tuples)	Enqueue multiple tuples to the stream
Schema	getSchema()	Get the Schema for the associated stream. Equivalent to getStreamProperties().getSchema()
StreamProperties	getStreamProperties()	Get the StreamProperties for the associated stream.

Method Details

getStreamProperties

StreamProperties getStreamProperties()

Get the StreamProperties for the associated stream.

Returns:

stream properties

getSchema

Schema getSchema()

Get the Schema for the associated stream.
Equivalent to getStreamProperties().getSchema()

Returns:

stream schema

enqueue

void enqueue(Tuple tuple)
      throws StreamBaseException

Enqueue Tuple to the stream

Parameters:

tuple - tuple to enqueue

Throws:

StreamBaseException - enqueue error

enqueue

void enqueue(List<Tuple> tuples)
      throws StreamBaseException

Enqueue multiple tuples to the stream

Parameters:

tuples - tuples to enqueue

Throws:

StreamBaseException - enqueue error

enqueue

void enqueue(Tuple... tuples)
      throws StreamBaseException

Enqueue multiple tuples to the stream

Parameters:

tuples - tuples to enqueue

Throws:

StreamBaseException - enqueue error

enqueue

<T> void enqueue(TupleMaker<T> tupleMaker,
 T t)
          throws StreamBaseException

Create a tuple using a TupleMaker and then enqueue it.

Type Parameters:

T - tuple type

Parameters:

tupleMaker - tuple maker

t - tuple data

Throws:

StreamBaseException - enqueue error

enqueue

<T> void enqueue(TupleMaker<T> tupleMaker,
 T... t)
          throws StreamBaseException

Create multiple tuples using a TupleMaker and then enqueue them.

Type Parameters:

T - tuple type

Parameters:

tupleMaker - tuple maker

t - tuple data

Throws:

StreamBaseException - enqueue error

enqueue

<T> void enqueue(TupleMaker<T> tupleMaker,
 List<T> t)
          throws StreamBaseException

Create multiple tuples using a TupleMaker and then enqueue them.

Type Parameters:

T - tuple type

Parameters:

tupleMaker - tuple maker

t - list of tuple data

Throws:

StreamBaseException - enqueue error