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> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
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.