tanat.store package

Subpackages

• tanat.store.base package
  • Submodules
  • tanat.store.base.static module
    • StaticStoreMixin
      • StaticStoreMixin.FILE_STATIC_FEATURES
      • StaticStoreMixin.add_static()
      • StaticStoreMixin.drop_static()
      • StaticStoreMixin.get_static_data()
      • StaticStoreMixin.static()
      • StaticStoreMixin.static_features()
  • tanat.store.base.store module
    • BaseStore
      • BaseStore.__init__()
      • BaseStore.clear_virtual_context()
      • BaseStore.core
      • BaseStore.fork_virtual_context()
      • BaseStore.main_id_col
      • BaseStore.main_index
      • BaseStore.root_path
      • BaseStore.write_metadata_json()
  • tanat.store.base.utils module
    • atomic_write()
    • check_no_reserved_names()
    • drop_columns_from_file()
    • get_column_names()
    • hconcat_datasets()
    • hconcat_physical_virtual()
    • infer_features()
    • normalise_to_lazyframe()
    • scan_if_exists()
    • validate_required_columns()
  • tanat.store.base.virtual module
    • VirtualStore
      • VirtualStore.__init__()
      • VirtualStore.add_entity_features()
      • VirtualStore.add_static_features()
      • VirtualStore.clear()
      • VirtualStore.clear_context()
      • VirtualStore.create()
      • VirtualStore.drop_features()
      • VirtualStore.exists()
      • VirtualStore.features()
      • VirtualStore.fork_context()
      • VirtualStore.new_context()
      • VirtualStore.time_index()
      • VirtualStore.write_time_index()
  • Module contents
• tanat.store.sequence package
  • Subpackages
    • tanat.store.sequence.builder package
      • Subpackages
      • Submodules
      • tanat.store.sequence.builder.base module
      • Module contents
  • Submodules
  • tanat.store.sequence.schema module
    • StoreSchema
      • StoreSchema.Files
      • StoreSchema.LENGTH
      • StoreSchema.OFFSET
      • StoreSchema.SEQ_ID
      • StoreSchema.STORE_INDEX
      • StoreSchema.T_END
      • StoreSchema.T_EVENT
      • StoreSchema.T_START
      • StoreSchema.internal_columns()
      • StoreSchema.time_index_columns()
  • tanat.store.sequence.store module
    • SequenceStore
      • SequenceStore.__init__()
      • SequenceStore.add_entity_features()
      • SequenceStore.copy_to()
      • SequenceStore.drop_features()
      • SequenceStore.entity()
      • SequenceStore.entity_features()
      • SequenceStore.get_id_lf()
      • SequenceStore.get_id_time_index()
      • SequenceStore.get_sequence_type()
      • SequenceStore.get_temporal_data()
      • SequenceStore.get_time_index()
      • SequenceStore.n_entities
      • SequenceStore.seq_id_col
      • SequenceStore.seq_id_dtype
      • SequenceStore.sequence_index
      • SequenceStore.structural_columns()
      • SequenceStore.time_index()
      • SequenceStore.write_core_json()
      • SequenceStore.write_virtual_time_index()
  • Module contents
• tanat.store.source package
  • Subpackages
    • tanat.store.source.type package
      • Submodules
      • tanat.store.source.type.dataframe module
      • tanat.store.source.type.file module
      • tanat.store.source.type.sql module
      • Module contents
  • Submodules
  • tanat.store.source.base module
    • AbstractSource
      • AbstractSource.read()
      • AbstractSource.schema()
  • Module contents
    • AbstractSource
      • AbstractSource.read()
      • AbstractSource.schema()
• tanat.store.trajectory package
  • Submodules
  • tanat.store.trajectory.builder module
    • TrajectoryStoreBuilder
      • TrajectoryStoreBuilder.__init__()
      • TrajectoryStoreBuilder.add()
      • TrajectoryStoreBuilder.add_csv()
      • TrajectoryStoreBuilder.add_dataframe()
      • TrajectoryStoreBuilder.add_parquet()
      • TrajectoryStoreBuilder.add_sql()
      • TrajectoryStoreBuilder.build()
      • TrajectoryStoreBuilder.build_from_frames()
  • tanat.store.trajectory.schema module
    • TrajectorySchema
      • TrajectorySchema.Files
      • TrajectorySchema.TRAJ_ID
  • tanat.store.trajectory.store module
    • TrajectoryStore
      • TrajectoryStore.__init__()
      • TrajectoryStore.copy_to()
      • TrajectoryStore.get_frames_for_save()
      • TrajectoryStore.get_id_lf()
      • TrajectoryStore.sequence_stores
      • TrajectoryStore.store_aliases
      • TrajectoryStore.store_links
      • TrajectoryStore.traj_id_col
      • TrajectoryStore.traj_id_dtype
      • TrajectoryStore.trajectory_index
      • TrajectoryStore.write_core_json()
  • Module contents

Submodules

tanat.store.factory module

Store factory class.

class tanat.store.factory.StoreFactory

Bases: object

Factory for creating stores based on manifest definitions.

CORE_FILENAME = 'core.json'

classmethod from_path(store_path: Path)

Load a store instance based on the core file.

Parameters:

store_path – Path to the store directory containing the core file.

Returns:

An instance of the specified store.

static get_core_path(store_path: Path) → Path

Returns the full path to the core file for a given store.

static load_core(core_path: Path) → dict

Loads the core JSON file from the given path.

Module contents

Package stub.