/// Create new adapter.
///
/// This pre-calculates some data structure that we are going to need later.
Create new adapter.
This pre-calculates some data structure that we are going to need later.
Create new adapter . This pre - calculates some data structure that we are going to need later .
fn new(response: IngesterQueryResponse) -> Self {
        let app_metadata = IngesterQueryResponseMetadata {
            unpersisted_partitions: response
                .unpersisted_partitions
                .iter()
                .map(|(id, status)| {
                    (
                        id.get(),
                        PartitionStatus {
                            parquet_max_sequence_number: status
                                .parquet_max_sequence_number
                                .map(|x| x.get()),
                            tombstone_max_sequence_number: status
                                .tombstone_max_sequence_number
                                .map(|x| x.get()),
                        },
                    )
                })
                .collect(),
            batch_partition_ids: response
                .batch_partition_ids
                .iter()
                .map(|id| id.get())
                .collect(),
        };
        Self {
            response,
            app_metadata,
        }
    }
fn new ( response : IngesterQueryResponse ) -> Self { let app_metadata = IngesterQueryResponseMetadata { unpersisted_partitions : response . unpersisted_partitions . iter ( ) . map ( | ( id , status ) | { ( id . get ( ) , PartitionStatus { parquet_max_sequence_number : status . parquet_max_sequence_number . map ( | x | x . get ( ) ) , tombstone_max_sequence_number : status . tombstone_max_sequence_number . map ( | x | x . get ( ) ) , } , ) } ) . collect ( ) , batch_partition_ids : response . batch_partition_ids . iter ( ) . map ( | id | id . get ( ) ) . collect ( ) , } ; Self { response , app_metadata , } }
Create new adapter.
Create new adapter .
response
IngesterQueryResponse