@groovy.util.logging.Slf4j @groovy.transform.CompileStatic class BidsHandler extends java.lang.Object
Fluent builder that orchestrates the full BIDS-to-channel pipeline.
Typical usage (via BidsChannelFactory):
new BidsHandler()
.withConfig(configPath)
.withBidsDir(bidsDir)
.withOpts(options)
.withParser(new BidsParser(session))
.ignite(session)
Internally the handler:
[meta, data…] map per group.| Constructor and description |
|---|
BidsHandler() |
| Type Params | Return Type | Name and description |
|---|---|---|
|
groovyx.gpars.dataflow.DataflowWriteChannel |
ignite(nextflow.Session session)Create the output channel and schedule asynchronous execution. |
|
protected void |
loadConfiguration(java.lang.String configPath)Load and analyze configuration from file or use defaults |
|
BidsHandler |
perform(boolean async)Execute the BIDS parsing pipeline, optionally in a background thread. |
|
BidsHandler |
withBidsDir(java.lang.String bidsDir)Set the path to the BIDS dataset directory. |
|
BidsHandler |
withConfig(java.lang.String configPath)Load and analyze the YAML configuration file. |
|
BidsHandler |
withOpts(java.util.Map options)Supply the runtime options map (e.g. |
|
BidsHandler |
withParser(nfneuro.plugin.parser.BidsParser parser)Inject the nfneuro.plugin.parser.BidsParser to use for dataset parsing. |
|
BidsHandler |
withTarget(groovyx.gpars.dataflow.DataflowWriteChannel target)Override the output channel (used internally by ignite). |
| Methods inherited from class | Name |
|---|---|
class java.lang.Object |
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(), java.lang.Object#wait(long), java.lang.Object#wait(long, int), java.lang.Object#wait() |
Create the output channel and schedule asynchronous execution.
In DSL2 mode the work is deferred via session.addIgniter; in DSL1 it
runs immediately. Either way the returned channel is ready to be consumed by
downstream operators before parsing has completed.
session - the active Nextflow sessionDataflowWriteChannel that will receive BIDS data itemsLoad and analyze configuration from file or use defaults
configPath - Path to YAML configuration fileExecute the BIDS parsing pipeline, optionally in a background thread.
async - true to run asynchronously via java.util.concurrent.CompletableFuture (default);
false to block the calling threadthis for method chainingSet the path to the BIDS dataset directory.
bidsDir - absolute path to the root of the BIDS datasetthis for method chainingLoad and analyze the YAML configuration file.
configPath - path to a bids2nf.yaml configuration file, or null to use defaultsthis for method chaining Supply the runtime options map (e.g. libbids_sh, flatten_output).
options - map of additional options forwarded from Channel.fromBIDS()this for method chainingInject the nfneuro.plugin.parser.BidsParser to use for dataset parsing.
parser - pre-constructed parser instancethis for method chainingOverride the output channel (used internally by ignite).
target - the Dataflow write channel to bind results intothis for method chaining