Interface SourceTableConfig.Builder

  • Method Details

    • fields

      A list of fields used for column-level filtering.

      Parameters:
      fields - A list of fields used for column-level filtering.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • fields

      SourceTableConfig.Builder fields(String... fields)

      A list of fields used for column-level filtering.

      Parameters:
      fields - A list of fields used for column-level filtering.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • filterPredicate

      SourceTableConfig.Builder filterPredicate(String filterPredicate)

      A condition clause used for row-level filtering.

      Parameters:
      filterPredicate - A condition clause used for row-level filtering.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • primaryKey

      SourceTableConfig.Builder primaryKey(Collection<String> primaryKey)

      Unique identifier of a record.

      Parameters:
      primaryKey - Unique identifier of a record.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • primaryKey

      SourceTableConfig.Builder primaryKey(String... primaryKey)

      Unique identifier of a record.

      Parameters:
      primaryKey - Unique identifier of a record.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • recordUpdateField

      SourceTableConfig.Builder recordUpdateField(String recordUpdateField)

      Incremental pull timestamp-based field.

      Parameters:
      recordUpdateField - Incremental pull timestamp-based field.
      Returns:
      Returns a reference to this object so that method calls can be chained together.