Package | Description |
---|---|
org.apache.flink.table.planner.functions.aggfunctions |
Modifier and Type | Method and Description |
---|---|
ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator |
ListAggWsWithRetractAggFunction.createAccumulator() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator> |
ListAggWsWithRetractAggFunction.getAccumulatorType() |
Modifier and Type | Method and Description |
---|---|
void |
ListAggWsWithRetractAggFunction.accumulate(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc,
StringData value,
StringData lineDelimiter) |
StringData |
ListAggWsWithRetractAggFunction.getValue(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc) |
void |
ListAggWsWithRetractAggFunction.merge(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc,
Iterable<ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator> its) |
void |
ListAggWsWithRetractAggFunction.resetAccumulator(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc) |
void |
ListAggWsWithRetractAggFunction.retract(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc,
StringData value,
StringData lineDelimiter) |
Modifier and Type | Method and Description |
---|---|
void |
ListAggWsWithRetractAggFunction.merge(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc,
Iterable<ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator> its) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.