Interface PartitionSpec.Builder

  • Method Details

    • partitionStrategy

      PartitionSpec.Builder partitionStrategy(String partitionStrategy)

      The partitioning strategy applied to records written to the table.

      Parameters:
      partitionStrategy - The partitioning strategy applied to records written to the table.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:
    • partitionStrategy

      PartitionSpec.Builder partitionStrategy(PartitionStrategy partitionStrategy)

      The partitioning strategy applied to records written to the table.

      Parameters:
      partitionStrategy - The partitioning strategy applied to records written to the table.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:
    • sourceList

      The source columns used by the partitioning strategy. For TIME_HOUR, must contain exactly one source column whose value is a timestamp.

      Parameters:
      sourceList - The source columns used by the partitioning strategy. For TIME_HOUR, must contain exactly one source column whose value is a timestamp.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • sourceList

      PartitionSpec.Builder sourceList(PartitionSource... sourceList)

      The source columns used by the partitioning strategy. For TIME_HOUR, must contain exactly one source column whose value is a timestamp.

      Parameters:
      sourceList - The source columns used by the partitioning strategy. For TIME_HOUR, must contain exactly one source column whose value is a timestamp.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • sourceList

      The source columns used by the partitioning strategy. For TIME_HOUR, must contain exactly one source column whose value is a timestamp.

      This is a convenience method that creates an instance of the PartitionSource.Builder avoiding the need to create one manually via PartitionSource.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to sourceList(List<PartitionSource>).

      Parameters:
      sourceList - a consumer that will call methods on PartitionSource.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also: