Package io.debezium.pipeline.spi

Interface Partition

All Known Implementing Classes:
AbstractPartition
public interface Partition
Describes the source partition to be processed by the connector in connector-specific terms and provides its representation as a Kafka Connect source partition.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static interface 
    Partition.Provider<P extends Partition>
    Implementations provide a set of connector-specific partitions based on the connector task configuration.

  • Method Summary

    Modifier and Type
    Method
    Description
    default Map<String,String>
    getLoggingContext()
    Returns the partition representation in the logging context.
    Map<String,String>
    getSourcePartition()
    Get source partition representation in current format, the most recent one.
    default List<Map<String,String>>
    getSupportedFormats()
    Get all representations of the source partition in all supported formats.

  • Method Details

    • getSourcePartition

      Map<String,String> getSourcePartition()
      Get source partition representation in current format, the most recent one.
      Returns:
      map being representation of this source partition

    • getSupportedFormats

      default List<Map<String,String>> getSupportedFormats()
      Get all representations of the source partition in all supported formats. The list includes current format, as the first one - the most preferred, but also all legacy formats that are still supported, in descending order of preference.
      Returns:
      list of maps, each map being representation of this source partition

    • getLoggingContext

      default Map<String,String> getLoggingContext()
      Returns the partition representation in the logging context.