coffea.processor

A framework for analysis scale-out

Functions

run_spark_job(fileset, processor_instance, ...)	A wrapper to submit spark jobs
accumulate(items[, accum])

Classes

ProcessorABC()	ABC for a generalized processor
LazyDataFrame(tree[, entrystart, entrystop, ...])	Simple delayed uproot reader (a la lazyarrays)
Weights(size[, storeIndividual])	Container for event weights and associated systematic shifts
PackedSelection([dtype])	Store boolean mask vectors in a compact manner
IterativeExecutor([status, unit, desc, ...])	Execute in one thread iteratively
FuturesExecutor(status, unit, desc, ...)	Execute using multiple local cores using python futures
DaskExecutor([status, unit, desc, ...])	Execute using dask futures
ParslExecutor([status, unit, desc, ...])	Execute using parsl pyapp wrapper
WorkQueueExecutor(status, unit, desc, ...)	Execute using Work Queue
Runner(executor, pre_executor, chunksize, ...)	A tool to run a processor using uproot for data delivery
AccumulatorABC()	Abstract base class for an accumulator
value_accumulator(default_factory[, initial])	Holds a value of arbitrary type
list_accumulator([iterable])	A list with accumulator semantics
set_accumulator	A set with accumulator semantics
dict_accumulator	A dictionary with accumulator semantics
defaultdict_accumulator	A defaultdict with accumulator semantics
column_accumulator(value)	An appendable numpy ndarray
NanoAODSchema(base_form[, version])	NanoAOD schema builder
TreeMakerSchema(base_form)	TreeMaker schema builder
iterative_executor	alias of IterativeExecutor
futures_executor	alias of FuturesExecutor
dask_executor	alias of DaskExecutor
parsl_executor	alias of ParslExecutor
work_queue_executor	alias of WorkQueueExecutor

Class Inheritance Diagram