Package org.apache.beam.sdk.extensions.sql.impl.transform

Class BeamBuiltinAnalyticFunctions

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.transform.BeamBuiltinAnalyticFunctions

public class BeamBuiltinAnalyticFunctions
extends Object

Built-in Analytic Functions for the aggregation analytics functionality.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BeamBuiltinAnalyticFunctions.PositionAwareCombineFn<InputT,AccumT,OutputT>

Field Summary

Fields

Modifier and Type	Field	Description
static final Map<String,Function<Schema.FieldType,Combine.CombineFn<?,?,?>>>	BUILTIN_ANALYTIC_FACTORIES

Constructor Summary

Constructors

Constructor	Description
BeamBuiltinAnalyticFunctions()

Method Summary

Modifier and Type	Method	Description
static Combine.CombineFn<?,?,?>	create(String functionName, Schema.FieldType fieldType)
static <T> Combine.CombineFn<T,?,T>	navigationFirstValue()
static <T> Combine.CombineFn<T,?,T>	navigationLastValue()
static <T> Combine.CombineFn<T,?,T>	numberingDenseRank()
static <T> Combine.CombineFn<T,?,T>	numberingPercentRank()
static <T> Combine.CombineFn<T,?,T>	numberingRank()
static <T> Combine.CombineFn<T,?,T>	numberingRowNumber()

Methods inherited from class java.lang.Object

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

Field Details

BUILTIN_ANALYTIC_FACTORIES

public static final Map<String,Function<Schema.FieldType,Combine.CombineFn<?,?,?>>> BUILTIN_ANALYTIC_FACTORIES

Constructor Details

BeamBuiltinAnalyticFunctions

public BeamBuiltinAnalyticFunctions()

Method Details

create

public static Combine.CombineFn<?,?,?> create(String functionName,
 Schema.FieldType fieldType)

navigationFirstValue

public static <T> Combine.CombineFn<T,?,T> navigationFirstValue()

navigationLastValue

public static <T> Combine.CombineFn<T,?,T> navigationLastValue()

numberingRowNumber

public static <T> Combine.CombineFn<T,?,T> numberingRowNumber()

numberingDenseRank

public static <T> Combine.CombineFn<T,?,T> numberingDenseRank()

numberingRank

public static <T> Combine.CombineFn<T,?,T> numberingRank()

numberingPercentRank

public static <T> Combine.CombineFn<T,?,T> numberingPercentRank()