Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
def wait():
for excinfo in excinfos:
_delayedraise(excinfo)
clipped = interpretation.clip(destination,
basket_itemoffset[0],
basket_itemoffset[-1],
basket_entryoffset[0],
basket_entryoffset[-1])
out = interpretation.finalize(clipped, self)
if cache is not None:
cache[cachekey] = out
if flatten and isinstance(interpretation, asjagged):
return out.content
else:
return out
----------
todtype : ``None`` or ``numpy.dtype``
if not ``None``, change the destination type of inner arrays.
todims : ``None`` or tuple of ints
if not ``None``, change the destination dimensions of inner arrays.
Returns
-------
:py:class:`asjagged `
new interpretation.
"""
_method(uproot.interp.jagged.asjagged.empty).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.compatible).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.numitems).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.source_numitems).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.fromroot).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.destination).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.fill).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.clip).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.finalize).__doc__ = interp_fragments["see1"]
# TODO: add asdtype asarray asdouble32 asstlbitset asjagged astable asobj asgenobj asstring STLVector STLString
################################################################ uproot.source.cursor.Cursor
uproot.source.cursor.Cursor.__doc__ = \
u"""Maintain a position in a :py:class:`Source ` that updates as data are read.
**Attributes, properties, and methods:**
Parameters
----------
todtype : ``None`` or ``numpy.dtype``
if not ``None``, change the destination type of inner arrays.
todims : ``None`` or tuple of ints
if not ``None``, change the destination dimensions of inner arrays.
Returns
-------
:py:class:`asjagged `
new interpretation.
"""
_method(uproot.interp.jagged.asjagged.empty).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.compatible).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.numitems).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.source_numitems).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.fromroot).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.destination).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.fill).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.clip).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.finalize).__doc__ = interp_fragments["see1"]
# TODO: add asdtype asarray asdouble32 asstlbitset asjagged astable asobj asgenobj asstring STLVector STLString
################################################################ uproot.source.cursor.Cursor
uproot.source.cursor.Cursor.__doc__ = \
u"""Maintain a position in a :py:class:`Source ` that updates as data are read.
context = copy.copy(branch._context)
context.speedbump = False
else:
context = branch._context
if isjagged:
return asgenobj(SimpleArray(streamerClass), context, 0)
else:
return asgenobj(streamerClass, context, 0)
else:
if isjagged:
if streamerClass._methods is None:
return asjagged(astable(asdtype(recarray)))
else:
return asjagged(asobj(astable(asdtype(recarray)), streamerClass._methods))
else:
if streamerClass._methods is None:
return asdtype(recarray)
else:
return asobj(astable(asdtype(recarray)), streamerClass._methods)
if not ``None``, change the destination dimensions of inner arrays.
Returns
-------
:py:class:`asjagged `
new interpretation.
"""
_method(uproot.interp.jagged.asjagged.empty).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.compatible).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.numitems).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.source_numitems).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.fromroot).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.destination).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.fill).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.clip).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.finalize).__doc__ = interp_fragments["see1"]
# TODO: add asdtype asarray asdouble32 asstlbitset asjagged astable asobj asgenobj asstring STLVector STLString
################################################################ uproot.source.cursor.Cursor
uproot.source.cursor.Cursor.__doc__ = \
u"""Maintain a position in a :py:class:`Source ` that updates as data are read.
**Attributes, properties, and methods:**
- **index** (*int*) the position.
- **origin** (*int*) "beginning of buffer" position, used in the **refs** key in :py:func:`uproot.rootio._readobjany `.
- **refs** (``None`` or ``dict``-like) manages cross-references in :py:func:`uproot.rootio._readobjany `.
- :py:meth:`copied ` return a copy of this :py:class:`Cursor ` with modifications.
- :py:meth:`skipped ` return a copy of this :py:class:`Cursor ` with the **index** moved forward.
if getattr(streamerClass, "_hasreadobjany", False):
return None
if streamerClass.__name__ == "string":
return asgenobj(STLVector(STLString(awkward)), branch._context, 6)
if len(branch._fBranches) != 0:
return None
try:
recarray = streamerClass._recarray_dtype(cntvers=cntvers, tobject=tobject)
except (AttributeError, ValueError):
return asgenobj(STLVector(streamerClass), branch._context, 6)
else:
if streamerClass._methods is None:
return asjagged(astable(asdtype(recarray)), skipbytes=10)
else:
return asjagged(asobj(astable(asdtype(recarray)), streamerClass._methods), skipbytes=10)
if hasattr(branch._streamer, "_fTypeName"):
m = re.match(b"bitset<([1-9][0-9]*)>", branch._streamer._fTypeName)
if m is not None:
return asjagged(asstlbitset(int(m.group(1))), skipbytes=6)
if getattr(branch._streamer, "_fTypeName", None) == b"vector" or getattr(branch._streamer, "_fTypeName", None) == b"vector":
return asjagged(asdtype(awkward.numpy.bool_), skipbytes=10)
elif getattr(branch._streamer, "_fTypeName", None) == b"vector" or getattr(branch._streamer, "_fTypeName", None) == b"vector":
return asjagged(asdtype("i1"), skipbytes=10)
elif getattr(branch._streamer, "_fTypeName", None) == b"vector" or getattr(branch._streamer, "_fTypeName", None) == b"vector" or getattr(branch._streamer, "_fTypeName", None) == b"vector":
return asjagged(asdtype("u1"), skipbytes=10)
elif getattr(branch._streamer, "_fTypeName", None) == b"vector" or getattr(branch._streamer, "_fTypeName", None) == b"vector":
return asjagged(asdtype("i2"), skipbytes=10)
from uproot.interp.auto import interpret
from uproot.interp.numerical import asdtype
from uproot.interp.numerical import asarray
from uproot.interp.numerical import asdouble32
from uproot.interp.numerical import asstlbitset
from uproot.interp.jagged import asjagged
from uproot.interp.objects import astable
from uproot.interp.objects import asobj
from uproot.interp.objects import asgenobj
from uproot.interp.objects import asstring
from uproot.interp.objects import SimpleArray
from uproot.interp.objects import STLVector
from uproot.interp.objects import STLMap
from uproot.interp.objects import STLString
from uproot.interp.objects import Pointer
asdebug = asjagged(asdtype("u1"))
from uproot import pandas
# put help strings on everything (they're long, too disruptive to intersperse
# in the code, and are built programmatically to avoid duplication; Python's
# inline docstring method doesn't accept non-literals)
import uproot._help
# convenient access to the version number
from uproot.version import __version__
# don't expose uproot.uproot; it's ugly
del uproot
__all__ = ["open", "xrootd", "http", "iterate", "numentries", "lazyarray", "lazyarrays", "daskarray", "daskframe", "create", "recreate", "update", "ZLIB", "LZMA", "LZ4", "ZSTD", "newtree", "newbranch", "MemmapSource", "FileSource", "XRootDSource", "HTTPSource", "ArrayCache", "ThreadSafeArrayCache", "interpret", "asdtype", "asarray", "asdouble32", "asstlbitset", "asjagged", "astable", "asobj", "asgenobj", "asstring", "asdebug", "SimpleArray", "STLVector", "STLMap", "STLString", "Pointer", "pandas", "__version__"]
todims : ``None`` or tuple of ints
if not ``None``, change the destination dimensions of inner arrays.
Returns
-------
:py:class:`asjagged `
new interpretation.
"""
_method(uproot.interp.jagged.asjagged.empty).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.compatible).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.numitems).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.source_numitems).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.fromroot).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.destination).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.fill).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.clip).__doc__ = interp_fragments["see1"]
_method(uproot.interp.jagged.asjagged.finalize).__doc__ = interp_fragments["see1"]
# TODO: add asdtype asarray asdouble32 asstlbitset asjagged astable asobj asgenobj asstring STLVector STLString
################################################################ uproot.source.cursor.Cursor
uproot.source.cursor.Cursor.__doc__ = \
u"""Maintain a position in a :py:class:`Source ` that updates as data are read.
**Attributes, properties, and methods:**
- **index** (*int*) the position.
- **origin** (*int*) "beginning of buffer" position, used in the **refs** key in :py:func:`uproot.rootio._readobjany `.
- **refs** (``None`` or ``dict``-like) manages cross-references in :py:func:`uproot.rootio._readobjany `.
- :py:meth:`copied ` return a copy of this :py:class:`Cursor ` with modifications.
Notes
-----
{see2}
This class has *todtype* and *todims* parameters like :py:class:`asdtype `, but they are derived from the *toarray* attribute.
""".format(**dict(list(interp_fragments.items()) + list(interp_numerical_fragments.items())))
_method(uproot.interp.numerical.asarray.destination).__doc__ = interp_fragments["see1"]
_method(uproot.interp.numerical.asarray.fill).__doc__ = interp_fragments["see1"]
_method(uproot.interp.numerical.asarray.clip).__doc__ = interp_fragments["see1"]
_method(uproot.interp.numerical.asarray.finalize).__doc__ = interp_fragments["see1"]
################################################################ uproot.interp.jagged.asjagged
uproot.interp.jagged.asjagged.__doc__ = \
u"""Interpret branch as a jagged array (array of non-uniformly sized arrays).
This interpretation directs branch-reading to fill contiguous arrays and present them to the user in a ``JaggedArray`` interface. Such an object behaves as though it were an array of non-uniformly sized arrays, but it is more memory and cache-line efficient because the underlying data are contiguous.
In this interpretation, "items" (for ``numitems``, ``itemstart``, ``itemstop``, etc.) are the items of the inner array (however that is defined), and "entries" are elements of the outer array. The outer array is always one-dimensional.
Parameters
----------
asdtype : :py:class:`asdtype `
interpretation for the inner arrays.
Notes
-----
{see2}
""".format(**interp_fragments)
def wrapped_interpret(branch, *args, **kwargs):
from uproot.interp.auto import interpret
result = interpret(branch, *args, **kwargs)
if result:
return result
if isinstance(branch, WrappedTree.FakeBranch):
if isinstance(branch._values, awkward.JaggedArray):
return asjagged(asdtype(branch._values.content.dtype.fields))
else:
return branch._values
return None