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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
enqueue(Tuple tuple)
Enqueue Tuple to the streamvoid
enqueue(Tuple... tuples)
Enqueue multiple tuples to the stream<T> void
enqueue(TupleMaker<T> tupleMaker, List<T> t)
Create multiple tuples using aTupleMaker
and then enqueue them.<T> void
enqueue(TupleMaker<T> tupleMaker, T t)
Create a tuple using aTupleMaker
and then enqueue it.<T> void
enqueue(TupleMaker<T> tupleMaker, T... t)
Create multiple tuples using aTupleMaker
and then enqueue them.void
enqueue(List<Tuple> tuples)
Enqueue multiple tuples to the streamSchema
getSchema()
StreamProperties
getStreamProperties()
Get theStreamProperties
for the associated stream.
-
-
-
Method Detail
-
getStreamProperties
StreamProperties getStreamProperties()
Get theStreamProperties
for the associated stream.- Returns:
- stream properties
-
getSchema
Schema 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 aTupleMaker
and then enqueue it.- Type Parameters:
T
- tuple type- Parameters:
tupleMaker
- tuple makert
- tuple data- Throws:
StreamBaseException
- enqueue error
-
enqueue
<T> void enqueue(TupleMaker<T> tupleMaker, T... t) throws StreamBaseException
Create multiple tuples using aTupleMaker
and then enqueue them.- Type Parameters:
T
- tuple type- Parameters:
tupleMaker
- tuple makert
- tuple data- Throws:
StreamBaseException
- enqueue error
-
enqueue
<T> void enqueue(TupleMaker<T> tupleMaker, List<T> t) throws StreamBaseException
Create multiple tuples using aTupleMaker
and then enqueue them.- Type Parameters:
T
- tuple type- Parameters:
tupleMaker
- tuple makert
- list of tuple data- Throws:
StreamBaseException
- enqueue error
-
-