orc.runtime.nodes.result
Class QueueResult

java.lang.Object
  orc.runtime.nodes.Node
      orc.runtime.nodes.result.Result
          orc.runtime.nodes.result.QueueResult

All Implemented Interfaces:

java.io.Serializable

public class QueueResult
extends Result

A special node that adds its output values to the given value queue. Equivalent to (where Q is the output channel):

    P >x> Q.put(x)
 

Author:

dkitchin

See Also:

Serialized Form

Constructor Summary

QueueResult(java.util.concurrent.BlockingQueue<Value> q)

Method Summary

void	emit(Value v)

Methods inherited from class orc.runtime.nodes.result.Result

process

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueueResult

public QueueResult(java.util.concurrent.BlockingQueue<Value> q)

Method Detail

emit

public void emit(Value v)

Specified by:

emit in class Result