Struct SourceDataBlocksInMemory 

pub struct SourceDataBlocksInMemory {
    pub blocks: Vec<Arc<PartitionSourceBlock>>,
    pub block_ids_hash: Vec<u8>,
}

A PartitionBlocksSource implementation that stores blocks in memory.

Fields

blocks: Vec<Arc<PartitionSourceBlock>>

block_ids_hash: Vec<u8>

Trait Implementations

impl Debug for SourceDataBlocksInMemory

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartitionBlocksSource for SourceDataBlocksInMemory

fn is_empty(&self) -> bool

Returns true if there are no blocks in the source.

fn get_nb_blocks(&self) -> i64

Returns the number of blocks in the source.

fn get_max_payload_size(&self) -> i64

Returns the maximum payload size of the blocks in the source.

fn get_source_data_hash(&self) -> Vec<u8>

Returns a hash of the source data.

fn get_blocks_stream<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = BoxStream<'static, Result<Arc<PartitionSourceBlock>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns a stream of the source blocks.