org.codehaus.gpars

groovyx.gpars.dataflow
[Groovy] Class ProcessingNode

java.lang.Object
  groovyx.gpars.dataflow.ProcessingNode

@groovy.transform.CompileStatic(value = TypeCheckingMode.PASS)
class ProcessingNode

A ProcessingNode specifies a DataflowOperator: its input and output channels, maxForks and its body of processing logic.

Authors:
Dierk Koenig


Property Summary
groovy.lang.Closure body

java.util.List inputs

int maxForks

java.util.List outputs

 
Constructor Summary
ProcessingNode()

 
Method Summary
static ProcessingNode node(groovy.lang.Closure body)

Convenience factory method

DataflowProcessor operator(PGroup group)

Factory method for an immediately started operator for this node

 
Methods inherited from class java.lang.Object
java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()
 

Property Detail

body

groovy.lang.Closure body


inputs

final java.util.List inputs


maxForks

int maxForks


outputs

final java.util.List outputs


 
Constructor Detail

ProcessingNode

ProcessingNode()


 
Method Detail

node

static ProcessingNode node(groovy.lang.Closure body)
Convenience factory method. *


operator

DataflowProcessor operator(PGroup group)
Factory method for an immediately started operator for this node. *


 

Copyright © 2008–2013 Václav Pech. All Rights Reserved.