Enum sql::ast::CreateSinkConnector [−][src]
pub enum CreateSinkConnector<T> where
T: AstInfo, {
Kafka {
broker: String,
topic: String,
key: Option<KafkaSinkKey>,
consistency: Option<KafkaConsistency<T>>,
},
AvroOcf {
path: String,
},
}
Variants
Kafka
AvroOcf
Fields
path: String
Avro Object Container File
Trait Implementations
Performs the conversion.
impl<'__enum_kinds1, T> From<&'__enum_kinds1 CreateSinkConnector<T>> for CreateSinkConnectorKind where
T: AstInfo,
impl<'__enum_kinds1, T> From<&'__enum_kinds1 CreateSinkConnector<T>> for CreateSinkConnectorKind where
T: AstInfo,
Performs the conversion.
impl<'__enum_kinds1, T> From<CreateSinkConnector<T>> for CreateSinkConnectorKind where
T: AstInfo,
impl<'__enum_kinds1, T> From<CreateSinkConnector<T>> for CreateSinkConnectorKind where
T: AstInfo,
Performs the conversion.
impl<T> PartialEq<CreateSinkConnector<T>> for CreateSinkConnector<T> where
T: PartialEq<T> + AstInfo,
impl<T> PartialEq<CreateSinkConnector<T>> for CreateSinkConnector<T> where
T: PartialEq<T> + AstInfo,
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
This method tests for !=
.
Auto Trait Implementations
impl<T> RefUnwindSafe for CreateSinkConnector<T> where
<T as AstInfo>::ObjectName: RefUnwindSafe,
impl<T> Send for CreateSinkConnector<T> where
<T as AstInfo>::ObjectName: Send,
impl<T> Sync for CreateSinkConnector<T> where
<T as AstInfo>::ObjectName: Sync,
impl<T> Unpin for CreateSinkConnector<T> where
<T as AstInfo>::ObjectName: Unpin,
impl<T> UnwindSafe for CreateSinkConnector<T> where
<T as AstInfo>::ObjectName: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Formats an object with the “alternative” format ({:#}
) and returns it.
Compare self to key
and return true
if they are equal.
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more