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

　　完整代码逻辑packageday04；importorg。apache。flink。api。common。eventtime。SerializableTimestampAssigner；importorg。apache。flink。api。common。eventtime。WatermarkStrategy；importorg。apache。flink。api。common。functions。AggregateFunction；importorg。apache。flink。api。common。functions。MapFunction；importorg。apache。flink。api。common。state。ListState；importorg。apache。flink。api。common。state。ListStateDescriptor；importorg。apache。flink。api。common。typeinfo。Types；importorg。apache。flink。configuration。Configuration；importorg。apache。flink。streaming。api。datastream。DataStream；importorg。apache。flink。streaming。api。datastream。DataStreamSource；importorg。apache。flink。streaming。api。environment。StreamExecutionEnvironment；importorg。apache。flink。streaming。api。functions。KeyedProcessFunction；importorg。apache。flink。streaming。api。functions。windowing。ProcessWindowFunction；importorg。apache。flink。streaming。api。windowing。assigners。SlidingEventTimeWindows；importorg。apache。flink。streaming。api。windowing。time。Time；importorg。apache。flink。streaming。api。windowing。windows。TimeWindow；importorg。apache。flink。util。Collector；importjava。sql。Timestamp；importjava。time。Duration；importjava。util。ArrayList；importjava。util。Comparator；program：bigDatalearndescription：每个窗口中最热门的商品是什么author：Mr。逗create：2021092409：44publicclassMostPopularProductByWindow｛publicstaticclassUserBehavior｛publicStringuserId；publicStringitemId；publicStringcategoryId；publicStringbehavior；publicLongtimestamp；publicUserBehavior（）｛｝publicUserBehavior（StringuserId，StringitemId，StringcategoryId，Stringbehavior，Longtimestamp）｛this。userIduserId；this。itemIditemId；this。categoryIdcategoryId；this。behaviorbehavior；this。timestamptimestamp；｝OverridepublicStringtoString（）｛returnUserBehavior｛userIduserId，itemIditemId，categoryIdcategoryId，behaviorbehavior，timestampnewTimestamp（timestamp）｝；｝｝每个商品在每个窗口中的浏览次数publicstaticclassItemViewCount｛publicStringitemId；publicLongcount；publicLongwindowStart；publicLongwindowEnd；publicItemViewCount（）｛｝publicItemViewCount（StringitemId，Longcount，LongwindowStart，LongwindowEnd）｛this。itemIditemId；this。countcount；this。windowStartwindowStart；this。windowEndwindowEnd；｝OverridepublicStringtoString（）｛returnItemViewCount｛itemIditemId，countcount，windowStartnewTimestamp（windowStart），windowEndnewTimestamp（windowEnd）｝；｝｝Description：聚合窗口计算Param：return：Author：Mr。逗Date：2021924publicstaticclassCountAggimplementsAggregateFunctionUserBehavior，Long，Long｛创建累加器OverridepublicLongcreateAccumulator（）｛return0L；｝自定义累加规则OverridepublicLongadd（UserBehavioruserBehavior，Longaccumulator）｛returnaccumulator1；｝获取结果OverridepublicLonggetResult（Longaccumulator）｛returnaccumulator；｝OverridepublicLongmerge（LongaLong，Longacc1）｛returnnull；｝｝全窗口结果publicstaticclassWindowResultextendsProcessWindowFunctionLong，ItemViewCount，String，TimeWindow｛Overridepublicvoidprocess（Strings，Contextcontext，IterableLongit，CollectorItemViewCountout）throwsException｛out。collect（newItemViewCount（s，it。iterator（）。next（），context。window（）。getStart（），context。window（）。getEnd（）））；｝｝TopNpublicstaticclassTopNextendsKeyedProcessFunctionLong，ItemViewCount，String｛privateListStateItemViewCountlistState；privateIntegern；publicTopN（Integern）｛this。nn；｝Overridepublicvoidopen（Configurationparameters）throwsException｛super。open（parameters）；listStategetRuntimeContext（）。getListState（newListStateDescriptorItemViewCount（liststate，Types。POJO（ItemViewCount。class）））；｝OverridepublicvoidprocessElement（ItemViewCountvalue，Contextctx，CollectorStringout）throwsException｛listState。add（value）；ctx。timerService（）。registerEventTimeTimer（value。windowEnd1L）；｝OverridepublicvoidonTimer（longtimestamp，OnTimerContextctx，CollectorStringout）throwsException｛super。onTimer（timestamp，ctx，out）；ArrayListItemViewCountitemViewCountArrayListnewArrayList（）；for（ItemViewCountivc：listState。get（））｛itemViewCountArrayList。add（ivc）；｝listState。clear（）；itemViewCountArrayList。sort（newComparatorItemViewCount（）｛Overridepublicintcompare（ItemViewCounto1，ItemViewCounto2）｛returno1。count。intValue（）o2。count。intValue（）；｝｝）；StringBuilderresultnewStringBuilder（）；result。append（）。append（窗口结束时间：newTimestamp（timestamp1L））。append（）；for（inti0；in；i）｛ItemViewCountcurritemViewCountArrayList。get（i）；result。append（第（i1）名的商品id是：curr。itemId）。append（，浏览次数是：curr。count）。append（）；｝result。append（）；out。collect（result。toString（））；｝｝publicstaticvoidmain（String〔〕args）｛StreamExecutionEnvironmentenvStreamExecutionEnvironment。getExecutionEnvironment（）；env。setParallelism（1）；DataStreamSourceStringsourceenv。readTextFile（G：bigDatalearnFlinklearnsrcmainresourcesUserBehavior。csv）；DataStreamUserBehaviormapsource。map（newMapFunctionString，UserBehavior（）｛OverridepublicUserBehaviormap（Stringvalue）throwsException｛String〔〕arrvalue。split（，）；returnnewUserBehavior（arr〔0〕，arr〔1〕，arr〔2〕，arr〔3〕，Long。parseLong（arr〔4〕）1000L）；｝｝）；DataStreamUserBehaviorwatermarksmap。filter（vv。behavior。equals（pv））。assignTimestampsAndWatermarks（WatermarkStrategy。UserBehaviorforBoundedOutOfOrderness（Duration。ofSeconds（0））。withTimestampAssigner（newSerializableTimestampAssignerUserBehavior（）｛OverridepubliclongextractTimestamp（UserBehaviorv，longrecordTimestamp）｛returnv。timestamp；｝｝））；watermarks。keyBy（vv。itemId）。window（SlidingEventTimeWindows。of（Time。hours（1），Time。minutes（5）））。aggregate（newCountAgg（），newWindowResult（））。keyBy（vv。windowEnd）。process（newTopN（3））。print（）；StringnameMostPopularProductByWindow。class。getName（）；try｛env。execute（name）；｝catch（Exceptione）｛e。printStackTrace（）；｝｝｝结果展示C：ProgramFilesJavajdk1。8。0191binjava。exejavaagent：F：appIntelliJIDEA2019。3。3libideart。jar55029：F：appIntelliJIDEA2019。3。3binDfile。encodingUTF8classpathC：ProgramFilesJavajdk1。8。0191jrelibcharsets。jar；C：ProgramFilesJavajdk1。8。0191jrelibdeploy。jar；C：ProgramFilesJavajdk1。8。0191jrelibextaccessbridge64。jar；C：ProgramFilesJavajdk1。8。0191jrelibextcldrdata。jar；C：ProgramFilesJavajdk1。8。0191jrelibextdnsns。jar；C：ProgramFilesJavajdk1。8。0191jrelibextjaccess。jar；C：ProgramFilesJavajdk1。8。0191jrelibextjfxrt。jar；C：ProgramFilesJavajdk1。8。0191jrelibextlocaledata。jar；C：ProgramFilesJavajdk1。8。0191jrelibextashorn。jar；C：ProgramFilesJavajdk1。8。0191jrelibextsunec。jar；C：ProgramFilesJavajdk1。8。0191jrelibextsunjceprovider。jar；C：ProgramFilesJavajdk1。8。0191jrelibextsunmscapi。jar；C：ProgramFilesJavajdk1。8。0191jrelibextsunpkcs11。jar；C：ProgramFilesJavajdk1。8。0191jrelibextzipfs。jar；C：ProgramFilesJavajdk1。8。0191jrelibjavaws。jar；C：ProgramFilesJavajdk1。8。0191jrelibjce。jar；C：ProgramFilesJavajdk1。8。0191jrelibjfr。jar；C：ProgramFilesJavajdk1。8。0191jrelibjfxswt。jar；C：ProgramFilesJavajdk1。8。0191jrelibjsse。jar；C：ProgramFilesJavajdk1。8。0191jrelibmanagementagent。jar；C：ProgramFilesJavajdk1。8。0191jrelibplugin。jar；C：ProgramFilesJavajdk1。8。0191jrelibresources。jar；C：ProgramFilesJavajdk1。8。0191jrelibrt。jar；G：bigDatalearnFlinklearnargetclasses；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkjava1。13。0flinkjava1。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkcore1。13。0flinkcore1。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkannotations1。13。0flinkannotations1。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkmetricscore1。13。0flinkmetricscore1。13。0。jar；G：appapachemaven3。6。3mavenrepositorycomesotericsoftwarekryokryo2。24。0kryo2。24。0。jar；G：appapachemaven3。6。3mavenrepositorycomesotericsoftwareminlogminlog1。2minlog1。2。jar；G：appapachemaven3。6。3mavenrepositoryorgobjenesisobjenesis2。1objenesis2。1。jar；G：appapachemaven3。6。3mavenrepositorycommonscollectionscommonscollections3。2。2commonscollections3。2。2。jar；G：appapachemaven3。6。3mavenrepositoryorgapachecommonscommonscompress1。20commonscompress1。20。jar；G：appapachemaven3。6。3mavenrepositoryorgapachecommonscommonslang33。3。2commonslang33。3。2。jar；G：appapachemaven3。6。3mavenrepositoryorgapachecommonscommonsmath33。5commonsmath33。5。jar；G：appapachemaven3。6。3mavenrepositoryorgslf4jslf4japi1。7。15slf4japi1。7。15。jar；G：appapachemaven3。6。3mavenrepositorycomgooglecodefindbugsjsr3051。3。9jsr3051。3。9。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkforceshading1。13。0forceshading1。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkstreamingjava2。121。13。0flinkstreamingjava2。121。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkfilesinkcommon1。13。0flinkfilesinkcommon1。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkruntime2。121。13。0flinkruntime2。121。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkqueryablestateclientjava1。13。0flinkqueryablestateclientjava1。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkhadoopfs1。13。0flinkhadoopfs1。13。0。jar；G：appapachemaven3。6。3mavenrepositorycommonsiocommonsio2。7commonsio2。7。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkshadednetty4。1。49。Final13。0flinkshadednetty4。1。49。Final13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkshadedjackson2。12。113。0flinkshadedjackson2。12。113。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkshadedzookeeper33。4。1413。0flinkshadedzookeeper33。4。1413。0。jar；G：appapachemaven3。6。3mavenrepositoryorgjavassistjavassist3。24。0GAjavassist3。24。0GA。jar；G：appapachemaven3。6。3mavenrepositorycomypesafeakkaakkaactor2。122。5。21akkaactor2。122。5。21。jar；G：appapachemaven3。6。3mavenrepositorycomypesafeconfig1。3。3config1。3。3。jar；G：appapachemaven3。6。3mavenrepositoryorgscalalangmodulesscalajava8compat2。12。8。0scalajava8compat2。120。8。0。jar；G：appapachemaven3。6。3mavenrepositorycomypesafeakkaakkastream2。122。5。21akkastream2。122。5。21。jar；G：appapachemaven3。6。3mavenrepositoryorgreactivestreamsreactivestreams1。0。2reactivestreams1。0。2。jar；G：appapachemaven3。6。3mavenrepositorycomypesafesslconfigcore2。12。3。7sslconfigcore2。120。3。7。jar；G：appapachemaven3。6。3mavenrepositoryorgscalalangmodulesscalaparsercombinators2。121。1。1scalaparsercombinators2。121。1。1。jar；G：appapachemaven3。6。3mavenrepositorycomypesafeakkaakkaprotobuf2。122。5。21akkaprotobuf2。122。5。21。jar；G：appapachemaven3。6。3mavenrepositorycomypesafeakkaakkaslf4j2。122。5。21akkaslf4j2。122。5。21。jar；G：appapachemaven3。6。3mavenrepositoryorgclappergrizzledslf4j2。121。3。2grizzledslf4j2。121。3。2。jar；G：appapachemaven3。6。3mavenrepositorycomgithubscoptscopt2。123。5。0scopt2。123。5。0。jar；G：appapachemaven3。6。3mavenrepositoryorgxerialsnappysnappyjava1。1。8。3snappyjava1。1。8。3。jar；G：appapachemaven3。6。3mavenrepositorycomwitterchill2。12。7。6chill2。120。7。6。jar；G：appapachemaven3。6。3mavenrepositorycomwitterchilljava。7。6chilljava0。7。6。jar；G：appapachemaven3。6。3mavenrepositoryorglz4lz4java1。6。0lz4java1。6。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkshadedguava18。013。0flinkshadedguava18。013。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkclients2。121。13。0flinkclients2。121。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkoptimizer2。121。13。0flinkoptimizer2。121。13。0。jar；G：appapachemaven3。6。3mavenrepositorycommonsclicommonscli1。3。1commonscli1。3。1。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinktableapijavabridge2。121。13。0flinktableapijavabridge2。121。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinktableapijava1。13。0flinktableapijava1。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinktableplannerblink2。121。13。0flinktableplannerblink2。121。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinktableapiscala2。121。13。0flinktableapiscala2。121。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinktableapiscalabridge2。121。13。0flinktableapiscalabridge2。121。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinktableruntimeblink2。121。13。0flinktableruntimeblink2。121。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgcodehausjaninojanino3。0。11janino3。0。11。jar；G：appapachemaven3。6。3mavenrepositoryorgcodehausjaninocommonscompiler3。0。11commonscompiler3。0。11。jar；G：appapachemaven3。6。3mavenrepositoryorgapachecalciteavaticaavaticacore1。17。0avaticacore1。17。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkstreamingscala2。121。13。0flinkstreamingscala2。121。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkscala2。121。13。0flinkscala2。121。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgscalalangscalareflect2。12。7scalareflect2。12。7。jar；G：appapachemaven3。6。3mavenrepositoryorgscalalangscalalibrary2。12。7scalalibrary2。12。7。jar；G：appapachemaven3。6。3mavenrepositoryorgscalalangscalacompiler2。12。7scalacompiler2。12。7。jar；G：appapachemaven3。6。3mavenrepositoryorgscalalangmodulesscalaxml2。121。0。6scalaxml2。121。0。6。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinktablecommon1。13。0flinktablecommon1。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkconnectorfiles1。13。0flinkconnectorfiles1。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkshadedasm77。113。0flinkshadedasm77。113。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkcep2。121。13。0flinkcep2。121。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkcsv1。13。0flinkcsv1。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkconnectorkafka2。121。13。0flinkconnectorkafka2。121。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapachekafkakafkaclients2。4。1kafkaclients2。4。1。jar；G：appapachemaven3。6。3mavenrepositorycomgithublubenzstdjni1。4。31zstdjni1。4。31。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkconnectorbase1。13。0flinkconnectorbase1。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapachebahirflinkconnectorredis2。111。0flinkconnectorredis2。111。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkstreamingjava2。111。2。0flinkstreamingjava2。111。2。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkruntime2。111。2。0flinkruntime2。111。2。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkshadedhadoop21。2。0flinkshadedhadoop21。2。0。jar；G：appapachemaven3。6。3mavenrepositoryorgukaanixz1。0xz1。0。jar；G：appapachemaven3。6。3mavenrepositoryxmlencxmlenc。52xmlenc0。52。jar；G：appapachemaven3。6。3mavenrepositorycommonscodeccommonscodec1。4commonscodec1。4。jar；G：appapachemaven3。6。3mavenrepositorycommonsnetcommonsnet3。1commonsnet3。1。jar；G：appapachemaven3。6。3mavenrepositoryjavaxservletservletapi2。5servletapi2。5。jar；G：appapachemaven3。6。3mavenrepositoryorgmortbayjettyjettyutil6。1。26jettyutil6。1。26。jar；G：appapachemaven3。6。3mavenrepositorycomsunjerseyjerseycore1。9jerseycore1。9。jar；G：appapachemaven3。6。3mavenrepositorycommonselcommonsel1。0commonsel1。0。jar；G：appapachemaven3。6。3mavenrepositorycommonsloggingcommonslogging1。1。3commonslogging1。1。3。jar；G：appapachemaven3。6。3mavenrepositorycomjamesmurtyutilsjavaxmlbuilder。4javaxmlbuilder0。4。jar；G：appapachemaven3。6。3mavenrepositorycommonslangcommonslang2。6commonslang2。6。jar；G：appapachemaven3。6。3mavenrepositorycommonsconfigurationcommonsconfiguration1。7commonsconfiguration1。7。jar；G：appapachemaven3。6。3mavenrepositorycommonsdigestercommonsdigester1。8。1commonsdigester1。8。1。jar；G：appapachemaven3。6。3mavenrepositoryorgcodehausjacksonjacksoncoreasl1。8。8jacksoncoreasl1。8。8。jar；G：appapachemaven3。6。3mavenrepositoryorgcodehausjacksonjacksonmapperasl1。8。8jacksonmapperasl1。8。8。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheavroavro1。7。7avro1。7。7。jar；G：appapachemaven3。6。3mavenrepositorycomhoughtworksparanamerparanamer2。3paranamer2。3。jar；G：appapachemaven3。6。3mavenrepositorycomjcraftjsch。1。42jsch0。1。42。jar；G：appapachemaven3。6。3mavenrepositorycommonsbeanutilscommonsbeanutilsbeancollections1。8。3commonsbeanutilsbeancollections1。8。3。jar；G：appapachemaven3。6。3mavenrepositorycommonsdaemoncommonsdaemon1。0。13commonsdaemon1。0。13。jar；G：appapachemaven3。6。3mavenrepositoryjavaxxmlbindjaxbapi2。2。2jaxbapi2。2。2。jar；G：appapachemaven3。6。3mavenrepositoryjavaxxmlstreamstaxapi1。02staxapi1。02。jar；G：appapachemaven3。6。3mavenrepositoryjavaxactivationactivation1。1activation1。1。jar；G：appapachemaven3。6。3mavenrepositoryioettyettyall4。0。27。Finalettyall4。0。27。Final。jar；G：appapachemaven3。6。3mavenrepositorycomdataartisansflakkaactor2。112。3customflakkaactor2。112。3custom。jar；G：appapachemaven3。6。3mavenrepositorycomdataartisansflakkaremote2。112。3customflakkaremote2。112。3custom。jar；G：appapachemaven3。6。3mavenrepositoryioettyetty3。8。0。Finaletty3。8。0。Final。jar；G：appapachemaven3。6。3mavenrepositoryorguncommonsmathsuncommonsmaths1。2。2auncommonsmaths1。2。2a。jar；G：appapachemaven3。6。3mavenrepositorycomdataartisansflakkaslf4j2。112。3customflakkaslf4j2。112。3custom。jar；G：appapachemaven3。6。3mavenrepositoryorgclappergrizzledslf4j2。111。0。2grizzledslf4j2。111。0。2。jar；G：appapachemaven3。6。3mavenrepositorycomgithubscoptscopt2。113。2。0scopt2。113。2。0。jar；G：appapachemaven3。6。3mavenrepositorycomfasterxmljacksoncorejacksoncore2。7。4jacksoncore2。7。4。jar；G：appapachemaven3。6。3mavenrepositorycomfasterxmljacksoncorejacksondatabind2。7。4jacksondatabind2。7。4。jar；G：appapachemaven3。6。3mavenrepositorycomfasterxmljacksoncorejacksonannotations2。7。0jacksonannotations2。7。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapachezookeeperzookeeper3。4。6zookeeper3。4。6。jar；G：appapachemaven3。6。3mavenrepositoryjlinejline。9。94jline0。9。94。jar；G：appapachemaven3。6。3mavenrepositoryjunitjunit3。8。1junit3。8。1。jar；G：appapachemaven3。6。3mavenrepositorycomwitterchill2。11。7。4chill2。110。7。4。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkclients2。111。2。0flinkclients2。111。2。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkoptimizer2。111。2。0flinkoptimizer2。111。2。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheslingorg。apache。sling。commons。json2。0。6org。apache。sling。commons。json2。0。6。jar；G：appapachemaven3。6。3mavenrepositorymysqlmysqlconnectorjava8。0。21mysqlconnectorjava8。0。21。jar；G：appapachemaven3。6。3mavenrepositorycomgoogleprotobufprotobufjava3。11。4protobufjava3。11。4。jar；G：appapachemaven3。6。3mavenrepositoryorgapacheflinkflinkconnectorjdbc2。121。13。0flinkconnectorjdbc2。121。13。0。jar；G：appapachemaven3。6。3mavenrepositoryorgslf4jslf4jlog4j121。7。30slf4jlog4j121。7。30。jar；G：appapachemaven3。6。3mavenrepositorylog4jlog4j1。2。17log4j1。2。17。jar；G：appapachemaven3。6。3mavenrepositoryorgapachelogginglog4jlog4jtoslf4j2。14。0log4jtoslf4j2。14。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapachelogginglog4jlog4japi2。14。0log4japi2。14。0。jar；G：appapachemaven3。6。3mavenrepositoryredisclientsjedis2。9。0jedis2。9。0。jar；G：appapachemaven3。6。3mavenrepositoryorgapachecommonscommonspool22。4。2commonspool22。4。2。jar；G：appapachemaven3。6。3mavenrepositorycomgooglecodegsongson2。8。5gson2。8。5。jarday04。MostPopularProductByWindowlog4j：WARNNoappenderscouldbefoundforlogger（org。apache。flink。api。java。typeutils。TypeExtractor）。log4j：WARNPleaseinitializethelog4jsystemproperly。log4j：WARNSeehttp：logging。apache。orglog4j1。2faq。htmlnoconfigformoreinfo。窗口结束时间：2017112609：05：00。0第1名的商品id是：1715，浏览次数是：1第2名的商品id是：3611281，浏览次数是：1第3名的商品id是：942195，浏览次数是：1窗口结束时间：2017112609：10：00。0第1名的商品id是：26072，浏览次数是：1第2名的商品id是：1214771，浏览次数是：1第3名的商品id是：5027001，浏览次数是：1窗口结束时间：2017112609：15：00。0第1名的商品id是：5027001，浏览次数是：1第2名的商品id是：1214771，浏览次数是：1第3名的商品id是：4764374，浏览次数是：1窗口结束时间：2017112609：20：00。0第1名的商品id是：1214771，浏览次数是：1第2名的商品id是：5027001，浏览次数是：1第3名的商品id是：4764374，浏览次数是：1窗口结束时间：2017112609：25：00。0第1名的商品id是：1214771，浏览次数是：1第2名的商品id是：5027001，浏览次数是：1第3名的商品id是：1926022，浏览次数是：1窗口结束时间：2017112609：30：00。0第1名的商品id是：1214771，浏览次数是：1第2名的商品id是：1715，浏览次数是：1第3名的商品id是：1926022，浏览次数是：1窗口结束时间：2017112609：35：00。0第1名的商品id是：1214771，浏览次数是：1第2名的商品id是：1926022，浏览次数是：1第3名的商品id是：4832545，浏览次数是：1窗口结束时间：2017112609：40：00。0第1名的商品id是：26072，浏览次数是：1第2名的商品id是：1926022，浏览次数是：1第3名的商品id是：4866351，浏览次数是：1窗口结束时间：2017112609：45：00。0第1名的商品id是：4495168，浏览次数是：1第2名的商品id是：1872142，浏览次数是：1第3名的商品id是：1926022，浏览次数是：1窗口结束时间：2017112609：50：00。0第1名的商品id是：1926022，浏览次数是：1第2名的商品id是：1872142，浏览次数是：1第3名的商品id是：1937464，浏览次数是：1窗口结束时间：2017112609：55：00。0第1名的商品id是：1926022，浏览次数是：1第2名的商品id是：1872142，浏览次数是：1第3名的商品id是：2764196，浏览次数是：1窗口结束时间：2017112610：00：00。0第1名的商品id是：1715，浏览次数是：1第2名的商品id是：1926022，浏览次数是：1第3名的商品id是：1872142，浏览次数是：1窗口结束时间：2017112610：05：00。0第1名的商品id是：1926022，浏览次数是：1第2名的商品id是：1872142，浏览次数是：1第3名的商品id是：4254351，浏览次数是：1窗口结束时间：2017112610：10：00。0第1名的商品id是：1872142，浏览次数是：1第2名的商品id是：2764196，浏览次数是：1第3名的商品id是：1740710，浏览次数是：1窗口结束时间：2017112610：15：00。0第1名的商品id是：1872142，浏览次数是：1第2名的商品id是：3878753，浏览次数是：1第3名的商品id是：3177547，浏览次数是：1窗口结束时间：2017112610：20：00。0第1名的商品id是：2125378，浏览次数是：1第2名的商品id是：1893561，浏览次数是：1第3名的商品id是：2888394，浏览次数是：1窗口结束时间：2017112610：25：00。0第1名的商品id是：133272，浏览次数是：1第2名的商品id是：1893561，浏览次数是：1第3名的商品id是：2243084，浏览次数是：1窗口结束时间：2017112610：30：00。0第1名的商品id是：1893561，浏览次数是：1第2名的商品id是：605099，浏览次数是：1第3名的商品id是：2714987，浏览次数是：1窗口结束时间：2017112610：35：00。0第1名的商品id是：1893561，浏览次数是：1第2名的商品id是：335853，浏览次数是：1第3名的商品id是：2714987，浏览次数是：1窗口结束时间：2017112610：40：00。0第1名的商品id是：2714987，浏览次数是：1第2名的商品id是：547062，浏览次数是：1第3名的商品id是：2300809，浏览次数是：1窗口结束时间：2017112610：45：00。0第1名的商品id是：1901552，浏览次数是：1第2名的商品id是：2243084，浏览次数是：1第3名的商品id是：547062，浏览次数是：1窗口结束时间：2017112610：50：00。0第1名的商品id是：2070855，浏览次数是：1第2名的商品id是：547062，浏览次数是：1第3名的商品id是：2162935，浏览次数是：1窗口结束时间：2017112610：55：00。0第1名的商品id是：547062，浏览次数是：1第2名的商品id是：2076557，浏览次数是：1第3名的商品id是：1461407，浏览次数是：1窗口结束时间：2017112611：00：00。0第1名的商品id是：2682512，浏览次数是：1第2名的商品id是：547062，浏览次数是：1第3名的商品id是：2714987，浏览次数是：1窗口结束时间：2017112611：05：00。0第1名的商品id是：547062，浏览次数是：1第2名的商品id是：4288621，浏览次数是：1第3名的商品id是：4843772，浏览次数是：1窗口结束时间：2017112611：10：00。0第1名的商品id是：1825144，浏览次数是：1第2名的商品id是：547062，浏览次数是：1第3名的商品id是：2560087，浏览次数是：1窗口结束时间：2017112611：15：00。0第1名的商品id是：547062，浏览次数是：1第2名的商品id是：4938455，浏览次数是：1第3名的商品id是：3685517，浏览次数是：1窗口结束时间：2017112611：20：00。0第1名的商品id是：5039901，浏览次数是：1第2名的商品id是：4517350，浏览次数是：1第3名的商品id是：1711003，浏览次数是：1窗口结束时间：2017112611：25：00。0第1名的商品id是：703437，浏览次数是：1第2名的商品id是：1461407，浏览次数是：1第3名的商品id是：2297621，浏览次数是：1窗口结束时间：2017112611：30：00。0第1名的商品id是：2078005，浏览次数是：1第2名的商品id是：4863774，浏览次数是：1第3名的商品id是：2422213，浏览次数是：1窗口结束时间：2017112611：35：00。0第1名的商品id是：2560087，浏览次数是：1第2名的商品id是：2422213，浏览次数是：1第3名的商品id是：485633，浏览次数是：1窗口结束时间：2017112611：40：00。0第1名的商品id是：2422213，浏览次数是：1第2名的商品id是：1734346，浏览次数是：1第3名的商品id是：485633，浏览次数是：1窗口结束时间：2017112611：45：00。0第1名的商品id是：6524，浏览次数是：1第2名的商品id是：574681，浏览次数是：1第3名的商品id是：546337，浏览次数是：1窗口结束时间：2017112611：50：00。0第1名的商品id是：2422213，浏览次数是：1第2名的商品id是：1591165，浏览次数是：1第3名的商品id是：602145，浏览次数是：1窗口结束时间：2017112611：55：00。0第1名的商品id是：905609，浏览次数是：1第2名的商品id是：4164690，浏览次数是：1第3名的商品id是：4611037，浏览次数是：1窗口结束时间：2017112612：00：00。0第1名的商品id是：2422213，浏览次数是：1第2名的商品id是：1853754，浏览次数是：1第3名的商品id是：2347538，浏览次数是：1窗口结束时间：2017112612：05：00。0第1名的商品id是：4649743，浏览次数是：1第2名的商品id是：1853754，浏览次数是：1第3名的商品id是：2347538，浏览次数是：1窗口结束时间：2017112612：10：00。0第1名的商品id是：3250004，浏览次数是：1第2名的商品id是：2347538，浏览次数是：1第3名的商品id是：3468397，浏览次数是：1窗口结束时间：2017112612：15：00。0第1名的商品id是：469241，浏览次数是：1第2名的商品id是：4944787，浏览次数是：1第3名的商品id是：2347538，浏览次数是：1窗口结束时间：2017112612：20：00。0第1名的商品id是：2347538，浏览次数是：1第2名的商品id是：2856510，浏览次数是：1第3名的商品id是：2723221，浏览次数是：1窗口结束时间：2017112612：25：00。0第1名的商品id是：2723221，浏览次数是：1第2名的商品id是：2347538，浏览次数是：1第3名的商品id是：3698827，浏览次数是：1窗口结束时间：2017112612：30：00。0第1名的商品id是：2723221，浏览次数是：1第2名的商品id是：2343683，浏览次数是：1第3名的商品id是：2347538，浏览次数是：1窗口结束时间：2017112612：35：00。0第1名的商品id是：2723221，浏览次数是：1第2名的商品id是：2347538，浏览次数是：1第3名的商品id是：4123299，浏览次数是：1窗口结束时间：2017112612：40：00。0第1名的商品id是：452391，浏览次数是：1第2名的商品id是：3382626，浏览次数是：1第3名的商品id是：135950，浏览次数是：1窗口结束时间：2017112612：45：00。0第1名的商品id是：2424023，浏览次数是：1第2名的商品id是：135950，浏览次数是：1第3名的商品id是：2700369，浏览次数是：1窗口结束时间：2017112612：50：00。0第1名的商品id是：135950，浏览次数是：1第2名的商品id是：3268515，浏览次数是：1第3名的商品id是：2019254，浏览次数是：1窗口结束时间：2017112612：55：00。0第1名的商品id是：2804460，浏览次数是：1第2名的商品id是：577342，浏览次数是：1第3名的商品id是：1142684，浏览次数是：1窗口结束时间：2017112613：00：00。0第1名的商品id是：3613081，浏览次数是：1第2名的商品id是：135950，浏览次数是：1第3名的商品id是：1027421，浏览次数是：1窗口结束时间：2017112613：05：00。0第1名的商品id是：1027421，浏览次数是：1第2名的商品id是：1926775，浏览次数是：1第3名的商品id是：135950，浏览次数是：1窗口结束时间：2017112613：10：00。0第1名的商品id是：1926775，浏览次数是：1第2名的商品id是：1027421，浏览次数是：1第3名的商品id是：3839913，浏览次数是：1窗口结束时间：2017112613：15：00。0第1名的商品id是：1926775，浏览次数是：1第2名的商品id是：1027421，浏览次数是：1第3名的商品id是：1835955，浏览次数是：1窗口结束时间：2017112613：20：00。0第1名的商品id是：2720662，浏览次数是：1第2名的商品id是：1835955，浏览次数是：1第3名的商品id是：1929997，浏览次数是：1窗口结束时间：2017112613：25：00。0第1名的商品id是：5150918，浏览次数是：1第2名的商品id是：1835955，浏览次数是：1第3名的商品id是：3928189，浏览次数是：1窗口结束时间：2017112613：30：00。0第1名的商品id是：1835955，浏览次数是：1第2名的商品id是：2060116，浏览次数是：1第3名的商品id是：2521128，浏览次数是：1窗口结束时间：2017112613：35：00。0第1名的商品id是：5150918，浏览次数是：1第2名的商品id是：1300827，浏览次数是：1第3名的商品id是：2060116，浏览次数是：1窗口结束时间：2017112613：40：00。0第1名的商品id是：340143，浏览次数是：1第2名的商品id是：2060116，浏览次数是：1第3名的商品id是：1835955，浏览次数是：1窗口结束时间：2017112613：45：00。0第1名的商品id是：513749，浏览次数是：1第2名的商品id是：2060116，浏览次数是：1第3名的商品id是：1835955，浏览次数是：1窗口结束时间：2017112613：50：00。0第1名的商品id是：4650468，浏览次数是：1第2名的商品id是：2060116，浏览次数是：1第3名的商品id是：1835955，浏览次数是：1窗口结束时间：2017112613：55：00。0第1名的商品id是：513749，浏览次数是：1第2名的商品id是：1728662，浏览次数是：1第3名的商品id是：2546377，浏览次数是：1窗口结束时间：2017112614：00：00。0第1名的商品id是：2923435，浏览次数是：1第2名的商品id是：4171073，浏览次数是：1第3名的商品id是：274952，浏览次数是：1窗口结束时间：2017112614：05：00。0第1名的商品id是：232878，浏览次数是：1第2名的商品id是：274952，浏览次数是：1第3名的商品id是：3846404，浏览次数是：1窗口结束时间：2017112614：10：00。0第1名的商品id是：1717631，浏览次数是：1第2名的商品id是：495039，浏览次数是：1第3名的商品id是：274952，浏览次数是：1窗口结束时间：2017112614：15：00。0第1名的商品id是：1947553，浏览次数是：1第2名的商品id是：274952，浏览次数是：1第3名的商品id是：1459382，浏览次数是：1窗口结束时间：2017112614：20：00。0第1名的商品id是：4822390，浏览次数是：1第2名的商品id是：274952，浏览次数是：1第3名的商品id是：39330，浏览次数是：1窗口结束时间：2017112614：25：00。0第1名的商品id是：2182145，浏览次数是：1第2名的商品id是：1459382，浏览次数是：1第3名的商品id是：5158468，浏览次数是：1窗口结束时间：2017112614：30：00。0第1名的商品id是：274952，浏览次数是：1第2名的商品id是：1459382，浏览次数是：1第3名的商品id是：2453703，浏览次数是：1窗口结束时间：2017112614：35：00。0第1名的商品id是：1056273，浏览次数是：1第2名的商品id是：274952，浏览次数是：1第3名的商品id是：1459382，浏览次数是：1窗口结束时间：2017112614：40：00。0第1名的商品id是：1459382，浏览次数是：1第2名的商品id是：1351520，浏览次数是：1第3名的商品id是：1887742，浏览次数是：1窗口结束时间：2017112614：45：00。0第1名的商品id是：3787445，浏览次数是：1第2名的商品id是：3302466，浏览次数是：1第3名的商品id是：1459382，浏览次数是：1窗口结束时间：2017112614：50：00。0第1名的商品id是：3186978，浏览次数是：1第2名的商品id是：1459382，浏览次数是：1第3名的商品id是：4585156，浏览次数是：1窗口结束时间：2017112614：55：00。0第1名的商品id是：1459382，浏览次数是：1第2名的商品id是：1887742，浏览次数是：1第3名的商品id是：1755041，浏览次数是：1窗口结束时间：2017112615：00：00。0第1名的商品id是：1459382，浏览次数是：1第2名的商品id是：2820520，浏览次数是：1第3名的商品id是：4719604，浏览次数是：1窗口结束时间：2017112615：05：00。0第1名的商品id是：1459382，浏览次数是：1第2名的商品id是：1887742，浏览次数是：1第3名的商品id是：4342434，浏览次数是：1窗口结束时间：2017112615：10：00。0第1名的商品id是：1568206，浏览次数是：1第2名的商品id是：624903，浏览次数是：1第3名的商品id是：362796，浏览次数是：1窗口结束时间：2017112615：15：00。0第1名的商品id是：4350288，浏览次数是：1第2名的商品id是：2420534，浏览次数是：1第3名的商品id是：234805，浏览次数是：1窗口结束时间：2017112615：20：00。0第1名的商品id是：2023716，浏览次数是：1第2名的商品id是：935229，浏览次数是：1第3名的商品id是：1989489，浏览次数是：1窗口结束时间：2017112615：25：00。0第1名的商品id是：956921，浏览次数是：1第2名的商品id是：1224487，浏览次数是：1第3名的商品id是：1687681，浏览次数是：1窗口结束时间：2017112615：30：00。0第1名的商品id是：1061251，浏览次数是：1第2名的商品id是：1317129，浏览次数是：1第3名的商品id是：1803389，浏览次数是：1窗口结束时间：2017112615：35：00。0第1名的商品id是：4153921，浏览次数是：1第2名的商品id是：1252555，浏览次数是：1第3名的商品id是：234077，浏览次数是：1窗口结束时间：2017112615：40：00。0第1名的商品id是：2415944，浏览次数是：1第2名的商品id是：3860645，浏览次数是：1第3名的商品id是：3705929，浏览次数是：1窗口结束时间：2017112615：45：00。0第1名的商品id是：3445990，浏览次数是：1第2名的商品id是：3548305，浏览次数是：1第3名的商品id是：2862622，浏览次数是：1窗口结束时间：2017112615：50：00。0第1名的商品id是：3705929，浏览次数是：1第2名的商品id是：4402437，浏览次数是：1第3名的商品id是：4348177，浏览次数是：1窗口结束时间：2017112615：55：00。0第1名的商品id是：167862，浏览次数是：1第2名的商品id是：3329119，浏览次数是：1第3名的商品id是：3636313，浏览次数是：1窗口结束时间：2017112616：00：00。0第1名的商品id是：2309950，浏览次数是：1第2名的商品id是：2274457，浏览次数是：1第3名的商品id是：1780899，浏览次数是：1窗口结束时间：2017112616：05：00。0第1名的商品id是：4256250，浏览次数是：1第2名的商品id是：2500039，浏览次数是：1第3名的商品id是：2340232，浏览次数是：1窗口结束时间：2017112616：10：00。0第1名的商品id是：4313897，浏览次数是：1第2名的商品id是：3234987，浏览次数是：1第3名的商品id是：12350，浏览次数是：1窗口结束时间：2017112616：15：00。0第1名的商品id是：4227361，浏览次数是：1第2名的商品id是：3427755，浏览次数是：1第3名的商品id是：2488464，浏览次数是：1窗口结束时间：2017112616：20：00。0第1名的商品id是：4712719，浏览次数是：1第2名的商品id是：2420781，浏览次数是：1第3名的商品id是：2767425，浏览次数是：1窗口结束时间：2017112616：25：00。0第1名的商品id是：2170071，浏览次数是：1第2名的商品id是：4545392，浏览次数是：1第3名的商品id是：2393386，浏览次数是：1窗口结束时间：2017112616：30：00。0第1名的商品id是：221237，浏览次数是：1第2名的商品id是：2186395，浏览次数是：1第3名的商品id是：3028050，浏览次数是：1窗口结束时间：2017112616：35：00。0第1名的商品id是：4473466，浏览次数是：1第2名的商品id是：2331757，浏览次数是：1第3名的商品id是：3134181，浏览次数是：1窗口结束时间：2017112616：40：00。0第1名的商品id是：2331757，浏览次数是：1第2名的商品id是：5148005，浏览次数是：1第3名的商品id是：4761840，浏览次数是：1窗口结束时间：2017112616：45：00。0第1名的商品id是：17262，浏览次数是：1第2名的商品id是：826593，浏览次数是：1第3名的商品id是：1727321，浏览次数是：1窗口结束时间：2017112616：50：00。0第1名的商品id是：898116，浏览次数是：1第2名的商品id是：815377，浏览次数是：1第3名的商品id是：55238，浏览次数是：1窗口结束时间：2017112616：55：00。0第1名的商品id是：4242833，浏览次数是：1第2名的商品id是：326593，浏览次数是：1第3名的商品id是：2465281，浏览次数是：1窗口结束时间：2017112617：00：00。0第1名的商品id是：2605467，浏览次数是：1第2名的商品id是：4894663，浏览次数是：1第3名的商品id是：945999，浏览次数是：1窗口结束时间：2017112617：05：00。0第1名的商品id是：2806210，浏览次数是：1第2名的商品id是：4894352，浏览次数是：1第3名的商品id是：2572397，浏览次数是：1窗口结束时间：2017112617：10：00。0第1名的商品id是：2822277，浏览次数是：1第2名的商品id是：571603，浏览次数是：1第3名的商品id是：3272727，浏览次数是：1窗口结束时间：2017112617：15：00。0第1名的商品id是：2257069，浏览次数是：1第2名的商品id是：5112343，浏览次数是：1第3名的商品id是：394978，浏览次数是：1窗口结束时间：2017112617：20：00。0第1名的商品id是：1909165，浏览次数是：1第2名的商品id是：2703796，浏览次数是：1第3名的商品id是：1980891，浏览次数是：1窗口结束时间：2017112617：25：00。0第1名的商品id是：1648263，浏览次数是：1第2名的商品id是：2819476，浏览次数是：1第3名的商品id是：4773596，浏览次数是：1窗口结束时间：2017112617：30：00。0第1名的商品id是：3683596，浏览次数是：1第2名的商品id是：676804，浏览次数是：1第3名的商品id是：2090451，浏览次数是：1窗口结束时间：2017112617：35：00。0第1名的商品id是：5156932，浏览次数是：1第2名的商品id是：676804，浏览次数是：1第3名的商品id是：5042197，浏览次数是：1窗口结束时间：2017112617：40：00。0第1名的商品id是：948860，浏览次数是：1第2名的商品id是：938653，浏览次数是：1第3名的商品id是：4983419，浏览次数是：1窗口结束时间：2017112617：45：00。0第1名的商品id是：938653，浏览次数是：1第2名的商品id是：2247117，浏览次数是：1第3名的商品id是：1561974，浏览次数是：1窗口结束时间：2017112617：50：00。0第1名的商品id是：147659，浏览次数是：1第2名的商品id是：1270816，浏览次数是：1第3名的商品id是：292317，浏览次数是：1窗口结束时间：2017112617：55：00。0第1名的商品id是：938653，浏览次数是：1第2名的商品id是：2068397，浏览次数是：1第3名的商品id是：522620，浏览次数是：1窗口结束时间：2017112618：00：00。0第1名的商品id是：4455955，浏览次数是：1第2名的商品id是：2798214，浏览次数是：1第3名的商品id是：3631789，浏览次数是：1窗口结束时间：2017112618：05：00。0第1名的商品id是：3910585，浏览次数是：1第2名的商品id是：3631789，浏览次数是：1第3名的商品id是：3399340，浏览次数是：1窗口结束时间：2017112618：10：00。0第1名的商品id是：3719602，浏览次数是：1第2名的商品id是：2068397，浏览次数是：1第3名的商品id是：441764，浏览次数是：1窗口结束时间：2017112618：15：00。0第1名的商品id是：4794421，浏览次数是：1第2名的商品id是：2265283，浏览次数是：1第3名的商品id是：2068397，浏览次数是：1窗口结束时间：2017112618：20：00。0第1名的商品id是：2085791，浏览次数是：1第2名的商品id是：2020365，浏览次数是：1第3名的商品id是：4135873，浏览次数是：1窗口结束时间：2017112618：25：00。0第1名的商品id是：1823649，浏览次数是：1第2名的商品id是：816118，浏览次数是：1第3名的商品id是：80134，浏览次数是：1窗口结束时间：2017112618：30：00。0第1名的商品id是：2777271，浏览次数是：1第2名的商品id是：405764，浏览次数是：1第3名的商品id是：1054769，浏览次数是：1窗口结束时间：2017112618：35：00。0第1名的商品id是：4900292，浏览次数是：1第2名的商品id是：3631789，浏览次数是：1第3名的商品id是：4381701，浏览次数是：1窗口结束时间：2017112618：40：00。0第1名的商品id是：4113700，浏览次数是：1第2名的商品id是：4888386，浏览次数是：1第3名的商品id是：4736510，浏览次数是：1窗口结束时间：2017112618：45：00。0第1名的商品id是：826110，浏览次数是：1第2名的商品id是：2091848，浏览次数是：1第3名的商品id是：4959723，浏览次数是：1窗口结束时间：2017112618：50：00。0第1名的商品id是：3508317，浏览次数是：1第2名的商品id是：3593205，浏览次数是：1第3名的商品id是：2808043，浏览次数是：1窗口结束时间：2017112618：55：00。0第1名的商品id是：2463819，浏览次数是：1第2名的商品id是：2115271，浏览次数是：1第3名的商品id是：4193531，浏览次数是：1窗口结束时间：2017112619：00：00。0第1名的商品id是：2065878，浏览次数是：1第2名的商品id是：3715576，浏览次数是：1第3名的商品id是：4310064，浏览次数是：1Processfinishedwithexitcode0