Struct SubmitJobParams

Source
pub struct SubmitJobParams {
Show 16 fields pub dataset: String, pub symbols: Symbols, pub schema: Schema, pub date_time_range: DateTimeRange, pub encoding: Encoding, pub compression: Compression, pub pretty_px: bool, pub pretty_ts: bool, pub map_symbols: bool, pub split_symbols: bool, pub split_duration: Option<SplitDuration>, pub split_size: Option<NonZeroU64>, pub delivery: Delivery, pub stype_in: SType, pub stype_out: SType, pub limit: Option<NonZeroU64>,
}
Available on crate feature historical only.
Expand description

The parameters for BatchClient::submit_job(). Use SubmitJobParams::builder() to get a builder type with all the preset defaults.

Fields§

§dataset: String

The dataset code.

§symbols: Symbols

The symbols to filter for.

§schema: Schema

The data record schema.

§date_time_range: DateTimeRange

The date time request range. Filters on ts_recv if it exists in the schema, otherwise ts_event.

§encoding: Encoding

The data encoding. Defaults to Dbn.

§compression: Compression

The data compression mode. Defaults to ZStd.

§pretty_px: bool

If true, prices will be formatted to the correct scale (using the fixed- precision scalar 1e-9). Only valid for Encoding::Csv and Encoding::Json.

§pretty_ts: bool

If true, timestamps will be formatted as ISO 8601 strings. Only valid for Encoding::Csv and Encoding::Json.

§map_symbols: bool

If true, a symbol field will be included with each text-encoded record, reducing the need to look at the symbology.json. Only valid for Encoding::Csv and Encoding::Json.

§split_symbols: bool

If true, files will be split by raw symbol. Cannot be requested with Symbols::All.

§split_duration: Option<SplitDuration>

The maximum time duration before batched data is split into multiple files. If None the data will not be split by time. Defaults to Day.

§split_size: Option<NonZeroU64>

The optional maximum size (in bytes) of each batched data file before being split. Must be an integer between 1e9 and 10e9 inclusive (1GB - 10GB). Defaults to None.

§delivery: Delivery

The delivery mechanism for the batched data files once processed. Defaults to Download.

§stype_in: SType

The symbology type of the input symbols. Defaults to RawSymbol.

§stype_out: SType

The symbology type of the output symbols. Defaults to InstrumentId.

§limit: Option<NonZeroU64>

The optional maximum number of records to return. Defaults to no limit.

Implementations§

Source§

impl SubmitJobParams

Source

pub fn builder() -> SubmitJobParamsBuilder<((), (), (), (), (), (), (), (), (), (), (), (), (), (), (), ())>

Create a builder for building SubmitJobParams. On the builder, call .dataset(...), .symbols(...), .schema(...), .date_time_range(...), .encoding(...)(optional), .compression(...)(optional), .pretty_px(...)(optional), .pretty_ts(...)(optional), .map_symbols(...)(optional), .split_symbols(...)(optional), .split_duration(...)(optional), .split_size(...)(optional), .delivery(...)(optional), .stype_in(...)(optional), .stype_out(...)(optional), .limit(...)(optional) to set the values of the fields. Finally, call .build() to create the instance of SubmitJobParams.

Trait Implementations§

Source§

impl Clone for SubmitJobParams

Source§

fn clone(&self) -> SubmitJobParams

Returns a duplicate of the value. Read more
1.0.0 · Source§

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl Debug for SubmitJobParams

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl PartialEq for SubmitJobParams

Source§

fn eq(&self, other: &SubmitJobParams) -> bool

Tests for self and other values to be equal, and is used by ==.
1.0.0 · Source§

const fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
Source§

impl Eq for SubmitJobParams

Source§

impl StructuralPartialEq for SubmitJobParams

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,