pub struct ParquetDataCatalog { /* private fields */ }Implementations§
Source§impl ParquetDataCatalog
impl ParquetDataCatalog
pub fn new(base_path: PathBuf, batch_size: Option<usize>) -> Self
pub fn data_to_record_batches<T>(&self, data: Vec<T>) -> Vec<RecordBatch>where
T: GetTsInit + EncodeToRecordBatch,
pub fn write_to_json<T>(
&self,
data: Vec<T>,
path: Option<PathBuf>,
write_metadata: bool,
) -> PathBufwhere
T: GetTsInit + Serialize + CatalogPathPrefix + EncodeToRecordBatch,
pub fn write_to_parquet<T>(
&self,
data: Vec<T>,
path: Option<PathBuf>,
compression: Option<Compression>,
max_row_group_size: Option<usize>,
) -> PathBufwhere
T: GetTsInit + EncodeToRecordBatch + CatalogPathPrefix,
Sourcepub fn query_file<T>(
&mut self,
path: PathBuf,
start: Option<UnixNanos>,
end: Option<UnixNanos>,
where_clause: Option<&str>,
) -> Result<QueryResult>where
T: DecodeDataFromRecordBatch + CatalogPathPrefix,
pub fn query_file<T>(
&mut self,
path: PathBuf,
start: Option<UnixNanos>,
end: Option<UnixNanos>,
where_clause: Option<&str>,
) -> Result<QueryResult>where
T: DecodeDataFromRecordBatch + CatalogPathPrefix,
Query data loaded in the catalog
Sourcepub fn query_directory<T>(
&mut self,
instrument_ids: Vec<String>,
start: Option<UnixNanos>,
end: Option<UnixNanos>,
where_clause: Option<&str>,
) -> Result<QueryResult>where
T: DecodeDataFromRecordBatch + CatalogPathPrefix,
pub fn query_directory<T>(
&mut self,
instrument_ids: Vec<String>,
start: Option<UnixNanos>,
end: Option<UnixNanos>,
where_clause: Option<&str>,
) -> Result<QueryResult>where
T: DecodeDataFromRecordBatch + CatalogPathPrefix,
Query data loaded in the catalog
pub fn write_data_enum(&self, data: Vec<Data>)
Auto Trait Implementations§
impl Freeze for ParquetDataCatalog
impl !RefUnwindSafe for ParquetDataCatalog
impl Send for ParquetDataCatalog
impl Sync for ParquetDataCatalog
impl Unpin for ParquetDataCatalog
impl !UnwindSafe for ParquetDataCatalog
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more