API reference¶
binning¶
Binning ([boundaries, lows, ups, retvalue, …]) |
|
Echo ([nextFunc, valid]) |
|
Round ([width, aboundary, min, …]) |
Equal width binning |
RoundLog ([width, aboundary, min, …]) |
Binning with equal width in log scale |
loop¶
Collector (resultsCombinationMethod[, …]) |
This class collects results, i.e., this class combines results of readers and deliver them. |
CollectorComposite (**kwargs) |
A composite of collectors. |
CollectorDelegate (collector) |
|
EventLoop (**kwargs) |
An event loop |
DatasetIntoEventBuildersSplitter (…[, …]) |
|
EventDatasetReader (**kwargs) |
This class manages objects involved in reading events in data sets. |
EventLoopRunner () |
This class runs instances of EventLoop and keeps the results. |
MPEventLoopRunner (communicationChannel) |
This class (concurrently) runs instances of EventLoop. |
ReaderComposite ([readers]) |
A composite of event readers” |
NullCollector |
|
ReaderComposite ([readers]) |
A composite of event readers” |
splitfuncs.create_files_start_length_list (files) |
determines how to split input data into chunks |
roottree¶
Branch (name, array, countarray) |
This class encloses an array.array object, which is typically used to set the address of a branch of a ROOT TTree. |
Events (tree[, maxEvents, start]) |
An iterative object for events. |
selection¶
build_selection (**kargs) |
|
modules.All ([name, selections]) |
select events that meet all conditions |
modules.Any ([name, selections]) |
select events that meet any of the conditions |
modules.Not (selection[, name]) |
select events that do NOT pass the selection |
modules.AllwCount ([name, selections, collector]) |
select events that meet all conditions |
modules.AnywCount ([name, selections, collector]) |
select events that meet any of the conditions |
modules.NotwCount (selection[, name, collector]) |
select events that do NOT pass the selection |
modules.Count.Count ([selections]) |
|
modules.LambdaStr.LambdaStr (lambda_str[, name]) |
select events to which a lambda returns True. |
summary¶
BackrefMultipleArrayReader (arrays, idxs_conf) |
|||
Count ([val, weight, contents]) |
|
||
KeyValueComposer ([keyAttrNames, binnings, …]) |
This class composes keys and values for the event | ||
NextKeyComposer (binnings) |
|||
Reader (keyValComposer, summarizer[, …]) |
|||
Scan ([val, weight, contents]) |
|||
Sum ([val, weight, contents]) |
|||
Summarizer (Summary) |
|||
WeightCalculatorOne |
concurrently¶
CommunicationChannel (dropbox) |
A communication channel with workers in other processes. |
CommunicationChannel0 (**kwargs) |
A communication channel for the single process mode |
HTCondorJobSubmitter (**kwargs) |
A dispatcher that dispatches jobs to HTCondor |
MultiprocessingDropbox (**kwargs) |
A drop box for task packages. |
SubprocessRunner ([pipe]) |
An example dispatcher which runs tasks in subprocesses |
TaskPackage |
|
TaskPackageDropbox (workingArea, dispatcher) |
A drop box for task packages. |
Worker |
|
WorkingArea (**kwargs) |
A working area for tasks |