org.apache.flink.table.runtime.functions.aggregate

Class JsonArrayAggFunction

java.lang.Object

org.apache.flink.table.functions.UserDefinedFunction

org.apache.flink.table.functions.ImperativeAggregateFunction<T,ACC>

org.apache.flink.table.functions.AggregateFunction<T,ACC>

org.apache.flink.table.runtime.functions.aggregate.BuiltInAggregateFunction<String,JsonArrayAggFunction.Accumulator>

org.apache.flink.table.runtime.functions.aggregate.JsonArrayAggFunction

All Implemented Interfaces:

Serializable, FunctionDefinition

@Internal
public class JsonArrayAggFunction
extends BuiltInAggregateFunction<String,JsonArrayAggFunction.Accumulator>

Implementation for BuiltInFunctionDefinitions.JSON_ARRAYAGG_ABSENT_ON_NULL / BuiltInFunctionDefinitions.JSON_ARRAYAGG_NULL_ON_NULL.

Note that this function only ever receives strings to accumulate because WrapJsonAggFunctionArgumentsRule wraps arguments into BuiltInFunctionDefinitions.JSON_STRING.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JsonArrayAggFunction.Accumulator Accumulator for JsonArrayAggFunction.

Constructor Summary

Constructors

Constructor and Description
JsonArrayAggFunction(LogicalType[] argumentTypes, boolean skipNulls)

Method Summary

Modifier and Type	Method and Description
void	accumulate(JsonArrayAggFunction.Accumulator acc, StringData itemData)
JsonArrayAggFunction.Accumulator	createAccumulator() Creates and initializes the accumulator for this ImperativeAggregateFunction.
DataType	getAccumulatorDataType()
List<DataType>	getArgumentDataTypes()
DataType	getOutputDataType()
String	getValue(JsonArrayAggFunction.Accumulator acc) Called every time when an aggregation result should be materialized.
void	resetAccumulator(JsonArrayAggFunction.Accumulator acc)
void	retract(JsonArrayAggFunction.Accumulator acc, StringData itemData)

Methods inherited from class org.apache.flink.table.runtime.functions.aggregate.BuiltInAggregateFunction

getRequirements, getTypeInference, isDeterministic

Methods inherited from class org.apache.flink.table.functions.AggregateFunction

getKind

Methods inherited from class org.apache.flink.table.functions.ImperativeAggregateFunction

getAccumulatorType, getResultType

Methods inherited from class org.apache.flink.table.functions.UserDefinedFunction

close, functionIdentifier, open, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonArrayAggFunction

public JsonArrayAggFunction(LogicalType[] argumentTypes,
                            boolean skipNulls)

Method Detail

getArgumentDataTypes

public List<DataType> getArgumentDataTypes()

Overrides:

getArgumentDataTypes in class BuiltInAggregateFunction<String,JsonArrayAggFunction.Accumulator>

getOutputDataType

public DataType getOutputDataType()

Overrides:

getOutputDataType in class BuiltInAggregateFunction<String,JsonArrayAggFunction.Accumulator>

getAccumulatorDataType

public DataType getAccumulatorDataType()

Overrides:

getAccumulatorDataType in class BuiltInAggregateFunction<String,JsonArrayAggFunction.Accumulator>

createAccumulator

public JsonArrayAggFunction.Accumulator createAccumulator()

Description copied from class: ImperativeAggregateFunction

Creates and initializes the accumulator for this ImperativeAggregateFunction.

The accumulator is an intermediate data structure that stores the aggregated values until a final aggregation result is computed.

Specified by:

createAccumulator in class ImperativeAggregateFunction<String,JsonArrayAggFunction.Accumulator>

Returns:

the accumulator with the initial value

resetAccumulator

public void resetAccumulator(JsonArrayAggFunction.Accumulator acc)

accumulate

public void accumulate(JsonArrayAggFunction.Accumulator acc,
                       StringData itemData)
                throws Exception

Throws:

Exception

retract

public void retract(JsonArrayAggFunction.Accumulator acc,
                    StringData itemData)
             throws Exception

Throws:

Exception

getValue

public String getValue(JsonArrayAggFunction.Accumulator acc)

Description copied from class: AggregateFunction

Called every time when an aggregation result should be materialized. The returned value could be either an early and incomplete result (periodically emitted as data arrives) or the final result of the aggregation.

Specified by:

getValue in class AggregateFunction<String,JsonArrayAggFunction.Accumulator>

Parameters:

acc - the accumulator which contains the current intermediate results

Returns:

the aggregation result