Enum dataflow_types::sources::ExternalSourceConnector [−][src]
pub enum ExternalSourceConnector {
Kafka(KafkaSourceConnector),
Kinesis(KinesisSourceConnector),
File(FileSourceConnector),
AvroOcf(FileSourceConnector),
S3(S3SourceConnector),
Postgres(PostgresSourceConnector),
PubNub(PubNubSourceConnector),
}
Variants
Kafka(KafkaSourceConnector)
Tuple Fields
Kinesis(KinesisSourceConnector)
Tuple Fields
File(FileSourceConnector)
Tuple Fields
AvroOcf(FileSourceConnector)
Tuple Fields
S3(S3SourceConnector)
Tuple Fields
Postgres(PostgresSourceConnector)
Tuple Fields
PubNub(PubNubSourceConnector)
Tuple Fields
Implementations
Returns the name and type of each additional metadata column that Materialize will automatically append to the source’s inherent columns.
Presently, each source type exposes precisely one metadata column that corresponds to some source-specific record counter. For example, file sources use a line number, while Kafka sources use a topic offset.
The columns declared here must be kept in sync with the actual source implementations that produce these columns.
pub fn metadata_column_types(
&self,
include_defaults: bool
) -> Vec<IncludedColumnSource>ⓘ
Optionally returns the name of the upstream resource this source corresponds to. (Currently only implemented for Kafka and Kinesis, to match old-style behavior TODO: decide whether we want file paths and other upstream names to show up in metrics too.
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
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 RefUnwindSafe for ExternalSourceConnector
impl Send for ExternalSourceConnector
impl Sync for ExternalSourceConnector
impl Unpin for ExternalSourceConnector
impl UnwindSafe for ExternalSourceConnector
Blanket Implementations
Mutably borrows from an owned value. Read more
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