当前位置: 首页 > news >正文

班级网站建设php专业网站建设哪家效果好

班级网站建设php,专业网站建设哪家效果好,淘宝不能发布网站开发了,服务好的南京网站建设Flink Python快速入门_实时计算 Flink版(Flink)-阿里云帮助中心 import argparse # 用于处理命令行参数和选项#xff0c;使程序能够接收用户通过命令行传递的参数 import logging import sysfrom pyflink.common import WatermarkStrategy, Encoder, Types from pyflink.data…Flink Python快速入门_实时计算 Flink版(Flink)-阿里云帮助中心 import argparse # 用于处理命令行参数和选项使程序能够接收用户通过命令行传递的参数 import logging import sysfrom pyflink.common import WatermarkStrategy, Encoder, Types from pyflink.datastream import StreamExecutionEnvironment, RuntimeExecutionMode from pyflink.datastream.connectors import (FileSource, StreamFormat, FileSink, OutputFileConfig,RollingPolicy)# WatermarkStrategy: 用于生成水印watermarks水印是用于处理事件时间event time的数据流中的延迟数据的一种机制。 # Encoder: 用于定义如何将数据编码为字节序列通常用于数据的序列化和反序列化。 # Types: 包含了 Flink 中各种数据类型的定义用于指定数据流中数据的类型。 # StreamExecutionEnvironment: 是所有 Flink 流处理程序的入口点用于配置和启动流处理任务。 # RuntimeExecutionMode: 定义了流处理任务的执行模式例如批处理模式或流处理模式。 # FileSource: 用于从文件系统中读取数据源。 # StreamFormat: 定义了数据的格式例如 CSV、JSON 等。 # FileSink: 用于将数据写入文件系统。 # OutputFileConfig: 配置输出文件的相关设置如前缀和后缀。 # RollingPolicy: 定义了文件滚动策略即何时创建新的输出文件。word_count_data [To be, or not to be,--that is the question:--,Whether tis nobler in the mind to suffer,The slings and arrows of outrageous fortune,Or to take arms against a sea of troubles,,And by opposing end them?--To die,--to sleep,--,No more; and by a sleep to say we end,The heartache, and the thousand natural shocks,That flesh is heir to,--tis a consummation,Devoutly to be wishd. To die,--to sleep;--,To sleep! perchance to dream:--ay, theres the rub;,For in that sleep of death what dreams may come,,When we have shuffled off this mortal coil,,Must give us pause: theres the respect,That makes calamity of so long life;,For who would bear the whips and scorns of time,,The oppressors wrong, the proud mans contumely,,The pangs of despisd love, the laws delay,,The insolence of office, and the spurns,That patient merit of the unworthy takes,,When he himself might his quietus make,With a bare bodkin? who would these fardels bear,,To grunt and sweat under a weary life,,But that the dread of something after death,--,The undiscoverd country, from whose bourn,No traveller returns,--puzzles the will,,And makes us rather bear those ills we have,Than fly to others that we know not of?,Thus conscience does make cowards of us all;,And thus the native hue of resolution,Is sicklied oer with the pale cast of thought;,And enterprises of great pith and moment,,With this regard, their currents turn awry,,And lose the name of action.--Soft you now!,The fair Ophelia!--Nymph, in thy orisons,Be all my sins rememberd.]def word_count(input_path, output_path):计算文本文件中单词的频率并将结果输出到指定路径。该函数从指定的输入路径读取文本数据进行单词频率统计并将结果写入指定的输出路径。如果没有提供输入路径或输出路径则使用默认数据或直接打印结果。参数:- input_path: 输入文本文件的路径。如果为None则使用默认数据。- output_path: 输出结果的路径。如果为None则直接打印结果。# 获取流处理环境并设置为流处理模式设置并行度为1env StreamExecutionEnvironment.get_execution_environment()env.set_runtime_mode(RuntimeExecutionMode.STREAMING)env.set_parallelism(1)# 定义数据源if input_path is not None:# 从文件系统中读取数据ds env.from_source(sourceFileSource.for_record_stream_format(StreamFormat.text_line_format(),input_path).process_static_file_set().build(),watermark_strategyWatermarkStrategy.for_monotonous_timestamps(),source_namefile_source)else:# 使用默认数据ds env.from_collection(word_count_data)# 定义分割函数将每行文本分割成单词def split(line):yield from line.split()# 计算单词频率ds ds.flat_map(split) \.map(lambda i: (i, 1), output_typeTypes.TUPLE([Types.STRING(), Types.INT()])) \.key_by(lambda i: i[0]) \.reduce(lambda i, j: (i[0], i[1] j[1]))# 定义数据汇if output_path is not None:# 将结果写入文件系统ds.sink_to(sinkFileSink.for_row_format(base_pathoutput_path,encoderEncoder.simple_string_encoder()).with_output_file_config(OutputFileConfig.builder().with_part_prefix(prefix).with_part_suffix(.ext).build()).with_rolling_policy(RollingPolicy.default_rolling_policy()).build())else:# 直接打印结果ds.print()# 提交作业以执行env.execute()if __name__ __main__:# 配置日志输出到标准输出设置日志级别为INFO并格式化日志消息以仅显示消息内容logging.basicConfig(streamsys.stdout, levellogging.INFO, format%(message)s)# 创建一个ArgumentParser对象以处理命令行参数parser argparse.ArgumentParser()# 添加可选的命令行参数用于指定输入和输出文件parser.add_argument(--input,destinput,requiredFalse,help要处理的输入文件。)parser.add_argument(--output,destoutput,requiredFalse,help要写入结果的输出文件。)# 获取命令行参数排除脚本名称argv sys.argv[1:]print(Command line arguments: , argv)# 解析已知的命令行参数并忽略未知参数known_args, _ parser.parse_known_args(argv)print(known_args: , known_args)# 调用word_count函数传入从解析参数中获取的输入和输出文件路径word_count(known_args.input, known_args.output)
http://www.yingshimen.cn/news/46619/

