Flink操练（四十二）之统计每个窗口中最热门的商品

　　完整代码逻辑package day04;  import org.apache.flink.api.common.eventtime.SerializableTimestampAssigner; import org.apache.flink.api.common.eventtime.WatermarkStrategy; import org.apache.flink.api.common.functions.AggregateFunction; import org.apache.flink.api.common.functions.MapFunction; import org.apache.flink.api.common.state.ListState; import org.apache.flink.api.common.state.ListStateDescriptor; import org.apache.flink.api.common.typeinfo.Types; import org.apache.flink.configuration.Configuration; import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.api.datastream.DataStreamSource; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.streaming.api.functions.KeyedProcessFunction; import org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction; import org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows; import org.apache.flink.streaming.api.windowing.time.Time; import org.apache.flink.streaming.api.windowing.windows.TimeWindow; import org.apache.flink.util.Collector;  import java.sql.Timestamp; import java.time.Duration; import java.util.ArrayList; import java.util.Comparator;  /**  * @program: bigData_learn  * @description: 每个窗口中最热门的商品是什么  * @author: Mr.逗  * @create: 2021-09-24 09:44  **/ public class MostPopularProductByWindow {     public static class UserBehavior {         public String userId;         public String itemId;         public String categoryId;         public String behavior;         public Long timestamp;          public UserBehavior() {         }          public UserBehavior(String userId, String itemId, String categoryId, String behavior, Long timestamp) {             this.userId = userId;             this.itemId = itemId;             this.categoryId = categoryId;             this.behavior = behavior;             this.timestamp = timestamp;         }          @Override         public String toString() {             return ＂UserBehavior{＂ +                     ＂userId=＂＂ + userId + ＂＂＂ +                     ＂, itemId=＂＂ + itemId + ＂＂＂ +                     ＂, categoryId=＂＂ + categoryId + ＂＂＂ +                     ＂, behavior=＂＂ + behavior + ＂＂＂ +                     ＂, timestamp=＂ + new Timestamp(timestamp) +                     ＂}＂;         }     }     // 每个商品在每个窗口中的浏览次数     public static class ItemViewCount {         public String itemId;         public Long count;         public Long windowStart;         public Long windowEnd;          public ItemViewCount() {         }          public ItemViewCount(String itemId, Long count, Long windowStart, Long windowEnd) {             this.itemId = itemId;             this.count = count;             this.windowStart = windowStart;             this.windowEnd = windowEnd;         }          @Override         public String toString() {             return ＂ItemViewCount{＂ +                     ＂itemId=＂＂ + itemId + ＂＂＂ +                     ＂, count=＂ + count +                     ＂, windowStart=＂ + new Timestamp(windowStart) +                     ＂, windowEnd=＂ + new Timestamp(windowEnd) +                     ＂}＂;         }     }     /**     * @Description: 聚合窗口计算     * @Param:     * @return:     * @Author: Mr.逗     * @Date: 2021/9/24     */     public static class CountAgg implements AggregateFunction {         //创建累加器         @Override         public Long createAccumulator() {             return 0L;         }         //自定义累加规则         @Override         public Long add(UserBehavior userBehavior, Long accumulator) {             return accumulator+1;         }         //获取结果         @Override         public Long getResult(Long accumulator) {             return accumulator;         }          @Override         public Long merge(Long aLong, Long acc1) {             return null;         }     }     //全窗口结果     public static class WindowResult extends ProcessWindowFunction     {          @Override         public void process(String s, Context context, Iterable it, Collector out) throws Exception {             out.collect(                     new ItemViewCount(s,it.iterator().next(),context.window().getStart(),context.window().getEnd())             );         }     }     //TopN     public static class TopN extends KeyedProcessFunction {         private ListState listState;         private Integer n;          public TopN(Integer n) {             this.n = n;         }          @Override         public void open(Configuration parameters) throws Exception {             super.open(parameters);             listState=getRuntimeContext().getListState(new ListStateDescriptor(                     ＂list-state＂                     ,Types.POJO(ItemViewCount.class)             ));         }          @Override         public void processElement(ItemViewCount value, Context ctx, Collector out) throws Exception {             listState.add(value);             ctx.timerService().registerEventTimeTimer(value.windowEnd+1L);         }          @Override         public void onTimer(long timestamp, OnTimerContext ctx, Collector out) throws Exception {             super.onTimer(timestamp, ctx, out);             ArrayList itemViewCountArrayList = new ArrayList<>();             for(ItemViewCount ivc:listState.get())             {                 itemViewCountArrayList.add(ivc);             }             listState.clear();             itemViewCountArrayList.sort(new Comparator() {                 @Override                 public int compare(ItemViewCount o1, ItemViewCount o2) {                     return o1.count.intValue() - o2.count.intValue();                 }             });             StringBuilder result = new StringBuilder();             result                     .append(＂============================================== ＂)                     .append(＂窗口结束时间：＂ + new Timestamp(timestamp - 1L))                     .append(＂ ＂);             for (int i = 0; i < n; i++) {                 ItemViewCount curr = itemViewCountArrayList.get(i);                 result                         .append(＂第＂ + (i + 1) + ＂名的商品id是：＂ + curr.itemId)                         .append(＂，浏览次数是：＂ + curr.count)                         .append(＂ ＂);             }             result                     .append(＂===============================================  ＂);             out.collect(result.toString());         }     }     public static void main(String[] args) {         StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();         env.setParallelism(1);         DataStreamSource source = env.readTextFile(＂G:/bigData_learn/Flink_learn/src/main/resources/UserBehavior.csv＂);         DataStream map = source.map(new MapFunction() {             @Override             public UserBehavior map(String value) throws Exception {                 String[] arr = value.split(＂,＂);                 return new UserBehavior(                         arr[0], arr[1], arr[2], arr[3], Long.parseLong(arr[4]) * 1000L                 );             }         });         DataStream watermarks = map.filter(v -> v.behavior.equals(＂pv＂))                 .assignTimestampsAndWatermarks(                         WatermarkStrategy.forBoundedOutOfOrderness(Duration.ofSeconds(0))                                 .withTimestampAssigner(new SerializableTimestampAssigner() {                                     @Override                                     public long extractTimestamp(UserBehavior v, long recordTimestamp) {                                         return v.timestamp;                                     }                                 })                 );         watermarks.keyBy(v->v.itemId)                 .window(SlidingEventTimeWindows.of(Time.hours(1),Time.minutes(5)))                 .aggregate(new CountAgg(),new WindowResult())                 .keyBy(v->v.windowEnd)                 .process(new TopN(3))                 .print();         String name = MostPopularProductByWindow.class.getName();         try {             env.execute(name);         }catch (Exception e)         {             e.printStackTrace();         }      } } 结果展示＂C:Program FilesJavajdk1.8.0_191binjava.exe＂ ＂-javaagent:F:appIntelliJ IDEA 2019.3.3libidea_rt.jar=55029:F:appIntelliJ IDEA 2019.3.3bin＂ -Dfile.encoding=UTF-8 -classpath ＂C:Program FilesJavajdk1.8.0_191jrelibcharsets.jar;C:Program FilesJavajdk1.8.0_191jrelibdeploy.jar;C:Program FilesJavajdk1.8.0_191jrelibextaccess-bridge-64.jar;C:Program FilesJavajdk1.8.0_191jrelibextcldrdata.jar;C:Program FilesJavajdk1.8.0_191jrelibextdnsns.jar;C:Program FilesJavajdk1.8.0_191jrelibextjaccess.jar;C:Program FilesJavajdk1.8.0_191jrelibextjfxrt.jar;C:Program FilesJavajdk1.8.0_191jrelibextlocaledata.jar;C:Program FilesJavajdk1.8.0_191jrelibext ashorn.jar;C:Program FilesJavajdk1.8.0_191jrelibextsunec.jar;C:Program FilesJavajdk1.8.0_191jrelibextsunjce_provider.jar;C:Program FilesJavajdk1.8.0_191jrelibextsunmscapi.jar;C:Program FilesJavajdk1.8.0_191jrelibextsunpkcs11.jar;C:Program FilesJavajdk1.8.0_191jrelibextzipfs.jar;C:Program FilesJavajdk1.8.0_191jrelibjavaws.jar;C:Program FilesJavajdk1.8.0_191jrelibjce.jar;C:Program FilesJavajdk1.8.0_191jrelibjfr.jar;C:Program FilesJavajdk1.8.0_191jrelibjfxswt.jar;C:Program FilesJavajdk1.8.0_191jrelibjsse.jar;C:Program FilesJavajdk1.8.0_191jrelibmanagement-agent.jar;C:Program FilesJavajdk1.8.0_191jrelibplugin.jar;C:Program FilesJavajdk1.8.0_191jrelibresources.jar;C:Program FilesJavajdk1.8.0_191jrelibrt.jar;G:bigData_learnFlink_learn	argetclasses;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-java1.13.0flink-java-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-core1.13.0flink-core-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-annotations1.13.0flink-annotations-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-metrics-core1.13.0flink-metrics-core-1.13.0.jar;G:appapache-maven-3.6.3maven-repositorycomesotericsoftwarekryokryo2.24.0kryo-2.24.0.jar;G:appapache-maven-3.6.3maven-repositorycomesotericsoftwareminlogminlog1.2minlog-1.2.jar;G:appapache-maven-3.6.3maven-repositoryorgobjenesisobjenesis2.1objenesis-2.1.jar;G:appapache-maven-3.6.3maven-repositorycommons-collectionscommons-collections3.2.2commons-collections-3.2.2.jar;G:appapache-maven-3.6.3maven-repositoryorgapachecommonscommons-compress1.20commons-compress-1.20.jar;G:appapache-maven-3.6.3maven-repositoryorgapachecommonscommons-lang33.3.2commons-lang3-3.3.2.jar;G:appapache-maven-3.6.3maven-repositoryorgapachecommonscommons-math33.5commons-math3-3.5.jar;G:appapache-maven-3.6.3maven-repositoryorgslf4jslf4j-api1.7.15slf4j-api-1.7.15.jar;G:appapache-maven-3.6.3maven-repositorycomgooglecodefindbugsjsr3051.3.9jsr305-1.3.9.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkforce-shading1.13.0force-shading-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-streaming-java_2.121.13.0flink-streaming-java_2.12-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-file-sink-common1.13.0flink-file-sink-common-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-runtime_2.121.13.0flink-runtime_2.12-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-queryable-state-client-java1.13.0flink-queryable-state-client-java-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-hadoop-fs1.13.0flink-hadoop-fs-1.13.0.jar;G:appapache-maven-3.6.3maven-repositorycommons-iocommons-io2.7commons-io-2.7.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-shaded-netty4.1.49.Final-13.0flink-shaded-netty-4.1.49.Final-13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-shaded-jackson2.12.1-13.0flink-shaded-jackson-2.12.1-13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-shaded-zookeeper-33.4.14-13.0flink-shaded-zookeeper-3-3.4.14-13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgjavassistjavassist3.24.0-GAjavassist-3.24.0-GA.jar;G:appapache-maven-3.6.3maven-repositorycom	ypesafeakkaakka-actor_2.122.5.21akka-actor_2.12-2.5.21.jar;G:appapache-maven-3.6.3maven-repositorycom	ypesafeconfig1.3.3config-1.3.3.jar;G:appapache-maven-3.6.3maven-repositoryorgscala-langmodulesscala-java8-compat_2.12.8.0scala-java8-compat_2.12-0.8.0.jar;G:appapache-maven-3.6.3maven-repositorycom	ypesafeakkaakka-stream_2.122.5.21akka-stream_2.12-2.5.21.jar;G:appapache-maven-3.6.3maven-repositoryorgreactivestreamsreactive-streams1.0.2reactive-streams-1.0.2.jar;G:appapache-maven-3.6.3maven-repositorycom	ypesafessl-config-core_2.12.3.7ssl-config-core_2.12-0.3.7.jar;G:appapache-maven-3.6.3maven-repositoryorgscala-langmodulesscala-parser-combinators_2.121.1.1scala-parser-combinators_2.12-1.1.1.jar;G:appapache-maven-3.6.3maven-repositorycom	ypesafeakkaakka-protobuf_2.122.5.21akka-protobuf_2.12-2.5.21.jar;G:appapache-maven-3.6.3maven-repositorycom	ypesafeakkaakka-slf4j_2.122.5.21akka-slf4j_2.12-2.5.21.jar;G:appapache-maven-3.6.3maven-repositoryorgclappergrizzled-slf4j_2.121.3.2grizzled-slf4j_2.12-1.3.2.jar;G:appapache-maven-3.6.3maven-repositorycomgithubscoptscopt_2.123.5.0scopt_2.12-3.5.0.jar;G:appapache-maven-3.6.3maven-repositoryorgxerialsnappysnappy-java1.1.8.3snappy-java-1.1.8.3.jar;G:appapache-maven-3.6.3maven-repositorycom	witterchill_2.12.7.6chill_2.12-0.7.6.jar;G:appapache-maven-3.6.3maven-repositorycom	witterchill-java.7.6chill-java-0.7.6.jar;G:appapache-maven-3.6.3maven-repositoryorglz4lz4-java1.6.0lz4-java-1.6.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-shaded-guava18.0-13.0flink-shaded-guava-18.0-13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-clients_2.121.13.0flink-clients_2.12-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-optimizer_2.121.13.0flink-optimizer_2.12-1.13.0.jar;G:appapache-maven-3.6.3maven-repositorycommons-clicommons-cli1.3.1commons-cli-1.3.1.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-table-api-java-bridge_2.121.13.0flink-table-api-java-bridge_2.12-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-table-api-java1.13.0flink-table-api-java-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-table-planner-blink_2.121.13.0flink-table-planner-blink_2.12-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-table-api-scala_2.121.13.0flink-table-api-scala_2.12-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-table-api-scala-bridge_2.121.13.0flink-table-api-scala-bridge_2.12-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-table-runtime-blink_2.121.13.0flink-table-runtime-blink_2.12-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgcodehausjaninojanino3.0.11janino-3.0.11.jar;G:appapache-maven-3.6.3maven-repositoryorgcodehausjaninocommons-compiler3.0.11commons-compiler-3.0.11.jar;G:appapache-maven-3.6.3maven-repositoryorgapachecalciteavaticaavatica-core1.17.0avatica-core-1.17.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-streaming-scala_2.121.13.0flink-streaming-scala_2.12-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-scala_2.121.13.0flink-scala_2.12-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgscala-langscala-reflect2.12.7scala-reflect-2.12.7.jar;G:appapache-maven-3.6.3maven-repositoryorgscala-langscala-library2.12.7scala-library-2.12.7.jar;G:appapache-maven-3.6.3maven-repositoryorgscala-langscala-compiler2.12.7scala-compiler-2.12.7.jar;G:appapache-maven-3.6.3maven-repositoryorgscala-langmodulesscala-xml_2.121.0.6scala-xml_2.12-1.0.6.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-table-common1.13.0flink-table-common-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-connector-files1.13.0flink-connector-files-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-shaded-asm-77.1-13.0flink-shaded-asm-7-7.1-13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-cep_2.121.13.0flink-cep_2.12-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-csv1.13.0flink-csv-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-connector-kafka_2.121.13.0flink-connector-kafka_2.12-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapachekafkakafka-clients2.4.1kafka-clients-2.4.1.jar;G:appapache-maven-3.6.3maven-repositorycomgithublubenzstd-jni1.4.3-1zstd-jni-1.4.3-1.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-connector-base1.13.0flink-connector-base-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapachebahirflink-connector-redis_2.111.0flink-connector-redis_2.11-1.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-streaming-java_2.111.2.0flink-streaming-java_2.11-1.2.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-runtime_2.111.2.0flink-runtime_2.11-1.2.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-shaded-hadoop21.2.0flink-shaded-hadoop2-1.2.0.jar;G:appapache-maven-3.6.3maven-repositoryorg	ukaanixz1.0xz-1.0.jar;G:appapache-maven-3.6.3maven-repositoryxmlencxmlenc.52xmlenc-0.52.jar;G:appapache-maven-3.6.3maven-repositorycommons-codeccommons-codec1.4commons-codec-1.4.jar;G:appapache-maven-3.6.3maven-repositorycommons-netcommons-net3.1commons-net-3.1.jar;G:appapache-maven-3.6.3maven-repositoryjavaxservletservlet-api2.5servlet-api-2.5.jar;G:appapache-maven-3.6.3maven-repositoryorgmortbayjettyjetty-util6.1.26jetty-util-6.1.26.jar;G:appapache-maven-3.6.3maven-repositorycomsunjerseyjersey-core1.9jersey-core-1.9.jar;G:appapache-maven-3.6.3maven-repositorycommons-elcommons-el1.0commons-el-1.0.jar;G:appapache-maven-3.6.3maven-repositorycommons-loggingcommons-logging1.1.3commons-logging-1.1.3.jar;G:appapache-maven-3.6.3maven-repositorycomjamesmurtyutilsjava-xmlbuilder.4java-xmlbuilder-0.4.jar;G:appapache-maven-3.6.3maven-repositorycommons-langcommons-lang2.6commons-lang-2.6.jar;G:appapache-maven-3.6.3maven-repositorycommons-configurationcommons-configuration1.7commons-configuration-1.7.jar;G:appapache-maven-3.6.3maven-repositorycommons-digestercommons-digester1.8.1commons-digester-1.8.1.jar;G:appapache-maven-3.6.3maven-repositoryorgcodehausjacksonjackson-core-asl1.8.8jackson-core-asl-1.8.8.jar;G:appapache-maven-3.6.3maven-repositoryorgcodehausjacksonjackson-mapper-asl1.8.8jackson-mapper-asl-1.8.8.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheavroavro1.7.7avro-1.7.7.jar;G:appapache-maven-3.6.3maven-repositorycom	houghtworksparanamerparanamer2.3paranamer-2.3.jar;G:appapache-maven-3.6.3maven-repositorycomjcraftjsch.1.42jsch-0.1.42.jar;G:appapache-maven-3.6.3maven-repositorycommons-beanutilscommons-beanutils-bean-collections1.8.3commons-beanutils-bean-collections-1.8.3.jar;G:appapache-maven-3.6.3maven-repositorycommons-daemoncommons-daemon1.0.13commons-daemon-1.0.13.jar;G:appapache-maven-3.6.3maven-repositoryjavaxxmlbindjaxb-api2.2.2jaxb-api-2.2.2.jar;G:appapache-maven-3.6.3maven-repositoryjavaxxmlstreamstax-api1.0-2stax-api-1.0-2.jar;G:appapache-maven-3.6.3maven-repositoryjavaxactivationactivation1.1activation-1.1.jar;G:appapache-maven-3.6.3maven-repositoryio etty etty-all4.0.27.Final etty-all-4.0.27.Final.jar;G:appapache-maven-3.6.3maven-repositorycomdata-artisansflakka-actor_2.112.3-customflakka-actor_2.11-2.3-custom.jar;G:appapache-maven-3.6.3maven-repositorycomdata-artisansflakka-remote_2.112.3-customflakka-remote_2.11-2.3-custom.jar;G:appapache-maven-3.6.3maven-repositoryio etty etty3.8.0.Final etty-3.8.0.Final.jar;G:appapache-maven-3.6.3maven-repositoryorguncommonsmathsuncommons-maths1.2.2auncommons-maths-1.2.2a.jar;G:appapache-maven-3.6.3maven-repositorycomdata-artisansflakka-slf4j_2.112.3-customflakka-slf4j_2.11-2.3-custom.jar;G:appapache-maven-3.6.3maven-repositoryorgclappergrizzled-slf4j_2.111.0.2grizzled-slf4j_2.11-1.0.2.jar;G:appapache-maven-3.6.3maven-repositorycomgithubscoptscopt_2.113.2.0scopt_2.11-3.2.0.jar;G:appapache-maven-3.6.3maven-repositorycomfasterxmljacksoncorejackson-core2.7.4jackson-core-2.7.4.jar;G:appapache-maven-3.6.3maven-repositorycomfasterxmljacksoncorejackson-databind2.7.4jackson-databind-2.7.4.jar;G:appapache-maven-3.6.3maven-repositorycomfasterxmljacksoncorejackson-annotations2.7.0jackson-annotations-2.7.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapachezookeeperzookeeper3.4.6zookeeper-3.4.6.jar;G:appapache-maven-3.6.3maven-repositoryjlinejline.9.94jline-0.9.94.jar;G:appapache-maven-3.6.3maven-repositoryjunitjunit3.8.1junit-3.8.1.jar;G:appapache-maven-3.6.3maven-repositorycom	witterchill_2.11.7.4chill_2.11-0.7.4.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-clients_2.111.2.0flink-clients_2.11-1.2.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-optimizer_2.111.2.0flink-optimizer_2.11-1.2.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheslingorg.apache.sling.commons.json2.0.6org.apache.sling.commons.json-2.0.6.jar;G:appapache-maven-3.6.3maven-repositorymysqlmysql-connector-java8.0.21mysql-connector-java-8.0.21.jar;G:appapache-maven-3.6.3maven-repositorycomgoogleprotobufprotobuf-java3.11.4protobuf-java-3.11.4.jar;G:appapache-maven-3.6.3maven-repositoryorgapacheflinkflink-connector-jdbc_2.121.13.0flink-connector-jdbc_2.12-1.13.0.jar;G:appapache-maven-3.6.3maven-repositoryorgslf4jslf4j-log4j121.7.30slf4j-log4j12-1.7.30.jar;G:appapache-maven-3.6.3maven-repositorylog4jlog4j1.2.17log4j-1.2.17.jar;G:appapache-maven-3.6.3maven-repositoryorgapachelogginglog4jlog4j-to-slf4j2.14.0log4j-to-slf4j-2.14.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapachelogginglog4jlog4j-api2.14.0log4j-api-2.14.0.jar;G:appapache-maven-3.6.3maven-repositoryredisclientsjedis2.9.0jedis-2.9.0.jar;G:appapache-maven-3.6.3maven-repositoryorgapachecommonscommons-pool22.4.2commons-pool2-2.4.2.jar;G:appapache-maven-3.6.3maven-repositorycomgooglecodegsongson2.8.5gson-2.8.5.jar＂ day04.MostPopularProductByWindow log4j:WARN No appenders could be found for logger (org.apache.flink.api.java.typeutils.TypeExtractor). log4j:WARN Please initialize the log4j system properly. log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info. ============================================== 窗口结束时间：2017-11-26 09:05:00.0 第1名的商品id是：1715，浏览次数是：1 第2名的商品id是：3611281，浏览次数是：1 第3名的商品id是：942195，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 09:10:00.0 第1名的商品id是：26072，浏览次数是：1 第2名的商品id是：1214771，浏览次数是：1 第3名的商品id是：5027001，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 09:15:00.0 第1名的商品id是：5027001，浏览次数是：1 第2名的商品id是：1214771，浏览次数是：1 第3名的商品id是：4764374，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 09:20:00.0 第1名的商品id是：1214771，浏览次数是：1 第2名的商品id是：5027001，浏览次数是：1 第3名的商品id是：4764374，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 09:25:00.0 第1名的商品id是：1214771，浏览次数是：1 第2名的商品id是：5027001，浏览次数是：1 第3名的商品id是：1926022，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 09:30:00.0 第1名的商品id是：1214771，浏览次数是：1 第2名的商品id是：1715，浏览次数是：1 第3名的商品id是：1926022，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 09:35:00.0 第1名的商品id是：1214771，浏览次数是：1 第2名的商品id是：1926022，浏览次数是：1 第3名的商品id是：4832545，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 09:40:00.0 第1名的商品id是：26072，浏览次数是：1 第2名的商品id是：1926022，浏览次数是：1 第3名的商品id是：4866351，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 09:45:00.0 第1名的商品id是：4495168，浏览次数是：1 第2名的商品id是：1872142，浏览次数是：1 第3名的商品id是：1926022，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 09:50:00.0 第1名的商品id是：1926022，浏览次数是：1 第2名的商品id是：1872142，浏览次数是：1 第3名的商品id是：1937464，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 09:55:00.0 第1名的商品id是：1926022，浏览次数是：1 第2名的商品id是：1872142，浏览次数是：1 第3名的商品id是：2764196，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 10:00:00.0 第1名的商品id是：1715，浏览次数是：1 第2名的商品id是：1926022，浏览次数是：1 第3名的商品id是：1872142，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 10:05:00.0 第1名的商品id是：1926022，浏览次数是：1 第2名的商品id是：1872142，浏览次数是：1 第3名的商品id是：4254351，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 10:10:00.0 第1名的商品id是：1872142，浏览次数是：1 第2名的商品id是：2764196，浏览次数是：1 第3名的商品id是：1740710，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 10:15:00.0 第1名的商品id是：1872142，浏览次数是：1 第2名的商品id是：3878753，浏览次数是：1 第3名的商品id是：3177547，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 10:20:00.0 第1名的商品id是：2125378，浏览次数是：1 第2名的商品id是：1893561，浏览次数是：1 第3名的商品id是：2888394，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 10:25:00.0 第1名的商品id是：133272，浏览次数是：1 第2名的商品id是：1893561，浏览次数是：1 第3名的商品id是：2243084，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 10:30:00.0 第1名的商品id是：1893561，浏览次数是：1 第2名的商品id是：605099，浏览次数是：1 第3名的商品id是：2714987，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 10:35:00.0 第1名的商品id是：1893561，浏览次数是：1 第2名的商品id是：335853，浏览次数是：1 第3名的商品id是：2714987，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 10:40:00.0 第1名的商品id是：2714987，浏览次数是：1 第2名的商品id是：547062，浏览次数是：1 第3名的商品id是：2300809，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 10:45:00.0 第1名的商品id是：1901552，浏览次数是：1 第2名的商品id是：2243084，浏览次数是：1 第3名的商品id是：547062，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 10:50:00.0 第1名的商品id是：2070855，浏览次数是：1 第2名的商品id是：547062，浏览次数是：1 第3名的商品id是：2162935，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 10:55:00.0 第1名的商品id是：547062，浏览次数是：1 第2名的商品id是：2076557，浏览次数是：1 第3名的商品id是：1461407，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 11:00:00.0 第1名的商品id是：2682512，浏览次数是：1 第2名的商品id是：547062，浏览次数是：1 第3名的商品id是：2714987，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 11:05:00.0 第1名的商品id是：547062，浏览次数是：1 第2名的商品id是：4288621，浏览次数是：1 第3名的商品id是：4843772，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 11:10:00.0 第1名的商品id是：1825144，浏览次数是：1 第2名的商品id是：547062，浏览次数是：1 第3名的商品id是：2560087，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 11:15:00.0 第1名的商品id是：547062，浏览次数是：1 第2名的商品id是：4938455，浏览次数是：1 第3名的商品id是：3685517，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 11:20:00.0 第1名的商品id是：5039901，浏览次数是：1 第2名的商品id是：4517350，浏览次数是：1 第3名的商品id是：1711003，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 11:25:00.0 第1名的商品id是：703437，浏览次数是：1 第2名的商品id是：1461407，浏览次数是：1 第3名的商品id是：2297621，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 11:30:00.0 第1名的商品id是：2078005，浏览次数是：1 第2名的商品id是：4863774，浏览次数是：1 第3名的商品id是：2422213，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 11:35:00.0 第1名的商品id是：2560087，浏览次数是：1 第2名的商品id是：2422213，浏览次数是：1 第3名的商品id是：485633，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 11:40:00.0 第1名的商品id是：2422213，浏览次数是：1 第2名的商品id是：1734346，浏览次数是：1 第3名的商品id是：485633，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 11:45:00.0 第1名的商品id是：6524，浏览次数是：1 第2名的商品id是：574681，浏览次数是：1 第3名的商品id是：546337，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 11:50:00.0 第1名的商品id是：2422213，浏览次数是：1 第2名的商品id是：1591165，浏览次数是：1 第3名的商品id是：602145，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 11:55:00.0 第1名的商品id是：905609，浏览次数是：1 第2名的商品id是：4164690，浏览次数是：1 第3名的商品id是：4611037，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 12:00:00.0 第1名的商品id是：2422213，浏览次数是：1 第2名的商品id是：1853754，浏览次数是：1 第3名的商品id是：2347538，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 12:05:00.0 第1名的商品id是：4649743，浏览次数是：1 第2名的商品id是：1853754，浏览次数是：1 第3名的商品id是：2347538，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 12:10:00.0 第1名的商品id是：3250004，浏览次数是：1 第2名的商品id是：2347538，浏览次数是：1 第3名的商品id是：3468397，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 12:15:00.0 第1名的商品id是：469241，浏览次数是：1 第2名的商品id是：4944787，浏览次数是：1 第3名的商品id是：2347538，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 12:20:00.0 第1名的商品id是：2347538，浏览次数是：1 第2名的商品id是：2856510，浏览次数是：1 第3名的商品id是：2723221，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 12:25:00.0 第1名的商品id是：2723221，浏览次数是：1 第2名的商品id是：2347538，浏览次数是：1 第3名的商品id是：3698827，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 12:30:00.0 第1名的商品id是：2723221，浏览次数是：1 第2名的商品id是：2343683，浏览次数是：1 第3名的商品id是：2347538，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 12:35:00.0 第1名的商品id是：2723221，浏览次数是：1 第2名的商品id是：2347538，浏览次数是：1 第3名的商品id是：4123299，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 12:40:00.0 第1名的商品id是：452391，浏览次数是：1 第2名的商品id是：3382626，浏览次数是：1 第3名的商品id是：135950，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 12:45:00.0 第1名的商品id是：2424023，浏览次数是：1 第2名的商品id是：135950，浏览次数是：1 第3名的商品id是：2700369，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 12:50:00.0 第1名的商品id是：135950，浏览次数是：1 第2名的商品id是：3268515，浏览次数是：1 第3名的商品id是：2019254，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 12:55:00.0 第1名的商品id是：2804460，浏览次数是：1 第2名的商品id是：577342，浏览次数是：1 第3名的商品id是：1142684，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 13:00:00.0 第1名的商品id是：3613081，浏览次数是：1 第2名的商品id是：135950，浏览次数是：1 第3名的商品id是：1027421，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 13:05:00.0 第1名的商品id是：1027421，浏览次数是：1 第2名的商品id是：1926775，浏览次数是：1 第3名的商品id是：135950，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 13:10:00.0 第1名的商品id是：1926775，浏览次数是：1 第2名的商品id是：1027421，浏览次数是：1 第3名的商品id是：3839913，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 13:15:00.0 第1名的商品id是：1926775，浏览次数是：1 第2名的商品id是：1027421，浏览次数是：1 第3名的商品id是：1835955，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 13:20:00.0 第1名的商品id是：2720662，浏览次数是：1 第2名的商品id是：1835955，浏览次数是：1 第3名的商品id是：1929997，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 13:25:00.0 第1名的商品id是：5150918，浏览次数是：1 第2名的商品id是：1835955，浏览次数是：1 第3名的商品id是：3928189，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 13:30:00.0 第1名的商品id是：1835955，浏览次数是：1 第2名的商品id是：2060116，浏览次数是：1 第3名的商品id是：2521128，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 13:35:00.0 第1名的商品id是：5150918，浏览次数是：1 第2名的商品id是：1300827，浏览次数是：1 第3名的商品id是：2060116，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 13:40:00.0 第1名的商品id是：340143，浏览次数是：1 第2名的商品id是：2060116，浏览次数是：1 第3名的商品id是：1835955，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 13:45:00.0 第1名的商品id是：513749，浏览次数是：1 第2名的商品id是：2060116，浏览次数是：1 第3名的商品id是：1835955，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 13:50:00.0 第1名的商品id是：4650468，浏览次数是：1 第2名的商品id是：2060116，浏览次数是：1 第3名的商品id是：1835955，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 13:55:00.0 第1名的商品id是：513749，浏览次数是：1 第2名的商品id是：1728662，浏览次数是：1 第3名的商品id是：2546377，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 14:00:00.0 第1名的商品id是：2923435，浏览次数是：1 第2名的商品id是：4171073，浏览次数是：1 第3名的商品id是：274952，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 14:05:00.0 第1名的商品id是：232878，浏览次数是：1 第2名的商品id是：274952，浏览次数是：1 第3名的商品id是：3846404，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 14:10:00.0 第1名的商品id是：1717631，浏览次数是：1 第2名的商品id是：495039，浏览次数是：1 第3名的商品id是：274952，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 14:15:00.0 第1名的商品id是：1947553，浏览次数是：1 第2名的商品id是：274952，浏览次数是：1 第3名的商品id是：1459382，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 14:20:00.0 第1名的商品id是：4822390，浏览次数是：1 第2名的商品id是：274952，浏览次数是：1 第3名的商品id是：39330，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 14:25:00.0 第1名的商品id是：2182145，浏览次数是：1 第2名的商品id是：1459382，浏览次数是：1 第3名的商品id是：5158468，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 14:30:00.0 第1名的商品id是：274952，浏览次数是：1 第2名的商品id是：1459382，浏览次数是：1 第3名的商品id是：2453703，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 14:35:00.0 第1名的商品id是：1056273，浏览次数是：1 第2名的商品id是：274952，浏览次数是：1 第3名的商品id是：1459382，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 14:40:00.0 第1名的商品id是：1459382，浏览次数是：1 第2名的商品id是：1351520，浏览次数是：1 第3名的商品id是：1887742，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 14:45:00.0 第1名的商品id是：3787445，浏览次数是：1 第2名的商品id是：3302466，浏览次数是：1 第3名的商品id是：1459382，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 14:50:00.0 第1名的商品id是：3186978，浏览次数是：1 第2名的商品id是：1459382，浏览次数是：1 第3名的商品id是：4585156，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 14:55:00.0 第1名的商品id是：1459382，浏览次数是：1 第2名的商品id是：1887742，浏览次数是：1 第3名的商品id是：1755041，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 15:00:00.0 第1名的商品id是：1459382，浏览次数是：1 第2名的商品id是：2820520，浏览次数是：1 第3名的商品id是：4719604，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 15:05:00.0 第1名的商品id是：1459382，浏览次数是：1 第2名的商品id是：1887742，浏览次数是：1 第3名的商品id是：4342434，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 15:10:00.0 第1名的商品id是：1568206，浏览次数是：1 第2名的商品id是：624903，浏览次数是：1 第3名的商品id是：362796，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 15:15:00.0 第1名的商品id是：4350288，浏览次数是：1 第2名的商品id是：2420534，浏览次数是：1 第3名的商品id是：234805，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 15:20:00.0 第1名的商品id是：2023716，浏览次数是：1 第2名的商品id是：935229，浏览次数是：1 第3名的商品id是：1989489，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 15:25:00.0 第1名的商品id是：956921，浏览次数是：1 第2名的商品id是：1224487，浏览次数是：1 第3名的商品id是：1687681，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 15:30:00.0 第1名的商品id是：1061251，浏览次数是：1 第2名的商品id是：1317129，浏览次数是：1 第3名的商品id是：1803389，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 15:35:00.0 第1名的商品id是：4153921，浏览次数是：1 第2名的商品id是：1252555，浏览次数是：1 第3名的商品id是：234077，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 15:40:00.0 第1名的商品id是：2415944，浏览次数是：1 第2名的商品id是：3860645，浏览次数是：1 第3名的商品id是：3705929，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 15:45:00.0 第1名的商品id是：3445990，浏览次数是：1 第2名的商品id是：3548305，浏览次数是：1 第3名的商品id是：2862622，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 15:50:00.0 第1名的商品id是：3705929，浏览次数是：1 第2名的商品id是：4402437，浏览次数是：1 第3名的商品id是：4348177，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 15:55:00.0 第1名的商品id是：167862，浏览次数是：1 第2名的商品id是：3329119，浏览次数是：1 第3名的商品id是：3636313，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 16:00:00.0 第1名的商品id是：2309950，浏览次数是：1 第2名的商品id是：2274457，浏览次数是：1 第3名的商品id是：1780899，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 16:05:00.0 第1名的商品id是：4256250，浏览次数是：1 第2名的商品id是：2500039，浏览次数是：1 第3名的商品id是：2340232，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 16:10:00.0 第1名的商品id是：4313897，浏览次数是：1 第2名的商品id是：3234987，浏览次数是：1 第3名的商品id是：12350，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 16:15:00.0 第1名的商品id是：4227361，浏览次数是：1 第2名的商品id是：3427755，浏览次数是：1 第3名的商品id是：2488464，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 16:20:00.0 第1名的商品id是：4712719，浏览次数是：1 第2名的商品id是：2420781，浏览次数是：1 第3名的商品id是：2767425，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 16:25:00.0 第1名的商品id是：2170071，浏览次数是：1 第2名的商品id是：4545392，浏览次数是：1 第3名的商品id是：2393386，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 16:30:00.0 第1名的商品id是：221237，浏览次数是：1 第2名的商品id是：2186395，浏览次数是：1 第3名的商品id是：3028050，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 16:35:00.0 第1名的商品id是：4473466，浏览次数是：1 第2名的商品id是：2331757，浏览次数是：1 第3名的商品id是：3134181，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 16:40:00.0 第1名的商品id是：2331757，浏览次数是：1 第2名的商品id是：5148005，浏览次数是：1 第3名的商品id是：4761840，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 16:45:00.0 第1名的商品id是：17262，浏览次数是：1 第2名的商品id是：826593，浏览次数是：1 第3名的商品id是：1727321，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 16:50:00.0 第1名的商品id是：898116，浏览次数是：1 第2名的商品id是：815377，浏览次数是：1 第3名的商品id是：55238，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 16:55:00.0 第1名的商品id是：4242833，浏览次数是：1 第2名的商品id是：326593，浏览次数是：1 第3名的商品id是：2465281，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 17:00:00.0 第1名的商品id是：2605467，浏览次数是：1 第2名的商品id是：4894663，浏览次数是：1 第3名的商品id是：945999，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 17:05:00.0 第1名的商品id是：2806210，浏览次数是：1 第2名的商品id是：4894352，浏览次数是：1 第3名的商品id是：2572397，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 17:10:00.0 第1名的商品id是：2822277，浏览次数是：1 第2名的商品id是：571603，浏览次数是：1 第3名的商品id是：3272727，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 17:15:00.0 第1名的商品id是：2257069，浏览次数是：1 第2名的商品id是：5112343，浏览次数是：1 第3名的商品id是：394978，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 17:20:00.0 第1名的商品id是：1909165，浏览次数是：1 第2名的商品id是：2703796，浏览次数是：1 第3名的商品id是：1980891，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 17:25:00.0 第1名的商品id是：1648263，浏览次数是：1 第2名的商品id是：2819476，浏览次数是：1 第3名的商品id是：4773596，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 17:30:00.0 第1名的商品id是：3683596，浏览次数是：1 第2名的商品id是：676804，浏览次数是：1 第3名的商品id是：2090451，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 17:35:00.0 第1名的商品id是：5156932，浏览次数是：1 第2名的商品id是：676804，浏览次数是：1 第3名的商品id是：5042197，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 17:40:00.0 第1名的商品id是：948860，浏览次数是：1 第2名的商品id是：938653，浏览次数是：1 第3名的商品id是：4983419，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 17:45:00.0 第1名的商品id是：938653，浏览次数是：1 第2名的商品id是：2247117，浏览次数是：1 第3名的商品id是：1561974，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 17:50:00.0 第1名的商品id是：147659，浏览次数是：1 第2名的商品id是：1270816，浏览次数是：1 第3名的商品id是：292317，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 17:55:00.0 第1名的商品id是：938653，浏览次数是：1 第2名的商品id是：2068397，浏览次数是：1 第3名的商品id是：522620，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 18:00:00.0 第1名的商品id是：4455955，浏览次数是：1 第2名的商品id是：2798214，浏览次数是：1 第3名的商品id是：3631789，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 18:05:00.0 第1名的商品id是：3910585，浏览次数是：1 第2名的商品id是：3631789，浏览次数是：1 第3名的商品id是：3399340，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 18:10:00.0 第1名的商品id是：3719602，浏览次数是：1 第2名的商品id是：2068397，浏览次数是：1 第3名的商品id是：441764，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 18:15:00.0 第1名的商品id是：4794421，浏览次数是：1 第2名的商品id是：2265283，浏览次数是：1 第3名的商品id是：2068397，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 18:20:00.0 第1名的商品id是：2085791，浏览次数是：1 第2名的商品id是：2020365，浏览次数是：1 第3名的商品id是：4135873，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 18:25:00.0 第1名的商品id是：1823649，浏览次数是：1 第2名的商品id是：816118，浏览次数是：1 第3名的商品id是：80134，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 18:30:00.0 第1名的商品id是：2777271，浏览次数是：1 第2名的商品id是：405764，浏览次数是：1 第3名的商品id是：1054769，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 18:35:00.0 第1名的商品id是：4900292，浏览次数是：1 第2名的商品id是：3631789，浏览次数是：1 第3名的商品id是：4381701，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 18:40:00.0 第1名的商品id是：4113700，浏览次数是：1 第2名的商品id是：4888386，浏览次数是：1 第3名的商品id是：4736510，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 18:45:00.0 第1名的商品id是：826110，浏览次数是：1 第2名的商品id是：2091848，浏览次数是：1 第3名的商品id是：4959723，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 18:50:00.0 第1名的商品id是：3508317，浏览次数是：1 第2名的商品id是：3593205，浏览次数是：1 第3名的商品id是：2808043，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 18:55:00.0 第1名的商品id是：2463819，浏览次数是：1 第2名的商品id是：2115271，浏览次数是：1 第3名的商品id是：4193531，浏览次数是：1 ===============================================   ============================================== 窗口结束时间：2017-11-26 19:00:00.0 第1名的商品id是：2065878，浏览次数是：1 第2名的商品id是：3715576，浏览次数是：1 第3名的商品id是：4310064，浏览次数是：1 ===============================================    Process finished with exit code 0