org.apache.beam.sdk.extensions.sql.provider

Class UdfTestProvider.Sum

java.lang.Object

org.apache.beam.sdk.extensions.sql.provider.UdfTestProvider.Sum

All Implemented Interfaces:

AggregateFn<java.lang.Long,java.lang.Long,java.lang.Long>

Enclosing class:

UdfTestProvider

public static class UdfTestProvider.Sum
extends java.lang.Object
implements AggregateFn<java.lang.Long,java.lang.Long,java.lang.Long>

Constructor Summary

Constructors

Constructor and Description
Sum()

Method Summary

Modifier and Type	Method and Description
java.lang.Long	addInput(java.lang.Long mutableAccumulator, java.lang.Long input) Adds the given input value to the given accumulator, returning the new accumulator value.
java.lang.Long	createAccumulator() Returns a new, mutable accumulator value, representing the accumulation of zero input values.
java.lang.Long	extractOutput(java.lang.Long mutableAccumulator) Returns the output value that is the result of combining all the input values represented by the given accumulator.
java.lang.Long	mergeAccumulators(java.lang.Long mutableAccumulator, java.lang.Iterable<java.lang.Long> immutableAccumulators) Returns an accumulator representing the accumulation of all the input values accumulated in the merging accumulators.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Sum

public Sum()

Method Detail

createAccumulator

public java.lang.Long createAccumulator()

Description copied from interface: AggregateFn

Returns a new, mutable accumulator value, representing the accumulation of zero input values.

Specified by:

createAccumulator in interface AggregateFn<java.lang.Long,java.lang.Long,java.lang.Long>

addInput

public java.lang.Long addInput(java.lang.Long mutableAccumulator,
                               java.lang.Long input)

Description copied from interface: AggregateFn

Adds the given input value to the given accumulator, returning the new accumulator value.

Specified by:

addInput in interface AggregateFn<java.lang.Long,java.lang.Long,java.lang.Long>

Parameters:

mutableAccumulator - may be modified and returned for efficiency

input - should not be mutated

mergeAccumulators

public java.lang.Long mergeAccumulators(java.lang.Long mutableAccumulator,
                                        java.lang.Iterable<java.lang.Long> immutableAccumulators)

Description copied from interface: AggregateFn

Returns an accumulator representing the accumulation of all the input values accumulated in the merging accumulators.

Specified by:

mergeAccumulators in interface AggregateFn<java.lang.Long,java.lang.Long,java.lang.Long>

Parameters:

mutableAccumulator - This accumulator may be modified and returned for efficiency.

immutableAccumulators - These other accumulators should not be mutated, because they may be shared with other code and mutating them could lead to incorrect results or data corruption.

extractOutput

public java.lang.Long extractOutput(java.lang.Long mutableAccumulator)

Description copied from interface: AggregateFn

Returns the output value that is the result of combining all the input values represented by the given accumulator.

Specified by:

extractOutput in interface AggregateFn<java.lang.Long,java.lang.Long,java.lang.Long>

Parameters:

mutableAccumulator - can be modified for efficiency