相关文章:

  • 淘宝上做淘宝客的网站wordpress标题收起
  • 如何做自己公司网站网站建设推广费计入什么科目
  • js网站记住密码怎么做免费网站生成
  • 柳州专业网站优化专业的网站建设服务商
  • 临沂企业建站模板免费建立网站的软件
  • 成都网站制作成都word 发布 wordpress
  • 网站建设描述怎么写免费制作主图的网站
  • 郑州家居网站建设服务公司无需注册免费的网站
  • 网站上线后想修改网上做任务的网站有哪些内容
  • 网站建设与管理课程中学生做网站的软件
  • 专门做进口零食的网站西安网站建设需要多少钱
  • 大连建设主管部门网站长沙网站关键词排名
  • 如何建设网站脱颖而出logo在线设计生成器小程序
  • 制作网站的公司出国做网站工作
  • 北京门户网站制作wordpress利用工具
  • 网站ftp的所有权归谁东莞网络推广优化排名
  • 不用关网站备案wordpress数据备份还原
  • 上门做美容的有什么网站婚庆公司策划书
  • 厦门网站定制泸县手机网站建设
  • 网站功能模版辽阳网站设计
  • 做神马网站温州企业做网站
  • 网站域名迁移公告沥林行业网站建设
  • 广东省建设注册执业资格中心网站展示网站报价
  • 英文版网站制作百度海南分公司
  • 传媒大学附近网站建设公司网站a记录的是做cname
  • 深圳定制网站制作咨询电话wordpress自动采集文章
  • h5响应式网站技术上海装修公司排名391
  • 营销型企业网站的含义比较权威的房产网站
  • 上不了建设银行网站网站建设维护是干什么
  • 加快建设乡镇招商网站手机软件开发公司简介