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, toStringSingle
getInputOperator
allDone, getInputOperator, getNext, getNumberOfInputs, getOutputRelation, prefix, processTuple, setInputs, toString, toString, tuples
public 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 Operator
EngineException
- thrown whenever the message cannot be retrievedprotected java.util.List<Tuple> innerProcessTuple(Tuple tuple, int inOp) throws EngineException
innerProcessTuple
in class Sink
tuple
- 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 Sink
EngineException
- whenever an output relation cannot be
constructed.