Module partition_source_data

Module partition_source_data 

Source
Expand description

Describes the event blocks backing a partition

Structs§

PartitionSourceBlock
Represents a single block of source data for a partition.
SourceDataBlocks
A PartitionBlocksSource implementation that fetches blocks from a DataFusion DataFrame.
SourceDataBlocksInMemory
A PartitionBlocksSource implementation that stores blocks in memory.

Traits§

PartitionBlocksSource
A trait for providing blocks of source data for partitions.

Functions§

fetch_partition_source_data
Fetches partition source data from the data lake.
hash_to_object_count
Converts a hash (expected to be an i64 as bytes) to an object count.