Enum dataflow_types::types::sinks::SinkConnector [−][src]
pub enum SinkConnector {
Kafka(KafkaSinkConnector),
Tail(TailSinkConnector),
AvroOcf(AvroOcfSinkConnector),
}
Variants
Kafka(KafkaSinkConnector)
Tuple Fields
Tail(TailSinkConnector)
Tuple Fields
AvroOcf(AvroOcfSinkConnector)
Tuple Fields
Implementations
Returns true
if this sink requires sources to block timestamp binding
compaction until all sinks that depend on a given source have finished
writing out that timestamp.
To achieve that, each sink will hold a AntichainToken
for all of
the sources it depends on, and will advance all of its source
dependencies’ compaction frontiers as it completes writes.
Sinks that do need to hold back compaction need to insert an
Antichain
into StorageState::sink_write_frontiers
that they update
in order to advance the frontier that holds back upstream compaction
of timestamp bindings.
See also transitive_source_dependencies
.
Trait Implementations
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
Auto Trait Implementations
impl RefUnwindSafe for SinkConnector
impl Send for SinkConnector
impl Sync for SinkConnector
impl Unpin for SinkConnector
impl UnwindSafe for SinkConnector
Blanket Implementations
Mutably borrows from an owned value. Read more
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