diff options
| -rw-r--r-- | dependency-reduced-pom.xml | 100 | ||||
| -rw-r--r-- | flink-top-task.iml | 173 | ||||
| -rw-r--r-- | src/main/java/com/galaxy/tsg/Toptask.java | 1 | ||||
| -rw-r--r-- | src/main/java/com/galaxy/tsg/function/UserCountWindowResult5.java | 2 |
4 files changed, 3 insertions, 273 deletions
diff --git a/dependency-reduced-pom.xml b/dependency-reduced-pom.xml deleted file mode 100644 index 478178b..0000000 --- a/dependency-reduced-pom.xml +++ /dev/null @@ -1,100 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> - <modelVersion>4.0.0</modelVersion> - <groupId>com.galaxy.tsg</groupId> - <artifactId>flink-top-task</artifactId> - <version>22-02-22</version> - <build> - <plugins> - <plugin> - <artifactId>maven-compiler-plugin</artifactId> - <version>3.8.0</version> - <configuration> - <source>1.8</source> - <target>1.8</target> - <useIncrementalCompilation>false</useIncrementalCompilation> - <compilerArgs> - <arg>-Xpkginfo:always</arg> - </compilerArgs> - </configuration> - </plugin> - <plugin> - <artifactId>maven-shade-plugin</artifactId> - <executions> - <execution> - <id>flink-top-task</id> - <phase>package</phase> - <goals> - <goal>shade</goal> - </goals> - <configuration> - <finalName>flink-top-task-23-02-22</finalName> - <filters> - <filter> - <artifact>*:*</artifact> - <excludes> - <exclude>META-INF</exclude> - </excludes> - </filter> - </filters> - <transformers> - <transformer> - <mainClass>com.galaxy.tsg.Toptask</mainClass> - </transformer> - </transformers> - </configuration> - </execution> - </executions> - </plugin> - </plugins> - </build> - <repositories> - <repository> - <id>nexus</id> - <name>Team Nexus Repository</name> - <url>http://192.168.40.125:8099/content/groups/public</url> - </repository> - </repositories> - <dependencies> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-streaming-java_2.12</artifactId> - <version>1.13.1</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-java</artifactId> - <version>1.13.1</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-core</artifactId> - <version>1.13.1</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-json</artifactId> - <version>1.13.1</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-csv</artifactId> - <version>1.13.1</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-clients_2.11</artifactId> - <version>1.13.1</version> - <scope>provided</scope> - </dependency> - </dependencies> - <properties> - <flink.version>1.13.1</flink.version> - <hadoop.version>2.7.1</hadoop.version> - </properties> -</project> diff --git a/flink-top-task.iml b/flink-top-task.iml deleted file mode 100644 index 425046c..0000000 --- a/flink-top-task.iml +++ /dev/null @@ -1,173 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<module org.jetbrains.idea.maven.project.MavenProjectsManager.isMavenModule="true" type="JAVA_MODULE" version="4"> - <component name="NewModuleRootManager" LANGUAGE_LEVEL="JDK_1_8"> - <output url="file://$MODULE_DIR$/target/classes" /> - <output-test url="file://$MODULE_DIR$/target/test-classes" /> - <content url="file://$MODULE_DIR$"> - <sourceFolder url="file://$MODULE_DIR$/src/main/java" isTestSource="false" /> - <sourceFolder url="file://$MODULE_DIR$/src/main/resources" type="java-resource" /> - <sourceFolder url="file://$MODULE_DIR$/src/test/java" isTestSource="true" /> - <excludeFolder url="file://$MODULE_DIR$/target" /> - </content> - <orderEntry type="inheritedJdk" /> - <orderEntry type="sourceFolder" forTests="false" /> - <orderEntry type="library" name="Maven: com.zdjizhi:galaxy:1.1.0" level="project" /> - <orderEntry type="library" name="Maven: org.apache.commons:commons-lang3:3.4" level="project" /> - <orderEntry type="library" name="Maven: commons-io:commons-io:2.4" level="project" /> - <orderEntry type="library" name="Maven: log4j:log4j:1.2.14" level="project" /> - <orderEntry type="library" name="Maven: joda-time:joda-time:2.10" level="project" /> - <orderEntry type="library" name="Maven: com.maxmind.geoip:geoip-api:1.3.1" level="project" /> - <orderEntry type="library" name="Maven: com.maxmind.geoip2:geoip2:2.12.0" level="project" /> - <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpclient:4.5.5" level="project" /> - <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpcore:4.4.9" level="project" /> - <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-databind:2.9.5" level="project" /> - <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-core:2.9.5" level="project" /> - <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-annotations:2.9.5" level="project" /> - <orderEntry type="library" name="Maven: com.maxmind.db:maxmind-db:1.4.0" level="project" /> - <orderEntry type="library" name="Maven: com.google.guava:guava:23.0" level="project" /> - <orderEntry type="library" name="Maven: com.google.errorprone:error_prone_annotations:2.0.18" level="project" /> - <orderEntry type="library" name="Maven: com.google.j2objc:j2objc-annotations:1.1" level="project" /> - <orderEntry type="library" name="Maven: org.codehaus.mojo:animal-sniffer-annotations:1.14" level="project" /> - <orderEntry type="library" name="Maven: cn.hutool:hutool-all:5.5.2" level="project" /> - <orderEntry type="library" name="Maven: org.slf4j:slf4j-api:1.7.21" level="project" /> - <orderEntry type="library" name="Maven: org.slf4j:slf4j-log4j12:1.7.21" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-streaming-java_2.12:1.13.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-file-sink-common:1.13.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-runtime_2.12:1.13.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-queryable-state-client-java:1.13.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-hadoop-fs:1.13.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-shaded-netty:4.1.49.Final-13.0" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-shaded-jackson:2.12.1-13.0" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-shaded-zookeeper-3:3.4.14-13.0" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.javassist:javassist:3.24.0-GA" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.scala-lang:scala-library:2.12.7" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.typesafe.akka:akka-actor_2.12:2.5.21" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.typesafe:config:1.3.3" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.scala-lang.modules:scala-java8-compat_2.12:0.8.0" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.typesafe.akka:akka-stream_2.12:2.5.21" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.reactivestreams:reactive-streams:1.0.2" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.typesafe:ssl-config-core_2.12:0.3.7" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.scala-lang.modules:scala-parser-combinators_2.12:1.1.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.typesafe.akka:akka-protobuf_2.12:2.5.21" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.typesafe.akka:akka-slf4j_2.12:2.5.21" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.clapper:grizzled-slf4j_2.12:1.3.2" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.github.scopt:scopt_2.12:3.5.0" level="project" /> - <orderEntry type="library" name="Maven: org.xerial.snappy:snappy-java:1.1.8.3" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.twitter:chill_2.12:0.7.6" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.twitter:chill-java:0.7.6" level="project" /> - <orderEntry type="library" name="Maven: org.lz4:lz4-java:1.6.0" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-shaded-guava:18.0-13.0" level="project" /> - <orderEntry type="library" name="Maven: org.apache.commons:commons-math3:3.5" level="project" /> - <orderEntry type="library" name="Maven: com.google.code.findbugs:jsr305:1.3.9" level="project" /> - <orderEntry type="library" name="Maven: org.apache.flink:force-shading:1.13.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-java:1.13.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-core:1.13.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-annotations:1.13.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-metrics-core:1.13.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-shaded-asm-7:7.1-13.0" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.esotericsoftware.kryo:kryo:2.24.0" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.esotericsoftware.minlog:minlog:1.2" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.objenesis:objenesis:2.1" level="project" /> - <orderEntry type="library" name="Maven: commons-collections:commons-collections:3.2.2" level="project" /> - <orderEntry type="library" name="Maven: org.apache.commons:commons-compress:1.20" level="project" /> - <orderEntry type="library" name="Maven: org.apache.flink:flink-connector-kafka_2.12:1.13.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.kafka:kafka-clients:2.4.1" level="project" /> - <orderEntry type="library" name="Maven: com.github.luben:zstd-jni:1.4.3-1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.flink:flink-connector-base:1.13.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.zookeeper:zookeeper:3.4.9" level="project" /> - <orderEntry type="library" name="Maven: jline:jline:0.9.94" level="project" /> - <orderEntry type="library" name="Maven: io.netty:netty:3.10.5.Final" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hbase:hbase-client:2.2.3" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hbase.thirdparty:hbase-shaded-protobuf:2.2.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hbase:hbase-common:2.2.3" level="project" /> - <orderEntry type="library" name="Maven: com.github.stephenc.findbugs:findbugs-annotations:1.3.9-1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hbase:hbase-hadoop-compat:2.2.3" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hbase:hbase-metrics-api:2.2.3" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hbase:hbase-hadoop2-compat:2.2.3" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hbase:hbase-metrics:2.2.3" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hbase:hbase-protocol-shaded:2.2.3" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hbase:hbase-protocol:2.2.3" level="project" /> - <orderEntry type="library" name="Maven: commons-codec:commons-codec:1.10" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hbase.thirdparty:hbase-shaded-miscellaneous:2.2.1" level="project" /> - <orderEntry type="library" name="Maven: com.google.protobuf:protobuf-java:2.5.0" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hbase.thirdparty:hbase-shaded-netty:2.2.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.htrace:htrace-core4:4.2.0-incubating" level="project" /> - <orderEntry type="library" name="Maven: org.jruby.jcodings:jcodings:1.0.18" level="project" /> - <orderEntry type="library" name="Maven: org.jruby.joni:joni:2.1.11" level="project" /> - <orderEntry type="library" name="Maven: io.dropwizard.metrics:metrics-core:3.2.6" level="project" /> - <orderEntry type="library" name="Maven: org.apache.commons:commons-crypto:1.0.0" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hadoop:hadoop-auth:2.8.5" level="project" /> - <orderEntry type="library" name="Maven: com.nimbusds:nimbus-jose-jwt:4.41.1" level="project" /> - <orderEntry type="library" name="Maven: com.github.stephenc.jcip:jcip-annotations:1.0-1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.directory.server:apacheds-kerberos-codec:2.0.0-M15" level="project" /> - <orderEntry type="library" name="Maven: org.apache.directory.server:apacheds-i18n:2.0.0-M15" level="project" /> - <orderEntry type="library" name="Maven: org.apache.directory.api:api-asn1-api:1.0.0-M20" level="project" /> - <orderEntry type="library" name="Maven: org.apache.directory.api:api-util:1.0.0-M20" level="project" /> - <orderEntry type="library" name="Maven: org.apache.curator:curator-framework:2.7.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hadoop:hadoop-common:2.8.5" level="project" /> - <orderEntry type="library" name="Maven: xmlenc:xmlenc:0.52" level="project" /> - <orderEntry type="library" name="Maven: commons-net:commons-net:3.1" level="project" /> - <orderEntry type="library" name="Maven: org.mortbay.jetty:jetty-sslengine:6.1.26" level="project" /> - <orderEntry type="library" name="Maven: commons-logging:commons-logging:1.1.3" level="project" /> - <orderEntry type="library" name="Maven: commons-lang:commons-lang:2.6" level="project" /> - <orderEntry type="library" name="Maven: commons-configuration:commons-configuration:1.6" level="project" /> - <orderEntry type="library" name="Maven: commons-digester:commons-digester:1.8" level="project" /> - <orderEntry type="library" name="Maven: commons-beanutils:commons-beanutils:1.7.0" level="project" /> - <orderEntry type="library" name="Maven: commons-beanutils:commons-beanutils-core:1.8.0" level="project" /> - <orderEntry type="library" name="Maven: org.codehaus.jackson:jackson-core-asl:1.9.13" level="project" /> - <orderEntry type="library" name="Maven: org.codehaus.jackson:jackson-mapper-asl:1.9.13" level="project" /> - <orderEntry type="library" name="Maven: org.apache.avro:avro:1.7.4" level="project" /> - <orderEntry type="library" name="Maven: com.thoughtworks.paranamer:paranamer:2.3" level="project" /> - <orderEntry type="library" name="Maven: com.google.code.gson:gson:2.2.4" level="project" /> - <orderEntry type="library" name="Maven: com.jcraft:jsch:0.1.54" level="project" /> - <orderEntry type="library" name="Maven: org.apache.curator:curator-client:2.7.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.curator:curator-recipes:2.7.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.yetus:audience-annotations:0.5.0" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hadoop:hadoop-client:2.7.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hadoop:hadoop-hdfs:2.7.1" level="project" /> - <orderEntry type="library" name="Maven: org.mortbay.jetty:jetty-util:6.1.26" level="project" /> - <orderEntry type="library" name="Maven: io.netty:netty-all:4.0.23.Final" level="project" /> - <orderEntry type="library" name="Maven: xerces:xercesImpl:2.9.1" level="project" /> - <orderEntry type="library" name="Maven: xml-apis:xml-apis:1.3.04" level="project" /> - <orderEntry type="library" name="Maven: org.apache.htrace:htrace-core:3.1.0-incubating" level="project" /> - <orderEntry type="library" name="Maven: org.fusesource.leveldbjni:leveldbjni-all:1.8" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hadoop:hadoop-mapreduce-client-app:2.7.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hadoop:hadoop-mapreduce-client-common:2.7.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hadoop:hadoop-yarn-client:2.7.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hadoop:hadoop-yarn-server-common:2.7.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hadoop:hadoop-mapreduce-client-shuffle:2.7.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hadoop:hadoop-yarn-api:2.7.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hadoop:hadoop-mapreduce-client-core:2.7.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hadoop:hadoop-yarn-common:2.7.1" level="project" /> - <orderEntry type="library" name="Maven: javax.xml.bind:jaxb-api:2.2.2" level="project" /> - <orderEntry type="library" name="Maven: javax.xml.stream:stax-api:1.0-2" level="project" /> - <orderEntry type="library" name="Maven: javax.activation:activation:1.1" level="project" /> - <orderEntry type="library" name="Maven: com.sun.jersey:jersey-core:1.9" level="project" /> - <orderEntry type="library" name="Maven: com.sun.jersey:jersey-client:1.9" level="project" /> - <orderEntry type="library" name="Maven: org.codehaus.jackson:jackson-jaxrs:1.9.13" level="project" /> - <orderEntry type="library" name="Maven: org.codehaus.jackson:jackson-xc:1.9.13" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hadoop:hadoop-mapreduce-client-jobclient:2.7.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.hadoop:hadoop-annotations:2.7.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-json:1.13.1" level="project" /> - <orderEntry type="library" name="Maven: com.alibaba:fastjson:1.2.70" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-csv:1.13.1" level="project" /> - <orderEntry type="library" name="Maven: com.opencsv:opencsv:3.3" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-clients_2.11:1.13.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-runtime_2.11:1.13.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.typesafe.akka:akka-actor_2.11:2.5.21" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.scala-lang.modules:scala-java8-compat_2.11:0.7.0" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.typesafe.akka:akka-stream_2.11:2.5.21" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.typesafe:ssl-config-core_2.11:0.3.7" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.scala-lang.modules:scala-parser-combinators_2.11:1.1.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.typesafe.akka:akka-protobuf_2.11:2.5.21" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.typesafe.akka:akka-slf4j_2.11:2.5.21" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.clapper:grizzled-slf4j_2.11:1.3.2" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.github.scopt:scopt_2.11:3.5.0" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.twitter:chill_2.11:0.7.6" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-optimizer_2.11:1.13.1" level="project" /> - <orderEntry type="library" name="Maven: commons-cli:commons-cli:1.3.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.flink:flink-streaming-java_2.11:1.13.1" level="project" /> - <orderEntry type="library" name="Maven: org.apache.datasketches:datasketches-java:3.3.0" level="project" /> - <orderEntry type="library" name="Maven: org.apache.datasketches:datasketches-memory:2.1.0" level="project" /> - </component> -</module>
\ No newline at end of file diff --git a/src/main/java/com/galaxy/tsg/Toptask.java b/src/main/java/com/galaxy/tsg/Toptask.java index 1841988..0b31f58 100644 --- a/src/main/java/com/galaxy/tsg/Toptask.java +++ b/src/main/java/com/galaxy/tsg/Toptask.java @@ -238,6 +238,7 @@ public class Toptask { }).assignTimestampsAndWatermarks(strategyForSession); + clientipdStream2.windowAll(TumblingEventTimeWindows.of(Time.minutes(WINDOW_TIME_MINUTE))) .aggregate(new DatasketchForMetricsAggregate("oneSession"), new UserCountWindowResult5()) // .print() diff --git a/src/main/java/com/galaxy/tsg/function/UserCountWindowResult5.java b/src/main/java/com/galaxy/tsg/function/UserCountWindowResult5.java index c98545b..db9f053 100644 --- a/src/main/java/com/galaxy/tsg/function/UserCountWindowResult5.java +++ b/src/main/java/com/galaxy/tsg/function/UserCountWindowResult5.java @@ -55,9 +55,11 @@ public class UserCountWindowResult5 extends ProcessAllWindowFunction<HashMap<Str String jsonStr = ""; if(!entry.getKey().equals("eightSession")){ CollectionValue collectionValue = entry.getValue().getStringCollectionValueHashMap().get(items[i].getItem()); + collectionValue.setStat_time(context.window().getEnd()/1000); jsonStr = JSONObject.toJSONString(collectionValue); }else { TopUrlEntity topUrlEntity = entry.getValue().getStringTopUrlEntityHashMap().get(items[i].getItem()); + topUrlEntity.setStat_time(context.window().getEnd()/1000); jsonStr = JSONObject.toJSONString(topUrlEntity); } |