nextflow.extension

The nextflow.extension package implements the channel operators and other extension methods.

Class Diagram

classDiagram %% %% nextflow.extension %% direction LR ChannelEx --> DumpOp : dump Nextflow --> GroupKey : groupKey OperatorImpl --> BranchOp : branch OperatorImpl --> BufferOp : buffer OperatorImpl --> CollectFileOp : collectFile OperatorImpl --> CollectOp : collect OperatorImpl --> CombineOp : combine OperatorImpl --> ConcatOp : concat OperatorImpl --> CrossOp : cross OperatorImpl --> GroupTupleOp : groupTuple OperatorImpl --> JoinOp : join OperatorImpl --> MapOp : map OperatorImpl --> MergeOp : merge OperatorImpl --> MixOp : mix OperatorImpl --> MultiMapOp : multiMap OperatorImpl --> RandomSampleOp : randomSample OperatorImpl --> SplitOp : splitCsv, splitFasta, splitFastq, splitText OperatorImpl --> TakeOp : take OperatorImpl --> ToListOp : toList, toSortedList OperatorImpl --> TransposeOp : transpose OperatorImpl --> UntilOp : until WorkflowBinding --> OpCall : invokeMethod

Note

Some classes may be excluded from the above diagram for brevity.

Notes

Operators are implemented using the GPars dataflow library. In general, an operator consumes one or more DataflowReadChannels and produces one or more DataflowWriteChannels. See Operators for details about each operator.

Other notable classes include Bolts and FilesEx, which implement various extension methods used throughout the Nextflow codebase. If you see a method that doesn’t appear to be implemented by the calling object, it may be implemented in one of these extension classes.