Aggregatefunction any supports changelog

src/AggregateFunctions/Streaming/AggregateFunctionAny.cpp

@@ -0,0 +1,41 @@
+#include <AggregateFunctions/AggregateFunctionFactory.h>
+#include <AggregateFunctions/Streaming/AggregateFunctionMinMaxAny.h>
+#include <AggregateFunctions/Streaming/HelpersMinMaxAny.h>
+
+#include <string>
+
+namespace DB
+{
+namespace Streaming
+{
+AggregateFunctionPtr createAggregateFunctionAnyLast(
+    const std::string & name, const DataTypes & argument_types, const Array & parameters, const Settings * settings)
+{
+    return AggregateFunctionPtr(createAggregateFunctionSingleValue<AggregateFunctionsSingleValue, AggregateFunctionAnyLastData>(
+        name, argument_types, parameters, settings));
+}
+
+AggregateFunctionPtr
+createAggregateFunctionAny(const std::string & name, const DataTypes & argument_types, const Array & parameters, const Settings * settings)
+{
+    return AggregateFunctionPtr(createAggregateFunctionSingleValue<AggregateFunctionsSingleValue, AggregateFunctionAnyData>(
+        name, argument_types, parameters, settings));
+}
+
+void registerAggregateFunctionsAnyRetract(AggregateFunctionFactory & factory)
+{
+    /// FIXME:actually there is no retraction at all, we just ignore the data whose delta is -1
+    AggregateFunctionProperties properties = {.returns_default_when_only_null = false, .is_order_dependent = true};
+    factory.registerFunction("any_last_retract", {createAggregateFunctionAnyLast, properties});
+    factory.registerFunction("any_retract", {createAggregateFunctionAny, properties});
+
+    factory.registerFunction("first_value_retract", {createAggregateFunctionAny, properties}, AggregateFunctionFactory::CaseInsensitive);
+
+    factory.registerFunction("last_value_retract", {createAggregateFunctionAnyLast, properties}, AggregateFunctionFactory::CaseInsensitive);
+
+    factory.registerFunction("earliest_retract", {createAggregateFunctionAny, properties}, AggregateFunctionFactory::CaseInsensitive);
+
+    factory.registerFunction("latest_retract", {createAggregateFunctionAnyLast, properties}, AggregateFunctionFactory::CaseInsensitive);
+}
+}
+}

src/AggregateFunctions/Streaming/AggregateFunctionArgMinMax.h

@@ -18,7 +18,7 @@ extern const int ILLEGAL_TYPE_OF_ARGUMENT;
 namespace Streaming
 {
 /// Returns the first arg value found for the minimum/maximum value. Example: arg_max(arg, value).
-/// There are similar problems and trade off as stated in AggregateFunctionsCountedValue in AggregateFunctionMinMax.h
+/// There are similar problems and trade off as stated in AggregateFunctionsCountedValue in AggregateFunctionMinMaxAny.h
 /// In changelog mode, we need not only keep track the unique min/max value, but also need keep track the unique argument
 /// for each unique value. The following is one example how we keep tracking this in data structure
 /// For max sequence (value, arg, delta) and `retract_max = 3`:

src/AggregateFunctions/Streaming/AggregateFunctionMax.cpp

@@ -1,4 +1,4 @@
-#include "HelpersMinMax.h"
+#include "HelpersMinMaxAny.h"
 
 #include <AggregateFunctions/AggregateFunctionFactory.h>
 

src/AggregateFunctions/Streaming/AggregateFunctionMin.cpp

@@ -1,4 +1,4 @@
-#include "HelpersMinMax.h"
+#include "HelpersMinMaxAny.h"
 
 #include <AggregateFunctions/AggregateFunctionFactory.h>