pub enum SplitImpl {
Show 20 variants
MysqlCdc(DebeziumCdcSplit<Mysql>),
PostgresCdc(DebeziumCdcSplit<Postgres>),
CitusCdc(DebeziumCdcSplit<Citus>),
MongodbCdc(DebeziumCdcSplit<Mongodb>),
SqlServerCdc(DebeziumCdcSplit<SqlServer>),
Kafka(KafkaSplit),
Pulsar(PulsarSplit),
Kinesis(KinesisSplit),
Nexmark(NexmarkSplit),
Datagen(DatagenSplit),
GooglePubsub(PubsubSplit),
Mqtt(MqttSplit),
Nats(NatsSplit),
S3(FsSplit),
Gcs(OpendalFsSplit<OpendalGcs>),
OpendalS3(OpendalFsSplit<OpendalS3>),
PosixFs(OpendalFsSplit<OpendalPosixFs>),
Azblob(OpendalFsSplit<OpendalAzblob>),
Test(TestSourceSplit),
Iceberg(IcebergSplit),
}
Variants§
MysqlCdc(DebeziumCdcSplit<Mysql>)
PostgresCdc(DebeziumCdcSplit<Postgres>)
CitusCdc(DebeziumCdcSplit<Citus>)
MongodbCdc(DebeziumCdcSplit<Mongodb>)
SqlServerCdc(DebeziumCdcSplit<SqlServer>)
Kafka(KafkaSplit)
Pulsar(PulsarSplit)
Kinesis(KinesisSplit)
Nexmark(NexmarkSplit)
Datagen(DatagenSplit)
GooglePubsub(PubsubSplit)
Mqtt(MqttSplit)
Nats(NatsSplit)
S3(FsSplit)
Gcs(OpendalFsSplit<OpendalGcs>)
OpendalS3(OpendalFsSplit<OpendalS3>)
PosixFs(OpendalFsSplit<OpendalPosixFs>)
Azblob(OpendalFsSplit<OpendalAzblob>)
Test(TestSourceSplit)
Iceberg(IcebergSplit)
Implementations§
source§impl SplitImpl
impl SplitImpl
sourcepub fn is_mysql_cdc(&self) -> bool
pub fn is_mysql_cdc(&self) -> bool
Returns true if this is a SplitImpl::MysqlCdc
, otherwise false
sourcepub fn as_mysql_cdc_mut(&mut self) -> Option<&mut DebeziumCdcSplit<Mysql>>
pub fn as_mysql_cdc_mut(&mut self) -> Option<&mut DebeziumCdcSplit<Mysql>>
Optionally returns mutable references to the inner fields if this is a SplitImpl::MysqlCdc
, otherwise None
sourcepub fn as_mysql_cdc(&self) -> Option<&DebeziumCdcSplit<Mysql>>
pub fn as_mysql_cdc(&self) -> Option<&DebeziumCdcSplit<Mysql>>
Optionally returns references to the inner fields if this is a SplitImpl::MysqlCdc
, otherwise None
sourcepub fn into_mysql_cdc(self) -> Result<DebeziumCdcSplit<Mysql>, Self>
pub fn into_mysql_cdc(self) -> Result<DebeziumCdcSplit<Mysql>, Self>
Returns the inner fields if this is a SplitImpl::MysqlCdc
, otherwise returns back the enum in the Err
case of the result
sourcepub fn is_postgres_cdc(&self) -> bool
pub fn is_postgres_cdc(&self) -> bool
Returns true if this is a SplitImpl::PostgresCdc
, otherwise false
sourcepub fn as_postgres_cdc_mut(&mut self) -> Option<&mut DebeziumCdcSplit<Postgres>>
pub fn as_postgres_cdc_mut(&mut self) -> Option<&mut DebeziumCdcSplit<Postgres>>
Optionally returns mutable references to the inner fields if this is a SplitImpl::PostgresCdc
, otherwise None
sourcepub fn as_postgres_cdc(&self) -> Option<&DebeziumCdcSplit<Postgres>>
pub fn as_postgres_cdc(&self) -> Option<&DebeziumCdcSplit<Postgres>>
Optionally returns references to the inner fields if this is a SplitImpl::PostgresCdc
, otherwise None
sourcepub fn into_postgres_cdc(self) -> Result<DebeziumCdcSplit<Postgres>, Self>
pub fn into_postgres_cdc(self) -> Result<DebeziumCdcSplit<Postgres>, Self>
Returns the inner fields if this is a SplitImpl::PostgresCdc
, otherwise returns back the enum in the Err
case of the result
sourcepub fn is_citus_cdc(&self) -> bool
pub fn is_citus_cdc(&self) -> bool
Returns true if this is a SplitImpl::CitusCdc
, otherwise false
sourcepub fn as_citus_cdc_mut(&mut self) -> Option<&mut DebeziumCdcSplit<Citus>>
pub fn as_citus_cdc_mut(&mut self) -> Option<&mut DebeziumCdcSplit<Citus>>
Optionally returns mutable references to the inner fields if this is a SplitImpl::CitusCdc
, otherwise None
sourcepub fn as_citus_cdc(&self) -> Option<&DebeziumCdcSplit<Citus>>
pub fn as_citus_cdc(&self) -> Option<&DebeziumCdcSplit<Citus>>
Optionally returns references to the inner fields if this is a SplitImpl::CitusCdc
, otherwise None
sourcepub fn into_citus_cdc(self) -> Result<DebeziumCdcSplit<Citus>, Self>
pub fn into_citus_cdc(self) -> Result<DebeziumCdcSplit<Citus>, Self>
Returns the inner fields if this is a SplitImpl::CitusCdc
, otherwise returns back the enum in the Err
case of the result
sourcepub fn is_mongodb_cdc(&self) -> bool
pub fn is_mongodb_cdc(&self) -> bool
Returns true if this is a SplitImpl::MongodbCdc
, otherwise false
sourcepub fn as_mongodb_cdc_mut(&mut self) -> Option<&mut DebeziumCdcSplit<Mongodb>>
pub fn as_mongodb_cdc_mut(&mut self) -> Option<&mut DebeziumCdcSplit<Mongodb>>
Optionally returns mutable references to the inner fields if this is a SplitImpl::MongodbCdc
, otherwise None
sourcepub fn as_mongodb_cdc(&self) -> Option<&DebeziumCdcSplit<Mongodb>>
pub fn as_mongodb_cdc(&self) -> Option<&DebeziumCdcSplit<Mongodb>>
Optionally returns references to the inner fields if this is a SplitImpl::MongodbCdc
, otherwise None
sourcepub fn into_mongodb_cdc(self) -> Result<DebeziumCdcSplit<Mongodb>, Self>
pub fn into_mongodb_cdc(self) -> Result<DebeziumCdcSplit<Mongodb>, Self>
Returns the inner fields if this is a SplitImpl::MongodbCdc
, otherwise returns back the enum in the Err
case of the result
sourcepub fn is_sql_server_cdc(&self) -> bool
pub fn is_sql_server_cdc(&self) -> bool
Returns true if this is a SplitImpl::SqlServerCdc
, otherwise false
sourcepub fn as_sql_server_cdc_mut(
&mut self,
) -> Option<&mut DebeziumCdcSplit<SqlServer>>
pub fn as_sql_server_cdc_mut( &mut self, ) -> Option<&mut DebeziumCdcSplit<SqlServer>>
Optionally returns mutable references to the inner fields if this is a SplitImpl::SqlServerCdc
, otherwise None
sourcepub fn as_sql_server_cdc(&self) -> Option<&DebeziumCdcSplit<SqlServer>>
pub fn as_sql_server_cdc(&self) -> Option<&DebeziumCdcSplit<SqlServer>>
Optionally returns references to the inner fields if this is a SplitImpl::SqlServerCdc
, otherwise None
sourcepub fn into_sql_server_cdc(self) -> Result<DebeziumCdcSplit<SqlServer>, Self>
pub fn into_sql_server_cdc(self) -> Result<DebeziumCdcSplit<SqlServer>, Self>
Returns the inner fields if this is a SplitImpl::SqlServerCdc
, otherwise returns back the enum in the Err
case of the result
sourcepub fn as_kafka_mut(&mut self) -> Option<&mut KafkaSplit>
pub fn as_kafka_mut(&mut self) -> Option<&mut KafkaSplit>
Optionally returns mutable references to the inner fields if this is a SplitImpl::Kafka
, otherwise None
sourcepub fn as_kafka(&self) -> Option<&KafkaSplit>
pub fn as_kafka(&self) -> Option<&KafkaSplit>
Optionally returns references to the inner fields if this is a SplitImpl::Kafka
, otherwise None
sourcepub fn into_kafka(self) -> Result<KafkaSplit, Self>
pub fn into_kafka(self) -> Result<KafkaSplit, Self>
Returns the inner fields if this is a SplitImpl::Kafka
, otherwise returns back the enum in the Err
case of the result
sourcepub fn as_pulsar_mut(&mut self) -> Option<&mut PulsarSplit>
pub fn as_pulsar_mut(&mut self) -> Option<&mut PulsarSplit>
Optionally returns mutable references to the inner fields if this is a SplitImpl::Pulsar
, otherwise None
sourcepub fn as_pulsar(&self) -> Option<&PulsarSplit>
pub fn as_pulsar(&self) -> Option<&PulsarSplit>
Optionally returns references to the inner fields if this is a SplitImpl::Pulsar
, otherwise None
sourcepub fn into_pulsar(self) -> Result<PulsarSplit, Self>
pub fn into_pulsar(self) -> Result<PulsarSplit, Self>
Returns the inner fields if this is a SplitImpl::Pulsar
, otherwise returns back the enum in the Err
case of the result
sourcepub fn is_kinesis(&self) -> bool
pub fn is_kinesis(&self) -> bool
Returns true if this is a SplitImpl::Kinesis
, otherwise false
sourcepub fn as_kinesis_mut(&mut self) -> Option<&mut KinesisSplit>
pub fn as_kinesis_mut(&mut self) -> Option<&mut KinesisSplit>
Optionally returns mutable references to the inner fields if this is a SplitImpl::Kinesis
, otherwise None
sourcepub fn as_kinesis(&self) -> Option<&KinesisSplit>
pub fn as_kinesis(&self) -> Option<&KinesisSplit>
Optionally returns references to the inner fields if this is a SplitImpl::Kinesis
, otherwise None
sourcepub fn into_kinesis(self) -> Result<KinesisSplit, Self>
pub fn into_kinesis(self) -> Result<KinesisSplit, Self>
Returns the inner fields if this is a SplitImpl::Kinesis
, otherwise returns back the enum in the Err
case of the result
sourcepub fn is_nexmark(&self) -> bool
pub fn is_nexmark(&self) -> bool
Returns true if this is a SplitImpl::Nexmark
, otherwise false
sourcepub fn as_nexmark_mut(&mut self) -> Option<&mut NexmarkSplit>
pub fn as_nexmark_mut(&mut self) -> Option<&mut NexmarkSplit>
Optionally returns mutable references to the inner fields if this is a SplitImpl::Nexmark
, otherwise None
sourcepub fn as_nexmark(&self) -> Option<&NexmarkSplit>
pub fn as_nexmark(&self) -> Option<&NexmarkSplit>
Optionally returns references to the inner fields if this is a SplitImpl::Nexmark
, otherwise None
sourcepub fn into_nexmark(self) -> Result<NexmarkSplit, Self>
pub fn into_nexmark(self) -> Result<NexmarkSplit, Self>
Returns the inner fields if this is a SplitImpl::Nexmark
, otherwise returns back the enum in the Err
case of the result
sourcepub fn is_datagen(&self) -> bool
pub fn is_datagen(&self) -> bool
Returns true if this is a SplitImpl::Datagen
, otherwise false
sourcepub fn as_datagen_mut(&mut self) -> Option<&mut DatagenSplit>
pub fn as_datagen_mut(&mut self) -> Option<&mut DatagenSplit>
Optionally returns mutable references to the inner fields if this is a SplitImpl::Datagen
, otherwise None
sourcepub fn as_datagen(&self) -> Option<&DatagenSplit>
pub fn as_datagen(&self) -> Option<&DatagenSplit>
Optionally returns references to the inner fields if this is a SplitImpl::Datagen
, otherwise None
sourcepub fn into_datagen(self) -> Result<DatagenSplit, Self>
pub fn into_datagen(self) -> Result<DatagenSplit, Self>
Returns the inner fields if this is a SplitImpl::Datagen
, otherwise returns back the enum in the Err
case of the result
sourcepub fn is_google_pubsub(&self) -> bool
pub fn is_google_pubsub(&self) -> bool
Returns true if this is a SplitImpl::GooglePubsub
, otherwise false
sourcepub fn as_google_pubsub_mut(&mut self) -> Option<&mut PubsubSplit>
pub fn as_google_pubsub_mut(&mut self) -> Option<&mut PubsubSplit>
Optionally returns mutable references to the inner fields if this is a SplitImpl::GooglePubsub
, otherwise None
sourcepub fn as_google_pubsub(&self) -> Option<&PubsubSplit>
pub fn as_google_pubsub(&self) -> Option<&PubsubSplit>
Optionally returns references to the inner fields if this is a SplitImpl::GooglePubsub
, otherwise None
sourcepub fn into_google_pubsub(self) -> Result<PubsubSplit, Self>
pub fn into_google_pubsub(self) -> Result<PubsubSplit, Self>
Returns the inner fields if this is a SplitImpl::GooglePubsub
, otherwise returns back the enum in the Err
case of the result
sourcepub fn as_mqtt_mut(&mut self) -> Option<&mut MqttSplit>
pub fn as_mqtt_mut(&mut self) -> Option<&mut MqttSplit>
Optionally returns mutable references to the inner fields if this is a SplitImpl::Mqtt
, otherwise None
sourcepub fn as_mqtt(&self) -> Option<&MqttSplit>
pub fn as_mqtt(&self) -> Option<&MqttSplit>
Optionally returns references to the inner fields if this is a SplitImpl::Mqtt
, otherwise None
sourcepub fn into_mqtt(self) -> Result<MqttSplit, Self>
pub fn into_mqtt(self) -> Result<MqttSplit, Self>
Returns the inner fields if this is a SplitImpl::Mqtt
, otherwise returns back the enum in the Err
case of the result
sourcepub fn as_nats_mut(&mut self) -> Option<&mut NatsSplit>
pub fn as_nats_mut(&mut self) -> Option<&mut NatsSplit>
Optionally returns mutable references to the inner fields if this is a SplitImpl::Nats
, otherwise None
sourcepub fn as_nats(&self) -> Option<&NatsSplit>
pub fn as_nats(&self) -> Option<&NatsSplit>
Optionally returns references to the inner fields if this is a SplitImpl::Nats
, otherwise None
sourcepub fn into_nats(self) -> Result<NatsSplit, Self>
pub fn into_nats(self) -> Result<NatsSplit, Self>
Returns the inner fields if this is a SplitImpl::Nats
, otherwise returns back the enum in the Err
case of the result
sourcepub fn as_s3_mut(&mut self) -> Option<&mut FsSplit>
pub fn as_s3_mut(&mut self) -> Option<&mut FsSplit>
Optionally returns mutable references to the inner fields if this is a SplitImpl::S3
, otherwise None
sourcepub fn as_s3(&self) -> Option<&FsSplit>
pub fn as_s3(&self) -> Option<&FsSplit>
Optionally returns references to the inner fields if this is a SplitImpl::S3
, otherwise None
sourcepub fn into_s3(self) -> Result<FsSplit, Self>
pub fn into_s3(self) -> Result<FsSplit, Self>
Returns the inner fields if this is a SplitImpl::S3
, otherwise returns back the enum in the Err
case of the result
sourcepub fn as_gcs_mut(&mut self) -> Option<&mut OpendalFsSplit<OpendalGcs>>
pub fn as_gcs_mut(&mut self) -> Option<&mut OpendalFsSplit<OpendalGcs>>
Optionally returns mutable references to the inner fields if this is a SplitImpl::Gcs
, otherwise None
sourcepub fn as_gcs(&self) -> Option<&OpendalFsSplit<OpendalGcs>>
pub fn as_gcs(&self) -> Option<&OpendalFsSplit<OpendalGcs>>
Optionally returns references to the inner fields if this is a SplitImpl::Gcs
, otherwise None
sourcepub fn into_gcs(self) -> Result<OpendalFsSplit<OpendalGcs>, Self>
pub fn into_gcs(self) -> Result<OpendalFsSplit<OpendalGcs>, Self>
Returns the inner fields if this is a SplitImpl::Gcs
, otherwise returns back the enum in the Err
case of the result
sourcepub fn is_opendal_s3(&self) -> bool
pub fn is_opendal_s3(&self) -> bool
Returns true if this is a SplitImpl::OpendalS3
, otherwise false
sourcepub fn as_opendal_s3_mut(&mut self) -> Option<&mut OpendalFsSplit<OpendalS3>>
pub fn as_opendal_s3_mut(&mut self) -> Option<&mut OpendalFsSplit<OpendalS3>>
Optionally returns mutable references to the inner fields if this is a SplitImpl::OpendalS3
, otherwise None
sourcepub fn as_opendal_s3(&self) -> Option<&OpendalFsSplit<OpendalS3>>
pub fn as_opendal_s3(&self) -> Option<&OpendalFsSplit<OpendalS3>>
Optionally returns references to the inner fields if this is a SplitImpl::OpendalS3
, otherwise None
sourcepub fn into_opendal_s3(self) -> Result<OpendalFsSplit<OpendalS3>, Self>
pub fn into_opendal_s3(self) -> Result<OpendalFsSplit<OpendalS3>, Self>
Returns the inner fields if this is a SplitImpl::OpendalS3
, otherwise returns back the enum in the Err
case of the result
sourcepub fn is_posix_fs(&self) -> bool
pub fn is_posix_fs(&self) -> bool
Returns true if this is a SplitImpl::PosixFs
, otherwise false
sourcepub fn as_posix_fs_mut(&mut self) -> Option<&mut OpendalFsSplit<OpendalPosixFs>>
pub fn as_posix_fs_mut(&mut self) -> Option<&mut OpendalFsSplit<OpendalPosixFs>>
Optionally returns mutable references to the inner fields if this is a SplitImpl::PosixFs
, otherwise None
sourcepub fn as_posix_fs(&self) -> Option<&OpendalFsSplit<OpendalPosixFs>>
pub fn as_posix_fs(&self) -> Option<&OpendalFsSplit<OpendalPosixFs>>
Optionally returns references to the inner fields if this is a SplitImpl::PosixFs
, otherwise None
sourcepub fn into_posix_fs(self) -> Result<OpendalFsSplit<OpendalPosixFs>, Self>
pub fn into_posix_fs(self) -> Result<OpendalFsSplit<OpendalPosixFs>, Self>
Returns the inner fields if this is a SplitImpl::PosixFs
, otherwise returns back the enum in the Err
case of the result
sourcepub fn as_azblob_mut(&mut self) -> Option<&mut OpendalFsSplit<OpendalAzblob>>
pub fn as_azblob_mut(&mut self) -> Option<&mut OpendalFsSplit<OpendalAzblob>>
Optionally returns mutable references to the inner fields if this is a SplitImpl::Azblob
, otherwise None
sourcepub fn as_azblob(&self) -> Option<&OpendalFsSplit<OpendalAzblob>>
pub fn as_azblob(&self) -> Option<&OpendalFsSplit<OpendalAzblob>>
Optionally returns references to the inner fields if this is a SplitImpl::Azblob
, otherwise None
sourcepub fn into_azblob(self) -> Result<OpendalFsSplit<OpendalAzblob>, Self>
pub fn into_azblob(self) -> Result<OpendalFsSplit<OpendalAzblob>, Self>
Returns the inner fields if this is a SplitImpl::Azblob
, otherwise returns back the enum in the Err
case of the result
sourcepub fn as_test_mut(&mut self) -> Option<&mut TestSourceSplit>
pub fn as_test_mut(&mut self) -> Option<&mut TestSourceSplit>
Optionally returns mutable references to the inner fields if this is a SplitImpl::Test
, otherwise None
sourcepub fn as_test(&self) -> Option<&TestSourceSplit>
pub fn as_test(&self) -> Option<&TestSourceSplit>
Optionally returns references to the inner fields if this is a SplitImpl::Test
, otherwise None
sourcepub fn into_test(self) -> Result<TestSourceSplit, Self>
pub fn into_test(self) -> Result<TestSourceSplit, Self>
Returns the inner fields if this is a SplitImpl::Test
, otherwise returns back the enum in the Err
case of the result
sourcepub fn is_iceberg(&self) -> bool
pub fn is_iceberg(&self) -> bool
Returns true if this is a SplitImpl::Iceberg
, otherwise false
sourcepub fn as_iceberg_mut(&mut self) -> Option<&mut IcebergSplit>
pub fn as_iceberg_mut(&mut self) -> Option<&mut IcebergSplit>
Optionally returns mutable references to the inner fields if this is a SplitImpl::Iceberg
, otherwise None
sourcepub fn as_iceberg(&self) -> Option<&IcebergSplit>
pub fn as_iceberg(&self) -> Option<&IcebergSplit>
Optionally returns references to the inner fields if this is a SplitImpl::Iceberg
, otherwise None
sourcepub fn into_iceberg(self) -> Result<IcebergSplit, Self>
pub fn into_iceberg(self) -> Result<IcebergSplit, Self>
Returns the inner fields if this is a SplitImpl::Iceberg
, otherwise returns back the enum in the Err
case of the result
source§impl SplitImpl
impl SplitImpl
fn restore_from_json_inner(split_type: &str, value: JsonbVal) -> Result<Self>
pub fn is_cdc_split(&self) -> bool
sourcepub fn get_cdc_split_offset(&self) -> String
pub fn get_cdc_split_offset(&self) -> String
Get the current split offset.
Trait Implementations§
source§impl From<&SplitImpl> for ConnectorSplit
impl From<&SplitImpl> for ConnectorSplit
source§impl From<DatagenSplit> for SplitImpl
impl From<DatagenSplit> for SplitImpl
source§fn from(split: DatagenSplit) -> SplitImpl
fn from(split: DatagenSplit) -> SplitImpl
source§impl From<IcebergSplit> for SplitImpl
impl From<IcebergSplit> for SplitImpl
source§fn from(split: IcebergSplit) -> SplitImpl
fn from(split: IcebergSplit) -> SplitImpl
source§impl From<KafkaSplit> for SplitImpl
impl From<KafkaSplit> for SplitImpl
source§fn from(split: KafkaSplit) -> SplitImpl
fn from(split: KafkaSplit) -> SplitImpl
source§impl From<KinesisSplit> for SplitImpl
impl From<KinesisSplit> for SplitImpl
source§fn from(split: KinesisSplit) -> SplitImpl
fn from(split: KinesisSplit) -> SplitImpl
source§impl From<NexmarkSplit> for SplitImpl
impl From<NexmarkSplit> for SplitImpl
source§fn from(split: NexmarkSplit) -> SplitImpl
fn from(split: NexmarkSplit) -> SplitImpl
source§impl From<OpendalFsSplit<OpendalAzblob>> for SplitImpl
impl From<OpendalFsSplit<OpendalAzblob>> for SplitImpl
source§fn from(split: OpendalFsSplit<OpendalAzblob>) -> SplitImpl
fn from(split: OpendalFsSplit<OpendalAzblob>) -> SplitImpl
source§impl From<OpendalFsSplit<OpendalGcs>> for SplitImpl
impl From<OpendalFsSplit<OpendalGcs>> for SplitImpl
source§fn from(split: OpendalFsSplit<OpendalGcs>) -> SplitImpl
fn from(split: OpendalFsSplit<OpendalGcs>) -> SplitImpl
source§impl From<OpendalFsSplit<OpendalPosixFs>> for SplitImpl
impl From<OpendalFsSplit<OpendalPosixFs>> for SplitImpl
source§fn from(split: OpendalFsSplit<OpendalPosixFs>) -> SplitImpl
fn from(split: OpendalFsSplit<OpendalPosixFs>) -> SplitImpl
source§impl From<PubsubSplit> for SplitImpl
impl From<PubsubSplit> for SplitImpl
source§fn from(split: PubsubSplit) -> SplitImpl
fn from(split: PubsubSplit) -> SplitImpl
source§impl From<PulsarSplit> for SplitImpl
impl From<PulsarSplit> for SplitImpl
source§fn from(split: PulsarSplit) -> SplitImpl
fn from(split: PulsarSplit) -> SplitImpl
source§impl From<TestSourceSplit> for SplitImpl
impl From<TestSourceSplit> for SplitImpl
source§fn from(split: TestSourceSplit) -> SplitImpl
fn from(split: TestSourceSplit) -> SplitImpl
source§impl SplitMetaData for SplitImpl
impl SplitMetaData for SplitImpl
fn id(&self) -> SplitId
source§fn encode_to_json(&self) -> JsonbVal
fn encode_to_json(&self) -> JsonbVal
fn restore_from_json(value: JsonbVal) -> Result<Self>
fn update_offset(&mut self, last_seen_offset: String) -> Result<()>
fn encode_to_bytes(&self) -> Bytes
fn restore_from_bytes(bytes: &[u8]) -> Result<Self>
source§impl TryFrom<&ConnectorSplit> for SplitImpl
impl TryFrom<&ConnectorSplit> for SplitImpl
source§type Error = ConnectorError
type Error = ConnectorError
source§impl TryFrom<SplitImpl> for DatagenSplit
impl TryFrom<SplitImpl> for DatagenSplit
source§impl TryFrom<SplitImpl> for IcebergSplit
impl TryFrom<SplitImpl> for IcebergSplit
source§impl TryFrom<SplitImpl> for KafkaSplit
impl TryFrom<SplitImpl> for KafkaSplit
source§impl TryFrom<SplitImpl> for KinesisSplit
impl TryFrom<SplitImpl> for KinesisSplit
source§impl TryFrom<SplitImpl> for NexmarkSplit
impl TryFrom<SplitImpl> for NexmarkSplit
source§impl TryFrom<SplitImpl> for OpendalFsSplit<OpendalAzblob>
impl TryFrom<SplitImpl> for OpendalFsSplit<OpendalAzblob>
source§impl TryFrom<SplitImpl> for OpendalFsSplit<OpendalGcs>
impl TryFrom<SplitImpl> for OpendalFsSplit<OpendalGcs>
source§impl TryFrom<SplitImpl> for OpendalFsSplit<OpendalPosixFs>
impl TryFrom<SplitImpl> for OpendalFsSplit<OpendalPosixFs>
source§impl TryFrom<SplitImpl> for PubsubSplit
impl TryFrom<SplitImpl> for PubsubSplit
source§impl TryFrom<SplitImpl> for PulsarSplit
impl TryFrom<SplitImpl> for PulsarSplit
source§impl TryFrom<SplitImpl> for TestSourceSplit
impl TryFrom<SplitImpl> for TestSourceSplit
impl StructuralPartialEq for SplitImpl
Auto Trait Implementations§
impl Freeze for SplitImpl
impl RefUnwindSafe for SplitImpl
impl Send for SplitImpl
impl Sync for SplitImpl
impl Unpin for SplitImpl
impl UnwindSafe for SplitImpl
Blanket Implementations§
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
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit
)§impl<T> Conv for T
impl<T> Conv for T
§impl<Choices> CoproductSubsetter<CNil, HNil> for Choices
impl<Choices> CoproductSubsetter<CNil, HNil> for Choices
§impl<T> FmtForward for T
impl<T> FmtForward for T
§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
self
to use its Binary
implementation when Debug
-formatted.§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
self
to use its Display
implementation when
Debug
-formatted.§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
self
to use its LowerExp
implementation when
Debug
-formatted.§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
self
to use its LowerHex
implementation when
Debug
-formatted.§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
self
to use its Octal
implementation when Debug
-formatted.§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
self
to use its Pointer
implementation when
Debug
-formatted.§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
self
to use its UpperExp
implementation when
Debug
-formatted.§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
self
to use its UpperHex
implementation when
Debug
-formatted.§fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<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>
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>
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>
T
in a tonic::Request
§impl<T> IntoResult<T> for T
impl<T> IntoResult<T> for T
type Err = Infallible
fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>
§impl<T, U, I> LiftInto<U, I> for Twhere
U: LiftFrom<T, I>,
impl<T, U, I> LiftInto<U, I> for Twhere
U: LiftFrom<T, I>,
source§impl<M> MetricVecRelabelExt for M
impl<M> MetricVecRelabelExt for M
source§fn relabel(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
RelabeledMetricVec::with_metric_level
.source§fn relabel_n(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
relabel_num: usize,
) -> RelabeledMetricVec<M>
fn relabel_n( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, relabel_num: usize, ) -> RelabeledMetricVec<M>
RelabeledMetricVec::with_metric_level_relabel_n
.source§fn relabel_debug_1(
self,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel_debug_1( self, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
RelabeledMetricVec::with_metric_level_relabel_n
with metric_level
set to
MetricLevel::Debug
and relabel_num
set to 1.§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read more§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read more§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
self
, then passes self.as_ref()
into the pipe function.§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
self
, then passes self.as_mut()
into the pipe
function.§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self
, then passes self.deref()
into the pipe function.§impl<T> Pointable for T
impl<T> Pointable for T
§impl<Source> Sculptor<HNil, HNil> for Source
impl<Source> Sculptor<HNil, HNil> for Source
§impl<T> Tap for T
impl<T> Tap for T
§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B>
of a value. Read more§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B>
of a value. Read more§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R>
view of a value. Read more§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R>
view of a value. Read more§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target
of a value. Read more§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target
of a value. Read more§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap()
only in debug builds, and is erased in release builds.§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut()
only in debug builds, and is erased in release
builds.§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.tap_borrow()
only in debug builds, and is erased in release
builds.§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.tap_borrow_mut()
only in debug builds, and is erased in release
builds.§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.tap_ref()
only in debug builds, and is erased in release
builds.§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.tap_ref_mut()
only in debug builds, and is erased in release
builds.§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref()
only in debug builds, and is erased in release
builds.