pub(crate) fn build(
        &self,
        parquet_max_sequence_number: Option<SequenceNumber>,
        tombstone_max_sequence_number: Option<SequenceNumber>,
    ) -> IngesterPartition {
        let data = self.lp.iter().map(|lp| lp_to_record_batch(lp)).collect();

        IngesterPartition::try_new(
            Arc::clone(&self.ingester_name),
            ChunkId::new_test(self.ingester_chunk_id),
            Arc::from(self.ns.namespace.name.as_str()),
            Arc::from(self.table.table.name.as_str()),
            self.partition.partition.id,
            self.sequencer.sequencer.id,
            Arc::clone(&self.schema),
            parquet_max_sequence_number,
            tombstone_max_sequence_number,
            Arc::clone(&self.partition_sort_key),
            data,
        )
        .unwrap()
    }
/// Create an ingester partition with the specified field values
Create an ingester partition with the specified field values
Create an ingester partition with the specified field values
pub(crate) fn build(
        &self,
        parquet_max_sequence_number: Option<SequenceNumber>,
        tombstone_max_sequence_number: Option<SequenceNumber>,
    ) -> IngesterPartition {
        let data = self.lp.iter().map(|lp| lp_to_record_batch(lp)).collect();
        IngesterPartition::try_new(
            Arc::clone(&self.ingester_name),
            ChunkId::new_test(self.ingester_chunk_id),
            Arc::from(self.ns.namespace.name.as_str()),
            Arc::from(self.table.table.name.as_str()),
            self.partition.partition.id,
            self.sequencer.sequencer.id,
            Arc::clone(&self.schema),
            parquet_max_sequence_number,
            tombstone_max_sequence_number,
            Arc::clone(&self.partition_sort_key),
            data,
        )
        .unwrap()
    }
pub ( crate ) fn build ( & self , parquet_max_sequence_number : Option < SequenceNumber > , tombstone_max_sequence_number : Option < SequenceNumber > , ) -> IngesterPartition { let data = self . lp . iter ( ) . map ( | lp | lp_to_record_batch ( lp ) ) . collect ( ) ; IngesterPartition :: try_new ( Arc :: clone ( & self . ingester_name ) , ChunkId :: new_test ( self . ingester_chunk_id ) , Arc :: from ( self . ns . namespace . name . as_str ( ) ) , Arc :: from ( self . table . table . name . as_str ( ) ) , self . partition . partition . id , self . sequencer . sequencer . id , Arc :: clone ( & self . schema ) , parquet_max_sequence_number , tombstone_max_sequence_number , Arc :: clone ( & self . partition_sort_key ) , data , ) . unwrap ( ) }
Create an ingester partition with the specified field values
Create an ingester partition with the specified field values
&self
parquet_max_sequence_number
Option<SequenceNumber>
tombstone_max_sequence_number
Option<SequenceNumber>
&self
parquet_max_sequence_number
Option<SequenceNumber>
tombstone_max_sequence_number
Option<SequenceNumber>