pub struct BigQueryLoadConfig {
pub staging_bucket: String,
pub staging_prefix: String,
pub gcs_auth: GcsCredentials,
pub write_disposition: String,
pub storage_host: Option<String>,
}Available on crate feature
arrow only.Expand description
GCS-staged Parquet load-job configuration for the Arrow columnar path.
Fields§
§staging_bucket: StringGCS bucket used to stage Parquet files before the load job. Files are
written as gs://<bucket>/<staging_prefix><uuid>.parquet.
staging_prefix: StringObject-key prefix within the bucket. Default faucet-bq-load/. A
trailing / is added if missing.
gcs_auth: GcsCredentialsCredentials for the GCS staging upload (independent of the BigQuery
auth used for the load job). Defaults to Application Default
Credentials.
write_disposition: StringBigQuery load writeDisposition — WRITE_APPEND (default),
WRITE_TRUNCATE, or WRITE_EMPTY.
storage_host: Option<String>Optional GCS storage endpoint override (e.g. a fake-gcs-server host for
tests). None uses the real Google endpoint.
Trait Implementations§
Source§impl Clone for BigQueryLoadConfig
impl Clone for BigQueryLoadConfig
Source§fn clone(&self) -> BigQueryLoadConfig
fn clone(&self) -> BigQueryLoadConfig
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for BigQueryLoadConfig
impl Debug for BigQueryLoadConfig
Source§impl<'de> Deserialize<'de> for BigQueryLoadConfig
impl<'de> Deserialize<'de> for BigQueryLoadConfig
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl JsonSchema for BigQueryLoadConfig
impl JsonSchema for BigQueryLoadConfig
Source§fn schema_id() -> Cow<'static, str>
fn schema_id() -> Cow<'static, str>
Returns a string that uniquely identifies the schema produced by this type. Read more
Source§fn json_schema(generator: &mut SchemaGenerator) -> Schema
fn json_schema(generator: &mut SchemaGenerator) -> Schema
Generates a JSON Schema for this type. Read more
Source§fn inline_schema() -> bool
fn inline_schema() -> bool
Whether JSON Schemas generated for this type should be included directly in parent schemas,
rather than being re-used where possible using the
$ref keyword. Read moreAuto Trait Implementations§
impl Freeze for BigQueryLoadConfig
impl RefUnwindSafe for BigQueryLoadConfig
impl Send for BigQueryLoadConfig
impl Sync for BigQueryLoadConfig
impl Unpin for BigQueryLoadConfig
impl UnsafeUnpin for BigQueryLoadConfig
impl UnwindSafe for BigQueryLoadConfig
Blanket Implementations§
impl<T> Allocation for T
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
Source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request