Merge branch 'feature/aggregate' into 'develop'

[improve][core]aggregate processor增加window_timestamp_field配置

See merge request galaxy/platform/groot-stream!85

1 files changed, 6 insertions, 0 deletions

diff --git a/groot-common/src/main/java/com/geedgenetworks/common/config/AggregateConfigOptions.java b/groot-common/src/main/java/com/geedgenetworks/common/config/AggregateConfigOptions.java
index 3998a3b..0b0379d 100644
--- a/groot-common/src/main/java/com/geedgenetworks/common/config/AggregateConfigOptions.java
+++ b/groot-common/src/main/java/com/geedgenetworks/common/config/AggregateConfigOptions.java
@@ -5,6 +5,8 @@ import com.geedgenetworks.common.udf.UDFContext;
 
 import java.util.List;
 
+import static com.geedgenetworks.common.Event.WINDOW_START_TIMESTAMP;
+
 public interface AggregateConfigOptions {
     Option<String> TYPE = Options.key("type")
             .stringType()
@@ -46,4 +48,8 @@ public interface AggregateConfigOptions {
             .noDefaultValue()
             .withDescription("The size of sliding window.");
 
+    Option<String> WINDOW_TIMESTAMP_FIELD = Options.key("window_timestamp_field")
+            .stringType()
+            .noDefaultValue()
+            .withDescription("which field to be set the start time of window.");
 }