Uses of Class
org.apache.nemo.examples.spark.sql.JavaUserDefinedTypedAggregation.Average
-
Packages that use JavaUserDefinedTypedAggregation.Average Package Description org.apache.nemo.examples.spark.sql -
-
Uses of JavaUserDefinedTypedAggregation.Average in org.apache.nemo.examples.spark.sql
Methods in org.apache.nemo.examples.spark.sql that return JavaUserDefinedTypedAggregation.Average Modifier and Type Method Description JavaUserDefinedTypedAggregation.Average
JavaUserDefinedTypedAggregation.MyAverage. merge(JavaUserDefinedTypedAggregation.Average b1, JavaUserDefinedTypedAggregation.Average b2)
Merge two intermediate values.JavaUserDefinedTypedAggregation.Average
JavaUserDefinedTypedAggregation.MyAverage. reduce(JavaUserDefinedTypedAggregation.Average buffer, JavaUserDefinedTypedAggregation.Employee employee)
Combine two values to produce a new value.JavaUserDefinedTypedAggregation.Average
JavaUserDefinedTypedAggregation.MyAverage. zero()
A zero value for this aggregation.Methods in org.apache.nemo.examples.spark.sql that return types with arguments of type JavaUserDefinedTypedAggregation.Average Modifier and Type Method Description org.apache.spark.sql.Encoder<JavaUserDefinedTypedAggregation.Average>
JavaUserDefinedTypedAggregation.MyAverage. bufferEncoder()
Specifies the EncoderFactory for the intermediate value type.Methods in org.apache.nemo.examples.spark.sql with parameters of type JavaUserDefinedTypedAggregation.Average Modifier and Type Method Description java.lang.Double
JavaUserDefinedTypedAggregation.MyAverage. finish(JavaUserDefinedTypedAggregation.Average reduction)
Transform the output of the reduction.JavaUserDefinedTypedAggregation.Average
JavaUserDefinedTypedAggregation.MyAverage. merge(JavaUserDefinedTypedAggregation.Average b1, JavaUserDefinedTypedAggregation.Average b2)
Merge two intermediate values.JavaUserDefinedTypedAggregation.Average
JavaUserDefinedTypedAggregation.MyAverage. reduce(JavaUserDefinedTypedAggregation.Average buffer, JavaUserDefinedTypedAggregation.Employee employee)
Combine two values to produce a new value.
-