Interface AggregateOperation.Builder

All Superinterfaces:
Buildable, CopyableBuilder<AggregateOperation.Builder,AggregateOperation>, SdkBuilder<AggregateOperation.Builder,AggregateOperation>, SdkPojo
Enclosing class:
AggregateOperation
@Mutable @NotThreadSafe public static interface AggregateOperation.Builder extends SdkPojo, CopyableBuilder<AggregateOperation.Builder,AggregateOperation>

  • Method Details

    • alias

      AggregateOperation.Builder alias(String alias)

      Alias for this operation.

      Parameters:
      alias - Alias for this operation.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • source

      AggregateOperation.Builder source(TransformOperationSource source)

      The source transform operation that provides input data for the aggregation.

      Parameters:
      source - The source transform operation that provides input data for the aggregation.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • source

      default AggregateOperation.Builder source(Consumer<TransformOperationSource.Builder> source)

      The source transform operation that provides input data for the aggregation.

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

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to source(TransformOperationSource).

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

    • groupByColumnNames

      AggregateOperation.Builder groupByColumnNames(Collection<String> groupByColumnNames)

      The list of column names to group by when performing the aggregation. Rows with the same values in these columns will be grouped together.

      Parameters:
      groupByColumnNames - The list of column names to group by when performing the aggregation. Rows with the same values in these columns will be grouped together.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • groupByColumnNames

      AggregateOperation.Builder groupByColumnNames(String... groupByColumnNames)

      The list of column names to group by when performing the aggregation. Rows with the same values in these columns will be grouped together.

      Parameters:
      groupByColumnNames - The list of column names to group by when performing the aggregation. Rows with the same values in these columns will be grouped together.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • aggregations

      AggregateOperation.Builder aggregations(Collection<Aggregation> aggregations)

      The list of aggregation functions to apply to the grouped data, such as SUM, COUNT, or AVERAGE.

      Parameters:
      aggregations - The list of aggregation functions to apply to the grouped data, such as SUM, COUNT, or AVERAGE.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • aggregations

      AggregateOperation.Builder aggregations(Aggregation... aggregations)

      The list of aggregation functions to apply to the grouped data, such as SUM, COUNT, or AVERAGE.

      Parameters:
      aggregations - The list of aggregation functions to apply to the grouped data, such as SUM, COUNT, or AVERAGE.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • aggregations

      AggregateOperation.Builder aggregations(Consumer<Aggregation.Builder>... aggregations)

      The list of aggregation functions to apply to the grouped data, such as SUM, COUNT, or AVERAGE.

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

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

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