Overview  Package   Class  Deprecated  Index  Help 
org.codehaus.gpars
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | PROPERTY | CONSTR | METHOD DETAIL: FIELD | PROPERTY | CONSTR | METHOD

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.