Uses of Class
org.apache.flink.table.runtime.functions.aggregate.JsonObjectAggFunction.Accumulator
-
Packages that use JsonObjectAggFunction.Accumulator Package Description org.apache.flink.table.runtime.functions.aggregate -
-
Uses of JsonObjectAggFunction.Accumulator in org.apache.flink.table.runtime.functions.aggregate
Methods in org.apache.flink.table.runtime.functions.aggregate that return JsonObjectAggFunction.Accumulator Modifier and Type Method Description JsonObjectAggFunction.AccumulatorJsonObjectAggFunction. createAccumulator()Methods in org.apache.flink.table.runtime.functions.aggregate with parameters of type JsonObjectAggFunction.Accumulator Modifier and Type Method Description voidJsonObjectAggFunction. accumulate(JsonObjectAggFunction.Accumulator acc, org.apache.flink.table.data.StringData keyData, org.apache.flink.table.data.StringData valueData)StringJsonObjectAggFunction. getValue(JsonObjectAggFunction.Accumulator acc)voidJsonObjectAggFunction. merge(JsonObjectAggFunction.Accumulator acc, Iterable<JsonObjectAggFunction.Accumulator> others)voidJsonObjectAggFunction. resetAccumulator(JsonObjectAggFunction.Accumulator acc)voidJsonObjectAggFunction. retract(JsonObjectAggFunction.Accumulator acc, org.apache.flink.table.data.StringData keyData, org.apache.flink.table.data.StringData valueData)Method parameters in org.apache.flink.table.runtime.functions.aggregate with type arguments of type JsonObjectAggFunction.Accumulator Modifier and Type Method Description voidJsonObjectAggFunction. merge(JsonObjectAggFunction.Accumulator acc, Iterable<JsonObjectAggFunction.Accumulator> others)
-