MCPcopy Create free account

hub / github.com/deshaw/versioned-hdf5 / functions

Functions917 in github.com/deshaw/versioned-hdf5

↓ 3 callersMethodlen
Length of the first axis.
versioned_hdf5/wrappers.py:966
↓ 3 callersFunctionrequire_npystrings
Skip if StringDType is not supported. To be called by setup() for dtype='T'.
benchmarks/common.py:15
↓ 3 callersFunctionrewrite_dataset
Copy every chunk of `data` into the `raw_data` of `f`, deduplicating it against the chunks already there, and return the `{chunk_index: raw_data s
versioned_hdf5/backend.py:617
↓ 3 callersMethodsetup
(self, case)
benchmarks/replay.py:55
↓ 3 callersFunctionswap
Swap every dataset in old with the corresponding one in new Datasets in old that aren't in new are ignored.
versioned_hdf5/replay.py:764
↓ 3 callersMethodvisititems
(self, func)
versioned_hdf5/wrappers.py:461
↓ 3 callersMethodwhole_chunks_idxidx
(self)
versioned_hdf5/subchunk_map.py:358
↓ 2 callersMethod_add_to_data
(self, name, obj)
versioned_hdf5/wrappers.py:170
↓ 2 callersMethod_astype_impl
Return self._buffer as a new dtype. Return a view if possible.
versioned_hdf5/wrappers.py:576
↓ 2 callersFunction_chunk_blocks
Tile `shape` into blocks of whole chunks, each at most `max_bytes` in size. Blocks are grown one axis at a time, starting from the last one, so t
versioned_hdf5/backend.py:582
↓ 2 callersFunction_data_v4_to_sc_hash_table
Load the SHA256 digests from the on-disk hash table and convert it to the layout compatible with `StagedChangesArray.hash_tables`, which is indexe
versioned_hdf5/backend.py:387
↓ 2 callersMethod_find_all_data_groups
(self)
versioned_hdf5/api.py:368
↓ 2 callersMethod_find_object_dtype_data_groups
Find all data groups with dtype='O'.
versioned_hdf5/api.py:405
↓ 2 callersMethod_load_edge_chunks_along_axis
Load the edge chunks along an axis from the base slabs into a new slab
versioned_hdf5/staged_changes.py:2134
↓ 2 callersFunction_normalize_path
(path: str)
versioned_hdf5/replay.py:744
↓ 2 callersMethod_rebuild_hashtables
Rebuild the hashtables in data_groups.
versioned_hdf5/api.py:376
↓ 2 callersFunction_recreate_virtual_dataset
Recreate every virtual dataset `name` in the versions `versions` according to the new raw_data chunks in `raw_data_chunks_map`. Returns
versioned_hdf5/replay.py:324
↓ 2 callersMethod_recursion_to_root
Call `cb` on self and recursively on all parents up to the root. The callable must accept the node being currently visited and the name of the
versioned_hdf5/wrappers.py:431
↓ 2 callersFunction_staged_changes_to_data_dict
Transitional hack that converts a StagedChangsArray to a legacy data_dict. This was introduced when replacing the legacy system, which was wholly
versioned_hdf5/wrappers.py:1143
↓ 2 callersMethod_untrim_staged_slabs
Deep-copy trimmed staged slabs into new slabs padded to full chunk_size. Trimmed staged slabs are only ever created by from_array(as_base_sla
versioned_hdf5/staged_changes.py:806
↓ 2 callersFunctionare_compatible_dtypes
Return True if the dtypes are compatible. Compatible dtypes are those that are either equal or both variable length strings.
versioned_hdf5/backend.py:55
↓ 2 callersFunctionassert_object_array_equal
Assert that actual is an object array of either bytes or str. The exact contents (bytes or str) are allowed to diverge between h5py and versio
tests/test_npystrings.py:26
↓ 2 callersFunctionbasic_idx_st
Hypothesis draw of slice and integer indexes, with potential ellipsis
tests/test_subchunk_map.py:46
↓ 2 callersFunctionbuffer
Return a writeable buffer of random data, of shape SHAPE. This mimics the _buffer attribute of an InMemoryArrayDataset, the input to StagedCh
benchmarks/staged_changes.py:142
↓ 2 callersMethodget_diff
Compute the difference between two versions of a dataset. Parameters ---------- name : str Name of the dataset
versioned_hdf5/api.py:421
↓ 2 callersFunctionget_nth_previous_version
(f, version_name, n)
versioned_hdf5/versions.py:240
↓ 2 callersMethodget_version_by_name
(self, version)
versioned_hdf5/api.py:200
↓ 2 callersFunctionidx_st
(shape: tuple[int, ...])
tests/test_subchunk_map.py:142
↓ 2 callersMethodinverse
r""" Return a dictionary mapping Slice: array_of_hash. The Slices are all `reduce()`\d.
versioned_hdf5/hashtable.py:176
↓ 2 callersFunctionix_with_slices
Variant of numpy.ix_ with added support for mixing with slices. Given a numpy ndindex where each element could be either a 1D fancy integer a
versioned_hdf5/tools.py:59
↓ 2 callersFunctionmake_array
Return a NumPy array of the given shape, dtype, memory layout, and sample values.
tests/test_slicetools.py:48
↓ 2 callersFunctionmake_committable
Create a StagedChangesArray with staged changes as described by COMMIT_SCENARIOS, ready to be committed
benchmarks/staged_changes.py:237
↓ 2 callersFunctionnormalize_chunks
Normalize the ``chunks`` parameter of create_dataset(), guessing a sensible chunk size when it is not explicitly specified.
versioned_hdf5/backend.py:183
↓ 2 callersMethodrand_strings
Generate a ndarray of random strings
benchmarks/common.py:61
↓ 2 callersFunctionread_many_slices_params_nd
Assemble the parameters for read_many_slices() for a multi-dimensional index for a specific transfer type between two arrays. Parameters
versioned_hdf5/subchunk_map.py:863
↓ 2 callersFunctionscalar_indices_st
(size: int)
tests/test_subchunk_map.py:41
↓ 2 callersFunctionset_current_version
(f, version_name)
versioned_hdf5/versions.py:297
↓ 2 callersMethodsetup
(self, kind, chunks)
benchmarks/wrappers.py:147
↓ 2 callersFunctionshape_chunks_st
( draw, max_ndim: int = 4, min_size: int = 1, max_size: int = 20 )
tests/test_subchunk_map.py:131
↓ 2 callersFunctionsmallest_step_after
Find the smallest integer y >= x where y = a + k*m for whole k's Assumes 0 <= a <= x and m >= 1. a x y | <-- m --> |
versioned_hdf5/cytools.py:64
↓ 2 callersFunctionstop2count
Given a start:stop:step slice or range, return the number of elements yielded. This is functionally identical to:: len(range(start, stop
versioned_hdf5/cytools.py:17
↓ 2 callersMethodtransfer
Call read_many_slices() to transfer slices of data from src to dst
versioned_hdf5/staged_changes.py:1287
↓ 1 callersMethod__init__
Create a new InMemoryGroup object by binding to a low-level GroupID. Parameters ---------- bind : h5g.GroupID Low
versioned_hdf5/wrappers.py:72
↓ 1 callersMethod__iter__
Iterate over the first axis. BEWARE: Modifications to the yielded data are *NOT* written to file.
versioned_hdf5/wrappers.py:981
↓ 1 callersFunction_all_chunks
()
tests/test_hash_legacy_compat.py:42
↓ 1 callersFunction_all_extant_are_empty
Check if the given versions of a dataset are empty. Doesn't assume the dataset exists in any version. Parameters ---------- f : Vers
versioned_hdf5/replay.py:448
↓ 1 callersFunction_baseline_hash_row
The SHA256 of a chunk, as 4x uint64 (one hash_tables row). Does not cover VLEN dtypes (object strings or NpyStrings).
tests/test_staged_changes.py:1753
↓ 1 callersMethod_chunk_sizes_in_chunk_indices
Return the number of points taken from each chunk within self.chunk_indices. All but the last chunk always contain self.chunk_size points.
versioned_hdf5/subchunk_map.py:595
↓ 1 callersFunction_commit_random
Return a StagedChangesArray covering shape, with all of its chunks on a single base slab complete with hash table, built by staging random data an
benchmarks/staged_changes.py:124
↓ 1 callersMethod_create_hashtable
(self)
versioned_hdf5/hashtable.py:192
↓ 1 callersFunction_delete_dataset
Delete the given dataset from the versions.
versioned_hdf5/replay.py:476
↓ 1 callersFunction_delete_tmp_raw_data
Delete _tmp_raw_data if it exists in the file. Parameters ---------- f : File File in which _tmp_raw_data is to be removed na
versioned_hdf5/replay.py:281
↓ 1 callersMethod_diff_data
Compute the difference between two versions of a dataset. Parameters ---------- v1 : str Version of a dataset
versioned_hdf5/api.py:498
↓ 1 callersMethod_enlarge_along_axis
Enlarge along a single axis
versioned_hdf5/staged_changes.py:1918
↓ 1 callersFunction_exists_in_version
Check if a dataset exists in a given version. Parameters ---------- f : VersionedHDF5File File where the dataset may reside n
versioned_hdf5/replay.py:428
↓ 1 callersFunction_fancy_idx_to_slices
Break down a one-dimensional integer array into a (greedy) minimal list of slices. Populate input of read_many_slices(). Parameters -----
versioned_hdf5/subchunk_map.py:627
↓ 1 callersMethod_find_data_groups
Find all groups containing datasets that are descendents of the given node. Parameters ---------- node : h5py.Group
versioned_hdf5/api.py:382
↓ 1 callersMethod_get_chunks
Get the Dict which maps virtual dataset sources to raw data slices. Parameters ---------- name : str Name of the
versioned_hdf5/api.py:470
↓ 1 callersFunction_get_np_fillvalue
Get the fillvalue for an empty dataset. See InMemoryDataset.fillvalue. In h5py3 variable length strings use None for the h5py fillvalue, but
versioned_hdf5/replay.py:174
↓ 1 callersFunction_get_parent
(versions, version_name)
versioned_hdf5/replay.py:600
↓ 1 callersMethod_get_rand_fn
(cls, dtype)
analysis/generate_data_base.py:101
↓ 1 callersFunction_index_to_mapper
Convert a one-dimensional index, preprocessed by ndindex, to a mapper
versioned_hdf5/subchunk_map.py:792
↓ 1 callersMethod_invalidate_all
Forget everything that was read from the file, both in the live instances and in the instances registry, so that it is read again on next acce
versioned_hdf5/wrappers.py:102
↓ 1 callersFunction_is_empty
Return True if the dataset at the given version is empty, False otherwise. Assumes the dataset exists in the given version. Parameters -
versioned_hdf5/replay.py:406
↓ 1 callersMethod_load_hashtable
(self, hash_table_dataset)
versioned_hdf5/hashtable.py:209
↓ 1 callersMethod_modify_dss_dense
( cls, key0_ds, key1_ds, val_ds, num_rows_per_append_0, pct_ch
analysis/generate_data_base.py:370
↓ 1 callersMethod_modify_dss_dense_old
( cls, key0_ds, key1_ds, val_ds, num_rows_per_append_0, pct_ch
analysis/generate_data.py:351
↓ 1 callersMethod_modify_dss_sparse
( cls, key0_ds, key1_ds, val_ds, num_rows_per_append, pct_chan
analysis/generate_data_base.py:110
↓ 1 callersFunction_new_vds_layout
Recreate a VirtualLayout for d, replacing name1 with name2 in the source dset name
versioned_hdf5/replay.py:785
↓ 1 callersFunction_raw_data_as_base_slab
Return `raw_data`, to be used as a base slab of a StagedChangesArray of the given dtype. Variable-width strings are always stored as object d
versioned_hdf5/backend.py:426
↓ 1 callersMethod_read_many_slices_param
Return the parameters to read_many_slices() for a single chunk. Returns tuple of: - chunk_sub_start - value_sub_start
versioned_hdf5/subchunk_map.py:272
↓ 1 callersMethod_relocate_trimmed_staged_chunks_along_axis0
Relocate the edge chunks that lie on staged slabs trimmed along axis 0. Trimmed staged slabs are only ever created by from_array(as_base_slab
versioned_hdf5/staged_changes.py:2002
↓ 1 callersFunction_replace_attrs_prefix
Replace the prefix name1 with name2 in every string attribute of dataset that holds an absolute path, e.g. the 'raw_data' attribute of a version d
versioned_hdf5/replay.py:755
↓ 1 callersMethod_repr_idx
Return a string representation of the i-th row
versioned_hdf5/staged_changes.py:1304
↓ 1 callersFunction_sc_hash_table_to_data_v4
Inverse conversion of `_data_v4_to_sc_hash_table`
versioned_hdf5/backend.py:412
↓ 1 callersMethod_set_chunks
(self, dataset_name: str, value: tuple[int, ...] | None)
versioned_hdf5/wrappers.py:449
↓ 1 callersMethod_shrink_along_axis
Shrink along a single axis. Load partial edge chunks into memory to avoid ending up with partially overlapping chunks on disk, e.g. [
versioned_hdf5/staged_changes.py:1890
↓ 1 callersFunction_transformations
Yield a handful of strided/broadcast views of ``a``.
tests/test_hash.py:516
↓ 1 callersMethod_visit
(self, prefix, func)
versioned_hdf5/wrappers.py:464
↓ 1 callersFunction_walk
Traverse the object tree, returning all `raw_data` datasets. We use this instead of version_data.visit(delete_dataset) because visit() has tr
versioned_hdf5/replay.py:506
↓ 1 callersMethod_write_transactions_dense
( cls, name, chunk_size, compression, versions, print_transact
analysis/generate_data_base.py:347
↓ 1 callersMethod_write_transactions_dense_old
( cls, name, num_rows_initial_0, num_rows_initial_1, num_transactions,
analysis/generate_data.py:284
↓ 1 callersFunctionaction_st
(shape: tuple[int, ...], max_size: int = 20)
tests/test_staged_changes.py:25
↓ 1 callersFunctionarray_indices_st
(size: int)
tests/test_subchunk_map.py:34
↓ 1 callersMethodas_kwargs
Convert to kwargs for create_dataset.
versioned_hdf5/backend.py:107
↓ 1 callersFunctionassert_tuple_of_ints
(x: object)
tests/test_staged_changes.py:1162
↓ 1 callersFunctionasv_run
Benchmark whatever is installed in the current environment and store the results under commit_hash
ci/asv_compare.py:82
↓ 1 callersFunctionbase_slab
Return (slab, hash_table, slab_indices, slab_offsets) of a single base slab that covers the whole of SHAPE with unique chunks, optionally preceded
benchmarks/staged_changes.py:153
↓ 1 callersFunctionbenchmark
(small, large)
tests/test_npystrings.py:247
↓ 1 callersFunctionbenchmark
(shape)
tests/test_staged_changes.py:807
↓ 1 callersFunctionbound_slices_st
Hypothesis draw of a slice object to slice an array of <arr_size> points along an axis, returning a view of <view_size> points:: arr = np
tests/test_slicetools.py:231
↓ 1 callersFunctionbuild_hdf5
(version, hdf5_file, install_path, cmake_generator, use_prefix, dl_zip)
ci/get_hdf5_win.py:103
↓ 1 callersFunctioncallback
(dataset, version_name)
versioned_hdf5/replay.py:661
↓ 1 callersFunctioncheck
(arr)
tests/test_staged_changes.py:2168
↓ 1 callersFunctioncheck_compatible_dtypes
Raise if the dtypes are not compatible. Compatible dtypes are those that are either equal or both variable length strings.
versioned_hdf5/backend.py:62
↓ 1 callersMethodchunks_indexer
(self)
versioned_hdf5/subchunk_map.py:469
↓ 1 callersMethodcount
(self, key: ChunkHash)
versioned_hdf5/_commit_hash.py:27
↓ 1 callersMethodcount
(self, key: ChunkLoc)
versioned_hdf5/_commit_hash.py:32
↓ 1 callersFunctioncreate_dataset
(v, name, size, sparse=False)
tests/test_npystrings.py:235
↓ 1 callersFunctiondownload_hdf5
(version, outfile)
ci/get_hdf5_win.py:74
← previousnext →101–200 of 917, ranked by callers