async fn create_parquet_file(
    store: ParquetStorage,
    metadata: &IoxMetadata,
    record_batch: RecordBatch,
) -> (Vec<u8>, usize) {
    let stream = futures::stream::once(async { Ok(record_batch) });
    let (meta, file_size) = store
        .upload(stream, metadata)
        .await
        .expect("persisting parquet file should succeed");
    (meta.thrift_bytes().to_vec(), file_size)
}
/// Create parquet file and return thrift-encoded and zstd-compressed parquet metadata as well as the file size.
Create parquet file and return thrift-encoded and zstd-compressed parquet metadata as well as the file size.
Create parquet file and return thrift - encoded and zstd - compressed parquet metadata as well as the file size .
async fn create_parquet_file(
    store: ParquetStorage,
    metadata: &IoxMetadata,
    record_batch: RecordBatch,
) -> (Vec<u8>, usize) {
    let stream = futures::stream::once(async { Ok(record_batch) });
    let (meta, file_size) = store
        .upload(stream, metadata)
        .await
        .expect("persisting parquet file should succeed");
    (meta.thrift_bytes().to_vec(), file_size)
}
async fn create_parquet_file ( store : ParquetStorage , metadata : & IoxMetadata , record_batch : RecordBatch , ) -> ( Vec < u8 > , usize ) { let stream = futures :: stream :: once ( async { Ok ( record_batch ) } ) ; let ( meta , file_size ) = store . upload ( stream , metadata ) . await . expect ( " " ) ; ( meta . thrift_bytes ( ) . to_vec ( ) , file_size ) }
Create parquet file and return thrift-encoded and zstd-compressed parquet metadata as well as the file size.
Create parquet file and return thrift - encoded and zstd - compressed parquet metadata as well as the file size .
store
ParquetStorage
metadata
&IoxMetadata
record_batch
RecordBatch
store
ParquetStorage
metadata
&IoxMetadata
record_batch
RecordBatch