/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.shangjack.flink.windowing.util;
/**
* Data for TopSpeedWindowingExampleITCase.
*/
public class TopSpeedWindowingExampleData {
public static final String CAR_DATA =
"(0,55,15.277777777777777,1424951918630)\n" + "(1,45,12.5,1424951918632)\n" +
"(0,50,29.166666666666664,1424951919632)\n" + "(1,50,26.38888888888889,1424951919632)\n" +
"(0,55,44.44444444444444,1424951920633)\n" + "(1,45,38.888888888888886,1424951920633)\n" +
"(0,50,58.33333333333333,1424951921634)\n" + "(1,40,50.0,1424951921634)\n" +
"(0,55,73.6111111111111,1424951922634)\n" + "(1,35,59.72222222222222,1424951922634)\n" +
"(0,60,90.27777777777777,1424951923634)\n" + "(1,40,70.83333333333333,1424951923634)\n" +
"(0,65,108.33333333333333,1424951924635)\n" + "(1,35,80.55555555555554,1424951924635)\n" +
"(0,60,125.0,1424951925635)\n" + "(1,40,91.66666666666666,1424951925635)\n" +
"(0,55,140.27777777777777,1424951926635)\n" + "(1,45,104.16666666666666,1424951926636)\n" +
"(0,60,156.94444444444443,1424951927636)\n" + "(1,50,118.05555555555554,1424951927636)\n" +
"(0,55,172.2222222222222,1424951928636)\n" + "(1,45,130.55555555555554,1424951928636)\n" +
"(0,50,186.1111111111111,1424951929636)\n" + "(1,50,144.44444444444443,1424951929637)\n" +
"(0,55,201.38888888888886,1424951930637)\n" + "(1,55,159.7222222222222,1424951930637)\n" +
"(0,60,218.05555555555551,1424951931637)\n" + "(1,60,176.38888888888886,1424951931637)\n" +
"(0,55,233.3333333333333,1424951932637)\n" + "(1,65,194.4444444444444,1424951932638)\n" +
"(0,50,247.22222222222217,1424951933638)\n" + "(1,70,213.88888888888886,1424951933638)\n" +
"(0,45,259.7222222222222,1424951934638)\n" + "(1,65,231.9444444444444,1424951934638)\n" +
"(0,50,273.6111111111111,1424951935638)\n" + "(1,70,251.38888888888886,1424951935639)\n" +
"(0,55,288.88888888888886,1424951936639)\n" + "(1,75,272.2222222222222,1424951936639)\n" +
"(0,50,302.77777777777777,1424951937639)\n" + "(1,70,291.66666666666663,1424951937639)\n" +
"(0,45,315.27777777777777,1424951938640)\n" + "(1,65,309.7222222222222,1424951938640)\n" +
"(0,50,329.1666666666667,1424951939640)\n" + "(1,70,329.16666666666663,1424951939640)\n" +
"(0,55,344.44444444444446,1424951940640)\n" + "(1,65,347.2222222222222,1424951940640)\n" +
"(0,50,358.33333333333337,1424951941641)\n" + "(1,70,366.66666666666663,1424951941641)\n" +
"(0,55,373.61111111111114,1424951942641)\n" + "(1,65,384.7222222222222,1424951942641)\n" +
"(0,50,387.50000000000006,1424951943641)\n" + "(1,70,404.16666666666663,1424951943641)\n" +
"(0,45,400.00000000000006,1424951944642)\n" + "(1,65,422.2222222222222,1424951944642)\n" +
"(0,50,413.88888888888897,1424951945642)\n" + "(1,60,438.88888888888886,1424951945642)\n" +
"(0,45,426.38888888888897,1424951946642)\n" + "(1,65,456.9444444444444,1424951946642)\n" +
"(0,40,437.50000000000006,1424951947643)\n" + "(1,70,476.38888888888886,1424951947643)\n" +
"(0,45,450.00000000000006,1424951948643)\n" + "(1,75,497.2222222222222,1424951948643)\n" +
"(0,40,461.11111111111114,1424951949643)\n" + "(1,80,519.4444444444443,1424951949644)\n" +
"(0,45,473.61111111111114,1424951950644)\n" + "(1,75,540.2777777777777,1424951950644)\n" +
"(0,50,487.50000000000006,1424951951644)\n" + "(1,80,562.4999999999999,1424951951644)\n" +
"(0,45,500.00000000000006,1424951952644)\n" + "(1,85,586.111111111111,1424951952645)\n" +
"(0,40,511.11111111111114,1424951953645)\n" + "(1,80,608.3333333333331,1424951953645)\n" +
"(0,35,520.8333333333334,1424951954645)\n" + "(1,75,629.1666666666665,1424951954645)\n" +
"(0,40,531.9444444444445,1424951955645)\n" + "(1,70,648.611111111111,1424951955646)\n" +
"(0,45,544.4444444444445,1424951956646)\n" + "(1,75,669.4444444444443,1424951956646)\n" +
"(0,50,558.3333333333334,1424951957646)\n" + "(1,80,691.6666666666665,1424951957646)\n" +
"(0,55,573.6111111111112,1424951958646)\n" + "(1,85,715.2777777777776,1424951958647)\n" +
"(0,60,590.2777777777778,1424951959647)\n" + "(1,80,737.4999999999998,1424951959647)\n" +
"(0,65,608.3333333333334,1424951960647)\n" + "(1,85,761.1111111111109,1424951960647)\n" +
"(0,70,627.7777777777778,1424951961647)\n" + "(1,80,783.333333333333,1424951961648)\n" +
"(0,75,648.6111111111112,1424951962648)\n" + "(1,85,806.9444444444441,1424951962648)\n" +
"(0,80,670.8333333333334,1424951963648)\n" + "(1,90,831.9444444444441,1424951963648)\n" +
"(0,75,691.6666666666667,1424951964649)\n" + "(1,95,858.333333333333,1424951964649)\n" +
"(0,70,711.1111111111112,1424951965649)\n" + "(1,90,883.333333333333,1424951965649)\n" +
"(0,75,731.9444444444446,1424951966649)\n" + "(1,95,909.722222222222,1424951966649)\n" +
"(0,70,751.388888888889,1424951967649)\n" + "(1,100,937.4999999999998,1424951967650)\n" +
"(0,75,772.2222222222224,1424951968650)\n" + "(1,100,965.2777777777776,1424951968650)\n" +
"(0,80,794.4444444444446,1424951969650)\n" + "(1,100,993.0555555555554,1424951969650)\n" +
"(0,75,815.2777777777779,1424951970651)\n" + "(1,100,1020.8333333333333,1424951970651)\n" +
"(0,80,837.5000000000001,1424951971651)\n" + "(1,100,1048.611111111111,1424951971651)\n" +
"(0,85,861.1111111111112,1424951972651)\n" + "(1,100,1076.388888888889,1424951972651)\n" +
"(0,80,883.3333333333334,1424951973652)\n" + "(1,95,1102.7777777777778,1424951973652)\n" +
"(0,75,904.1666666666667,1424951974652)\n" + "(1,100,1130.5555555555557,1424951974652)\n" +
"(0,70,923.6111111111112,1424951975652)\n" + "(1,100,1158.3333333333335,1424951975652)\n" +
"(0,75,944.4444444444446,1424951976653)\n" + "(1,100,1186.1111111111113,1424951976653)\n" +
"(0,80,966.6666666666667,1424951977653)\n" + "(1,95,1212.5000000000002,1424951977653)\n" +
"(0,75,987.5000000000001,1424951978653)\n" + "(1,100,1240.277777777778,1424951978653)\n" +
"(0,80,1009.7222222222223,1424951979654)\n" + "(1,100,1268.0555555555559,1424951979654)\n" +
"(0,85,1033.3333333333335,1424951980654)\n" + "(1,100,1295.8333333333337,1424951980654)\n" +
"(0,90,1058.3333333333335,1424951981654)\n" + "(1,100,1323.6111111111115,1424951981654)\n" +
"(0,85,1081.9444444444446,1424951982655)\n" + "(1,100,1351.3888888888894,1424951982655)\n" +
"(0,90,1106.9444444444446,1424951983655)\n" + "(1,100,1379.1666666666672,1424951983655)\n" +
"(0,95,1133.3333333333335,1424951984655)\n" + "(1,100,1406.944444444445,1424951984656)\n" +
"(0,90,1158.3333333333335,1424951985656)\n" + "(1,95,1433.333333333334,1424951985656)\n" +
"(0,95,1184.7222222222224,1424951986656)\n" + "(1,90,1458.333333333334,1424951986656)\n" +
"(0,90,1209.7222222222224,1424951987656)\n" + "(1,95,1484.7222222222229,1424951987657)\n" +
"(0,85,1233.3333333333335,1424951988657)\n" + "(1,90,1509.7222222222229,1424951988657)\n" +
"(0,80,1255.5555555555557,1424951989657)\n" + "(1,95,1536.1111111111118,1424951989657)\n" +
"(0,85,1279.1666666666667,1424951990657)\n
flink datastream api 示例大全
需积分: 5 97 浏览量
2023-10-19
15:21:21
上传
评论 5
收藏 198KB RAR 举报
flink datastream api 示例大全 （253个子文件） 
TopSpeedWindowingExampleData.class 14KB AsyncIOExample.class 7KB TopSpeedWindowing.class 6KB StreamingWithWindowJoinExample.class 6KB StreamingWithSideOutputExample.class 6KB StreamingWithRedisSinkExample.class 5KB SessionWindowing.class 5KB StreamingWindowWatermark2.class 4KB AsyncIOExample$SampleAsyncFunction.class 4KB SocketWindowWordCount.class 4KB StreamingWindowWatermark2$4.class 4KB StreamingWindowWatermark$3.class 4KB StreamingWithKafkaSinkExample.class 4KB WindowWordCount.class 4KB SocketWindowWordCountJava.class 4KB StreamingKafkaSource.class 4KB StreamingWindowWatermark.class 4KB SocketDemoIncrAgg.class 3KB TopSpeedWindowing$CarSource.class 3KB GroupedProcessingTimeWindowExample.class 3KB StreamingDemoFilter.class 3KB StreamingDemoConnect.class 3KB StreamingDemoWithMyNoPralallelSourceBroadcast.class 3KB StreamingWindowWatermark$2.class 3KB StreamingDemoUnion.class 3KB AsyncIOExample$SimpleSource.class 3KB CustomRichParallelSource.class 3KB GroupedProcessingTimeWindowExample$DataSource.class 3KB StreamingWithSideOutputExample$Tokenizer.class 3KB GroupedProcessingTimeWindowExample$SummingWindowFunction.class 3KB StreamingWindowWatermark2$2.class 3KB StreamingDemoWithMyNoPralalleSource.class 3KB StreamingDemoWithMyPralalleSource.class 3KB StreamingDemoWithMyRichPralalleSource.class 3KB SteamingWithCustomPartitionerExample.class 3KB StreamingDemoSplit.class 3KB WindowJoinSampleData$SalarySource.class 3KB WindowJoinSampleData$GradeSource.class 3KB PojosClass.class 3KB SessionWindowing$1.class 3KB WordCountData.class 2KB StreamingFromCollection.class 2KB ThrottledIterator.class 2KB StringArrayWritable.class 2KB SocketDemoIncrAgg$2.class 2KB WordCount.class 2KB StreamingWithWindowJoinExample$1.class 2KB GroupedProcessingTimeWindowExample$SummingReducer.class 2KB StreamingWithRedisSinkExample$MyRedisMapper.class 2KB CustomParallelSource.class 2KB TopSpeedWindowing$ParseCarData.class 2KB SteamingWithCustomPartitionerExample$2.class 2KB WordCount$Tokenizer.class 2KB SocketWindowWordCountJava$1.class 2KB StreamingDemoWithMyPralalleSource$1.class 2KB SocketWindowWordCount$2.class 2KB TopSpeedWindowing$1.class 2KB AsyncIOExample$1.class 2KB TopSpeedWindowing$CarTimestamp.class 2KB StreamingWithWindowJoinExample$NameKeySelector.class 2KB StreamingDemoWithMyNoPralallelSourceBroadcast$1.class 2KB CustomNoParallelSource.class 2KB StreamingWindowWatermark2$1.class 2KB StreamingWindowWatermark$1.class 2KB SocketWindowWordCount$1.class 1KB StreamingDemoWithMyRichPralalleSource$1.class 1KB GroupedProcessingTimeWindowExample$FirstFieldKeyExtractor.class 1KB StreamingDemoWithMyNoPralalleSource$1.class 1KB SocketDemoIncrAgg$1.class 1KB StreamingDemoUnion$1.class 1KB StreamingDemoFilter$3.class 1KB StreamingDemoFilter$1.class 1KB StreamingDemoSplit$1.class 1KB GroupedProcessingTimeWindowExample$1.class 1KB PojosClass$AppendOne.class 1KB SteamingWithCustomPartitionerExample$1.class 1KB StreamingWithSideOutputExample$3.class 1KB StreamingDemoConnect$2.class 1KB StreamingDemoConnect$1.class 1KB CustomPartitioner.class 1KB StreamingWithSideOutputExample$2.class 1KB StreamingFromCollection$1.class 1KB SocketWindowWordCountJava$WordWithCount.class 1KB StreamingDemoFilter$2.class 1KB SocketWindowWordCount$WordWithCount.class 901B WindowJoinSampleData$SalarySource$1.class 886B WindowJoinSampleData$GradeSource$1.class 882B WindowJoinSampleData.class 834B StreamingWindowWatermark2$3.class 722B StreamingWithSideOutputExample$1.class 650B PojosClass$1.class 624B SessionWindowingData.class 468B flink-datastream-api.iml 13KB TopSpeedWindowingExampleData.java 18KB AsyncIOExample.java 10KB StreamingWindowWatermark2.java 6KB StreamingWithSideOutputExample.java 6KB TopSpeedWindowing.java 6KB StreamingWindowWatermark.java 6KB StreamingWithWindowJoinExample.java 4KB共 253 条
- 1
- 2
- 3
资源评论
shangjg3
- 粉丝: 1049
- 资源: 101
最新资源
- 基于python编写的Keras深度学习框架开发，利用卷积神经网络CNN,快速识别图片并进行分类
- 最全空间计量实证方法（空间杜宾模型和检验以及结果解释文档）.txt
- 5uonly.apk
- 蓝桥杯Python组的历年真题
- 2023-04-06-项目笔记 - 第一百十九阶段 - 4.4.2.117全局变量的作用域-117 -2024.04.30
- 2023-04-06-项目笔记 - 第一百十九阶段 - 4.4.2.117全局变量的作用域-117 -2024.04.30
- 前端开发技术实验报告：内含4四实验&实验报告
- Highlight Plus v20.0.1
- 林周瑜-论文.docx
- 基于MIC+NE555光敏电阻的声光控电路Multisim仿真原理图
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
