医院挂号系统源码(含数据库).pdf
2.虚拟产品一经售出概不退款(资源遇到问题,请及时私信上传者)
医院挂号系统源码(含数据库) 本系统经过多年应⽤并且持续不断改进,系统各部功能已基本完善,⾮常适合⼤型医疗集团,当然⼩型医院或科室就更适合了。 ⽂件:(访问密码:551685) 以下内容⽆关: -------------------------------------------分割线--------------------------------------------- Flink的API做了4层的封装,上两层TableAPI、SQL语法相对简单便于编写,⾯对⼩需求可以快速上⼿解决,本⽂参考官⽹及部分线上教程 编写source端、sink端代码,分别读取socket、kafka及⽂本作为source,并将流数据输出写⼊Kafka、ES及MySQL,⽅便后续查看使 ⽤。 ⼆、代码部分 说明:这⾥使⽤connect及DDL两种写法,connect满⾜Flink1.10及以前版本使⽤,⽬前官⽅⽂档均是以DDL写法作为介绍,建议1.10以 后的版本使⽤DDL写法操作,通⽤性更强。 1.读取(Source)端写法 1.1 基础环境建⽴,⽅便演⽰并⾏度为1且不设置CK //建⽴Stream环境,设置并⾏度为1 StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment().setParallelism(1); //建⽴Table环境 StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env); 1.2 读取Socket端⼝数据,并使⽤TableAPI及SQL两种⽅式查询 //读取服务器9999端⼝数据,并转换为对应JavaBean SingleOutputStreamOperator mapDS = env.socketTextStream("hadoop102", 9999) .map(value -> { String[] split = value.split(","); return new WaterSensor(split[0] , Long.parseLong(split[1]) , Integer.parseInt(split[2]));}); //创建表:将流转换成动态表。 Table table = tableEnv.fromDataStream(mapDS); //对动态表进⾏查询,TableAPI⽅式 Table selectResult = table.where( ("id"), $("ts"), $("vc")); //对动态表镜像查询,SQL⽅式-未注册表 Table selectResult = tableEnv.sqlQuery("select * from " + table); 1.3 读取⽂本(FileSystem)数据,并使⽤TableAPI进⾏查询 //Flink1.10写法使⽤connect⽅式,读取txt⽂件并建⽴临时表 tableEnv.connect(new FileSystem().path("input/sensor.txt")) .withFormat(new Csv().fieldDelimiter(',').lineDelimiter("\n")) .withSchema(new Schema().field("id", DataTypes.STRING()) .field("ts", DataTypes.BIGINT()) .field("vc",DataTypes.INT())) .createTemporaryTable("sensor"); //转换成表对象,对表进⾏查询。SQL写法参考Socket段写法 Table table = tableEnv.from("sensor"); Table selectResult = table.groupBy( ("id").count().as("id_count"))select($("id"), $("id_count")); 1.4 消费Kafka数据,并使⽤TableAPI进⾏查询,分别⽤conncet及DDL写法 ("id").isEqual("ws 01")).select( 0 ("id")).aggregate( //Flink1.10写法使⽤connect⽅式,消费kafka对应主题并建⽴临时表 tableEnv.connect(new Kafka().version("universal") .topic("sensor") .startFromLatest() .property(ConsumerConfig.BOO
- 凤舞斜阳草2024-03-06资源不错,内容挺好的,有一定的使用价值,值得借鉴,感谢分享。
- 粉丝: 168
- 资源: 3万+
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助