pub struct VortexOpenOptions { /* private fields */ }
Expand description
Open options for a Vortex file reader.
Implementations§
Source§impl VortexOpenOptions
impl VortexOpenOptions
Sourcepub fn new() -> Self
pub fn new() -> Self
Create a new VortexOpenOptions
with the expected options for the file source.
This should not be used directly, instead public API clients are expected to
access either VortexOpenOptions::new()
or VortexOpenOptions::memory()
Sourcepub fn with_initial_read_size(self, initial_read_size: usize) -> Self
pub fn with_initial_read_size(self, initial_read_size: usize) -> Self
Configure the initial read size for the Vortex file.
Sourcepub fn with_segment_cache(self, segment_cache: Arc<dyn SegmentCache>) -> Self
pub fn with_segment_cache(self, segment_cache: Arc<dyn SegmentCache>) -> Self
Configure a custom SegmentCache
.
Sourcepub fn without_segment_cache(self) -> Self
pub fn without_segment_cache(self) -> Self
Disable segment caching entirely.
Sourcepub fn with_handle(self, handle: Handle) -> Self
pub fn with_handle(self, handle: Handle) -> Self
Configure a Handle
to use for opening the file.
Warning: it is important that the runtime associated with the handle remains alive while the file is being used. If the runtime is dropped, any I/O operations on the file will fail.
We tried to enforce this with Rust lifetimes, but sadly Rust async cannot express scoped futures in a safe way, so we need static lifetimes for now. If you’re interested in the details, see this post.
Sourcepub fn with_array_registry(self, registry: Arc<ArrayRegistry>) -> Self
pub fn with_array_registry(self, registry: Arc<ArrayRegistry>) -> Self
Configure a Vortex array registry.
Sourcepub fn with_layout_registry(self, registry: Arc<LayoutRegistry>) -> Self
pub fn with_layout_registry(self, registry: Arc<LayoutRegistry>) -> Self
Configure a Vortex array registry.
Sourcepub fn with_file_size(self, file_size: u64) -> Self
pub fn with_file_size(self, file_size: u64) -> Self
Configure a known file size.
This helps to prevent an I/O request to discover the size of the file. Of course, all bets are off if you pass an incorrect value.
Sourcepub fn with_dtype(self, dtype: DType) -> Self
pub fn with_dtype(self, dtype: DType) -> Self
Configure a known DType.
If this is provided, then the Vortex file may be opened with fewer I/O requests.
For Vortex files that do not contain a DType
, this is required.
Configure a known file layout.
If this is provided, then the Vortex file can be opened without performing any I/O.
Once open, the Footer
can be accessed via crate::VortexFile::footer
.
Sourcepub fn with_metrics(self, metrics: VortexMetrics) -> Self
pub fn with_metrics(self, metrics: VortexMetrics) -> Self
Configure a custom VortexMetrics
.
Sourcepub async fn open<S: IntoReadSource>(
self,
source: S,
) -> VortexResult<VortexFile>
pub async fn open<S: IntoReadSource>( self, source: S, ) -> VortexResult<VortexFile>
Open a Vortex file using the provided I/O source.
This is the most common way to open a VortexFile
and tends to provide the best
out-of-the-box performance. The underlying I/O system will continue to be optimised for
different file systems and object stores so we encourage users to use this method
whenever possible and file issues if they encounter problems.
Sourcepub fn open_buffer<B: Into<ByteBuffer>>(
self,
buffer: B,
) -> VortexResult<VortexFile>
pub fn open_buffer<B: Into<ByteBuffer>>( self, buffer: B, ) -> VortexResult<VortexFile>
Open a Vortex file from an in-memory buffer.
Sourcepub async fn open_read_at<R: VortexReadAt>(
self,
read: R,
) -> VortexResult<VortexFile>
pub async fn open_read_at<R: VortexReadAt>( self, read: R, ) -> VortexResult<VortexFile>
An API for opening a VortexFile
using any VortexReadAt
implementation.
This is a low-level API and we strongly recommend using VortexOpenOptions::open
.
Source§impl VortexOpenOptions
impl VortexOpenOptions
pub async fn open_object_store( self, object_store: &Arc<dyn ObjectStore>, path: &str, ) -> VortexResult<VortexFile>
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for VortexOpenOptions
impl !RefUnwindSafe for VortexOpenOptions
impl Send for VortexOpenOptions
impl Sync for VortexOpenOptions
impl Unpin for VortexOpenOptions
impl !UnwindSafe for VortexOpenOptions
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
Source§impl<T> FmtForward for T
impl<T> FmtForward for T
Source§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
self
to use its Binary
implementation when Debug
-formatted.Source§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
self
to use its Display
implementation when
Debug
-formatted.Source§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
self
to use its LowerExp
implementation when
Debug
-formatted.Source§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
self
to use its LowerHex
implementation when
Debug
-formatted.Source§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
self
to use its Octal
implementation when Debug
-formatted.Source§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
self
to use its Pointer
implementation when
Debug
-formatted.Source§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
self
to use its UpperExp
implementation when
Debug
-formatted.Source§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
self
to use its UpperHex
implementation when
Debug
-formatted.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>
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>
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 moreSource§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
Source§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
Source§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read moreSource§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read moreSource§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
Source§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
Source§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
self
, then passes self.as_ref()
into the pipe function.Source§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
self
, then passes self.as_mut()
into the pipe
function.Source§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self
, then passes self.deref()
into the pipe function.Source§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> Tap for T
impl<T> Tap for T
Source§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B>
of a value. Read moreSource§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B>
of a value. Read moreSource§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R>
view of a value. Read moreSource§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R>
view of a value. Read moreSource§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target
of a value. Read moreSource§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target
of a value. Read moreSource§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap()
only in debug builds, and is erased in release builds.Source§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut()
only in debug builds, and is erased in release
builds.Source§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.tap_borrow()
only in debug builds, and is erased in release
builds.Source§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.tap_borrow_mut()
only in debug builds, and is erased in release
builds.Source§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.tap_ref()
only in debug builds, and is erased in release
builds.Source§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.tap_ref_mut()
only in debug builds, and is erased in release
builds.Source§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref()
only in debug builds, and is erased in release
builds.