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<(), Error>

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 = Pin<Box<dyn Stream<Item = Result<Arc<PartitionSourceBlock>, Error>> + Send>>> + Send + 'async_trait>>

where 'life0: 'async_trait, SourceDataBlocksInMemory: 'async_trait,

Returns a stream of the source blocks.