Class JavaUserDefinedTypedAggregation.MyAverage
- java.lang.Object
-
- org.apache.spark.sql.expressions.Aggregator<JavaUserDefinedTypedAggregation.Employee,JavaUserDefinedTypedAggregation.Average,java.lang.Double>
-
- org.apache.nemo.examples.spark.sql.JavaUserDefinedTypedAggregation.MyAverage
-
- All Implemented Interfaces:
java.io.Serializable
,scala.Serializable
- Enclosing class:
- JavaUserDefinedTypedAggregation
public static final class JavaUserDefinedTypedAggregation.MyAverage extends org.apache.spark.sql.expressions.Aggregator<JavaUserDefinedTypedAggregation.Employee,JavaUserDefinedTypedAggregation.Average,java.lang.Double>
MyAverage class.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description MyAverage()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.spark.sql.Encoder<JavaUserDefinedTypedAggregation.Average>
bufferEncoder()
Specifies the EncoderFactory for the intermediate value type.java.lang.Double
finish(JavaUserDefinedTypedAggregation.Average reduction)
Transform the output of the reduction.JavaUserDefinedTypedAggregation.Average
merge(JavaUserDefinedTypedAggregation.Average b1, JavaUserDefinedTypedAggregation.Average b2)
Merge two intermediate values.org.apache.spark.sql.Encoder<java.lang.Double>
outputEncoder()
Specifies the EncoderFactory for the final output value type.JavaUserDefinedTypedAggregation.Average
reduce(JavaUserDefinedTypedAggregation.Average buffer, JavaUserDefinedTypedAggregation.Employee employee)
Combine two values to produce a new value.JavaUserDefinedTypedAggregation.Average
zero()
A zero value for this aggregation.
-
-
-
Method Detail
-
zero
public JavaUserDefinedTypedAggregation.Average zero()
A zero value for this aggregation. Should satisfy the property that any b + zero = b.- Specified by:
zero
in classorg.apache.spark.sql.expressions.Aggregator<JavaUserDefinedTypedAggregation.Employee,JavaUserDefinedTypedAggregation.Average,java.lang.Double>
- Returns:
- zero.
-
reduce
public JavaUserDefinedTypedAggregation.Average reduce(JavaUserDefinedTypedAggregation.Average buffer, JavaUserDefinedTypedAggregation.Employee employee)
Combine two values to produce a new value. For performance, the function may modify `buffer` and return it instead of constructing a new object.- Specified by:
reduce
in classorg.apache.spark.sql.expressions.Aggregator<JavaUserDefinedTypedAggregation.Employee,JavaUserDefinedTypedAggregation.Average,java.lang.Double>
- Parameters:
buffer
- first value.employee
- second value.- Returns:
- average.
-
merge
public JavaUserDefinedTypedAggregation.Average merge(JavaUserDefinedTypedAggregation.Average b1, JavaUserDefinedTypedAggregation.Average b2)
Merge two intermediate values.- Specified by:
merge
in classorg.apache.spark.sql.expressions.Aggregator<JavaUserDefinedTypedAggregation.Employee,JavaUserDefinedTypedAggregation.Average,java.lang.Double>
- Parameters:
b1
- first value.b2
- second value.- Returns:
- merged result.
-
finish
public java.lang.Double finish(JavaUserDefinedTypedAggregation.Average reduction)
Transform the output of the reduction.- Specified by:
finish
in classorg.apache.spark.sql.expressions.Aggregator<JavaUserDefinedTypedAggregation.Employee,JavaUserDefinedTypedAggregation.Average,java.lang.Double>
- Parameters:
reduction
- reduction to transform.- Returns:
- the transformed result.
-
bufferEncoder
public org.apache.spark.sql.Encoder<JavaUserDefinedTypedAggregation.Average> bufferEncoder()
Specifies the EncoderFactory for the intermediate value type.- Specified by:
bufferEncoder
in classorg.apache.spark.sql.expressions.Aggregator<JavaUserDefinedTypedAggregation.Employee,JavaUserDefinedTypedAggregation.Average,java.lang.Double>
- Returns:
- buffer encoder.
-
outputEncoder
public org.apache.spark.sql.Encoder<java.lang.Double> outputEncoder()
Specifies the EncoderFactory for the final output value type.- Specified by:
outputEncoder
in classorg.apache.spark.sql.expressions.Aggregator<JavaUserDefinedTypedAggregation.Employee,JavaUserDefinedTypedAggregation.Average,java.lang.Double>
- Returns:
- output encoder.
-
-