public class MessageSink extends Sink
tupleCounter| Constructor and Description |
|---|
MessageSink(java.lang.String message)
Constructs a new message sink.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.List<Tuple> |
getMultiNext()
Overriden method to retrieve this sink's message.
|
protected java.util.List<Tuple> |
innerProcessTuple(Tuple tuple,
int inOp)
The inner tuple processing method -- doesn't do anything.
|
protected Relation |
setOutputRelation()
Doesn't do anything -- returns null by default.
|
cleanup, innerGetNext, setup, toStringSinglegetInputOperatorallDone, getInputOperator, getNext, getNumberOfInputs, getOutputRelation, prefix, processTuple, setInputs, toString, toString, tuplespublic MessageSink(java.lang.String message)
throws EngineException
message - the message.EngineException - thrown whenever the operator cannot
be properly constructed.public java.util.List<Tuple> getMultiNext() throws EngineException
getMultiNext in class OperatorEngineException - thrown whenever the message cannot be retrievedprotected java.util.List<Tuple> innerProcessTuple(Tuple tuple, int inOp) throws EngineException
innerProcessTuple in class Sinktuple - the tuple to be processed.inOp - the index of the input operator the tuple to be
processed belongs to.EngineException - thrown whenever there is something
wrong with processing the tuple.protected Relation setOutputRelation() throws EngineException
setOutputRelation in class SinkEngineException - whenever an output relation cannot be
constructed.