public interface Enqueuer
Modifier and Type | Method and Description |
---|---|
void |
enqueue(java.util.List<Tuple> tuples)
Enqueue multiple tuples to the stream
|
void |
enqueue(Tuple... tuples)
Enqueue multiple tuples to the stream
|
void |
enqueue(Tuple tuple)
Enqueue Tuple to the stream
|
<T> void |
enqueue(TupleMaker<T> tupleMaker,
java.util.List<T> t)
Create multiple tuples using a
TupleMaker and then enqueue them. |
<T> void |
enqueue(TupleMaker<T> tupleMaker,
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. |
Schema |
getSchema()
|
StreamProperties |
getStreamProperties()
Get the
StreamProperties for the associated stream. |
StreamProperties getStreamProperties()
StreamProperties
for the associated stream.Schema getSchema()
void enqueue(Tuple tuple) throws StreamBaseException
StreamBaseException
void enqueue(java.util.List<Tuple> tuples) throws StreamBaseException
StreamBaseException
void enqueue(Tuple... tuples) throws StreamBaseException
StreamBaseException
<T> void enqueue(TupleMaker<T> tupleMaker, T t) throws StreamBaseException
TupleMaker
and then enqueue it.StreamBaseException
<T> void enqueue(TupleMaker<T> tupleMaker, T... t) throws StreamBaseException
TupleMaker
and then enqueue them.StreamBaseException
<T> void enqueue(TupleMaker<T> tupleMaker, java.util.List<T> t) throws StreamBaseException
TupleMaker
and then enqueue them.StreamBaseException