fn identify_consistency_format(_enc: DataEncoding, env: SourceEnvelope) -> ConsistencyFormatting {
    if let SourceEnvelope::Debezium(_, DebeziumMode::Plain) = env {
        ConsistencyFormatting::DebeziumAvro
    } else {
        panic!("BYO timestamping for non-Debezium sources not supported!");
    }
}
/// This function determines the expected format of the consistency metadata as a function
/// of the encoding and the envelope of the source.
/// Specifically:
/// 1) an OCF file source with a Debezium envelope will expect an OCF Avro consistency source
/// that follows the TRX_METADATA_SCHEMA Avro spec outlined above
/// 2) any other file source with a Debezium envelope will expect an Avro consistency source
/// that follows the TRX_METADATA_SCHEMA Avro spec outlined above
This function determines the expected format of the consistency metadata as a function
of the encoding and the envelope of the source.
Specifically:
1) an OCF file source with a Debezium envelope will expect an OCF Avro consistency source
that follows the TRX_METADATA_SCHEMA Avro spec outlined above
2) any other file source with a Debezium envelope will expect an Avro consistency source
that follows the TRX_METADATA_SCHEMA Avro spec outlined above
This function determines the expected format of the consistency metadata as a function of the encoding and the envelope of the source . Specifically : 1 ) an OCF file source with a Debezium envelope will expect an OCF Avro consistency source that follows the TRX_METADATA_SCHEMA Avro spec outlined above 2 ) any other file source with a Debezium envelope will expect an Avro consistency source that follows the TRX_METADATA_SCHEMA Avro spec outlined above
fn identify_consistency_format(_enc: DataEncoding, env: SourceEnvelope) -> ConsistencyFormatting {
    if let SourceEnvelope::Debezium(_, DebeziumMode::Plain) = env {
        ConsistencyFormatting::DebeziumAvro
    } else {
        panic!("BYO timestamping for non-Debezium sources not supported!");
    }
}
fn identify_consistency_format ( _enc : DataEncoding , env : SourceEnvelope ) -> ConsistencyFormatting { if let SourceEnvelope :: Debezium ( _ , DebeziumMode :: Plain ) = env { ConsistencyFormatting :: DebeziumAvro } else { panic ! ( " " ) ; } }
This function determines the expected format of the consistency metadata as a function
of the encoding and the envelope of the source.
This function determines the expected format of the consistency metadata as a function of the encoding and the envelope of the source .
_enc
DataEncoding
env
SourceEnvelope
_enc
DataEncoding
env
SourceEnvelope