pub struct AvroOptions {
pub schema: Option<Value>,
pub codec: AvroCodec,
}Expand description
Avro read/write options.
Fields§
§schema: Option<Value>An Avro schema (the JSON form: an object, an array for a union, or a primitive name). On a source it is the reader schema every file is resolved against — projection, aliases, defaults for added fields. On a sink it is the writer schema; without it the schema is inferred from the records.
codec: AvroCodecBlock codec for written files: null (default), deflate, snappy,
zstd. Reading detects the codec from the file header.
Implementations§
Source§impl AvroOptions
impl AvroOptions
Sourcepub fn parsed_schema(&self) -> Result<Option<Schema>, FaucetError>
Available on crate feature file-format-avro only.
pub fn parsed_schema(&self) -> Result<Option<Schema>, FaucetError>
file-format-avro only.The configured schema, parsed, if any.
Trait Implementations§
Source§impl Clone for AvroOptions
impl Clone for AvroOptions
Source§impl Debug for AvroOptions
impl Debug for AvroOptions
Source§impl Default for AvroOptions
impl Default for AvroOptions
Source§impl<'de> Deserialize<'de> for AvroOptions
impl<'de> Deserialize<'de> for AvroOptions
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
impl Eq for AvroOptions
Source§impl JsonSchema for AvroOptions
impl JsonSchema for AvroOptions
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 moreSource§impl PartialEq for AvroOptions
impl PartialEq for AvroOptions
Source§impl Serialize for AvroOptions
impl Serialize for AvroOptions
impl StructuralPartialEq for AvroOptions
Auto Trait Implementations§
impl Freeze for AvroOptions
impl RefUnwindSafe for AvroOptions
impl Send for AvroOptions
impl Sync for AvroOptions
impl Unpin for AvroOptions
impl UnsafeUnpin for AvroOptions
impl UnwindSafe for AvroOptions
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<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.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> 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 moreSource§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