Stream

摘要： STREAM作为微处理器上广泛应用于测试各种计算机的内存性能的基准测试程序,如何使得其在FT2000/4处理器上发挥高性能是具有挑战性的研究工作。对STREAM工具的各参数进行测试并且合理的设置参数数值可以使得程序性能大幅度提高。数据测试结果表明,优化后,并行程序的最高访存性能能达到13.93GB/s,对比优化前的最高访存性能提高了56.34%。

摘要： 种植活动是幼儿亲近自然、探究动植物的科学探究活动,是幼儿园必不可少的活动之一。但幼儿园的种植活动普遍存在活动目标不够深入、幼儿的观察探究流于表面、缺乏连续性等问题。STREAM教育包括S(Science,科学)、T(Technology,技术)、R(Reading/Writing,读写)、E(Engineering,工程)、A(Arts,艺术)和M(Mathematics,数学)等方面,强调创造性地运用跨领域的视角与方法解决现实情境中的问题,能帮助幼儿在种植活动中连续、有效地深入探究。本文阐述了STREAM与幼儿发展及大班幼儿种植活动的联系,并以大班搭建豆苗藤架的活动为实例,提出了STREAM视域下大班幼儿种植活动的五项基本策略。

摘要： Surface water quality is largely influenced by both natural processes and anthropogenic inputs. This study involves the characterization of the concentration of heavy metals of Cd, Cr, Cu, Fe, Mn, Ni, Pb, and Zn, and the sources of pollution in water and sediment of the Upper Litani River Basin (ULRB) in Lebanon. The investigation was performed during three seasons of rainy, mid-rainy spring and wet periods for two years during different flow rates. Sediments were characterized by a set of chemical analyses, cation exchange capacity (CEC), mineralogy of the sediments, X-ray diffraction (XRD), and Fourier transformed infrared spectroscopy (FTIR). To assess metal contamination in sediment, Consensus-Based Sediment Quality Guidelines of Wisconsin (CBSQG) were applied. The metals contamination in the sediments was also evaluated by contamination factor (Cf). The test results showed that the effect of seasonal variations was significant in the Upper Litani River Basin. Principal Compound Analysis (PCA) and Pearson’s correlation were also performed in this study to compare and determine the correlation between metals in water and sediments. The concentrations of Pb, Cd, Cu, Cr and Zn in all sediment samples are above the norms in winter, while Fe was increased in summer. The results showed that the importance of monitoring of changes of heavy metals values and physico-chemical characterization of different parameters could represent the possibility of a comprehensive assessment of negative pressures on the water and soil ecosystem of Litani River Basin during different seasons.

摘要： STREAM跨学科教学虽然是在STEM与STEAM理念的基础上发展而来,但它对“智能+”教育时代的跨学科教学与人才培养具有更重要的价值。跨学科教学的本质在于“超越学科”,纵观当前国内外的课程改革和教学实践,已开始转向对学生的阅读、交互、探究、设计等“软技能”的培养。为此,基于2003-2022年国际期刊上发表的35项STREAM跨学科教学在线交互相关实验与准实验研究(实验样本涉及美国、中国、澳大利亚等7个国家的7955名教师与学生),元分析的结果表明:在线交互对STREAM跨学科教学具有显著正向强作用,尤其是对科学与技术等学科侧重、内容交互、虚拟和视频辅助的STREAM跨学科教学。这一元分析结果充分揭示了:STREAM跨学科教学在线交互在当前各类教学中具有较大的借鉴与应用价值,需要深入探索混合式STREAM跨学科教学深度交互、面向读写能力培养的STREAM跨学科教学资源整合、扩展现实技术辅助下的沉浸式跨学科教学实践、利用在线交互数据等,进一步驱动与落实STREAM跨学科教学的实践应用。

摘要： 随着地理信息技术日新月异的发展,培养学生地理技术素养需要更加具有专业性的技术手段和方法.在地理教学中教师易忽略或缺少对中学生技术素养的培养,导致中学生地理技术素养非常缺乏.因此,本文结合STREAM教育模式,以"水污染处理模拟实验"为教学案例呈现高中生地理技术素养培养过程,旨在丰富STREAM课程案例和为地理教师开展相关教学提供参考.

摘要： 一、什么是STREAM课程STREAM课程是在2010年美国学术竞争力委员会提出的STEM课程基础上,进一步融合艺术(Art)、读写(Reading/Writing)于科学(Science)、技术(Technology)、工程(Engieering)与数学(Mathematics)进行跨学科整合的课程。该课程的提出,旨在超越传统彼此割裂的分科课程,超越过往的45分钟课堂教学,强调聚焦某个特定的项目或任务.

摘要： 在当前信息超载的冲击下,学习渠道逐步多样化,学生既要在课堂内进行系统化地学习,也能在生活中随时随地进行移动式学习,也称碎片化学习。碎片化学习导致大量信息涌入学生生活,学生所得知识看似丰富,但禁不起深究;而在学校经过系统化学习,学生所学知识看似专业性较强,但往往局限在书本里,无法实践,地理知识体系的建立缺乏支柱性基础。在现代信息社会,如何正视两种学习形态,将碎片化学习纳入学生知识体系构造的过程中,找到二者的交叉点和平衡点,是地理教育工作者应具备的开阔视野和超前意识。提出将新建构主义作为正式学习与非正式学习的互联桥梁,以STREAM理念作为地理核心素养培养的目标及落脚点,创新一种新的教学模式,使学生建构出个人化的知识体系。

摘要： In data stream management systems (DSMSs), how to maintain the quality of queries is a difficult problem because both the processing cost and data arrival rates are highly unpredictable. When the system is overloaded, quality degrades significantly and thus load shedding becomes necessary. Unlike processing overloading in the general way which is only by a feedback control (FB) loop to obtain a good and stable performance over data streams, a feedback plus feed-forward control (FFC) strategy is introduced in DSMSs, which have a good quality of service (QoS) in the aspects of miss ratio and processing delay. In this paper, a quality adaptation framework is proposed, in which the control-theory-based techniques are leveraged to adjust the application behavior with the considerations of the current system status. Compared to previous solutions, the FFC strategy achieves a good quality with a waste of fewer resources.

摘要： 本发明涉及一种基于Spark Streaming的流式RDF数据并行推理算法。首先结合OWL Horst推理规则，构建相应的规则连接变量关系表；在迭代并行推理阶段定时获取Streaming数据流中的批量新数据以及前次推理产生的数据作为输入数据，对输入的模式数据和实例数据进行归类处理并存储到相应的Redis集群；然后，根据规则连接变量关系表，判断本次推理能够激活的规则，结合相应的实例数据产生推理数据；最后，删除本次推理产生的重复数据并存储，本次迭代推理结束。本发明减少了MapReduce的任务数，结合Spark进行流式数据的迭代推理；设计规则连接变量关系表来存储数据以及推理中产生的新数据，保证了算法的完备性；设计了实例三元组的存储方案，结合Redis的特性，以空间换时间，实现了实例数据的快速读取。

摘要： 本发明实施例公开了一种基于Spark Streaming的数据处理方法、装置、计算机设备及存储介质。该方法包括：获取当前批次的至少两个第一待执行任务，并合并为第二待执行任务，其中，第一待执行任务封装在弹性分布式数据集RDD中；执行第二待执行任务并将执行结果数据存储至分布式文件系统。本发明实施例所提供的技术方案，解决了由于NameNode的处理请求能力下降而导致的Spark Streaming进行数据处理时吞吐量下降的问题，减少了任务生成的文件数，即减少了向NameNode发出的请求数量，进而提高了NameNode处理请求能力的稳定性，从而提高了Spark Streaming数据处理时的吞吐量。

摘要： 本发明涉及一种基于Spark Streaming结合Kafka确保数据零丢失的系统和方法，属于流式数据实时处理排序技术领域。本发明结合集群思想和SDN网络集中控制理念设计一种新的匿名通信系统，从而使匿名通信服务更加安全、可靠。基于SDN的网络体系架构提高攻击者获取用户隐私难度和网络请求响应速率；采用集群的方式和节点选择限制策略，在很大程度上避免了恶意节点注入、流量分析以及单点攻击等安全威胁，提高系统的防御能力。

摘要： 本发明涉及服务器测试技术领域，具体提供一种基于STREAM的压力测试方法、系统、终端及存储介质，包括：利用编译器编译基于内存带宽测试实际性能测量工具的多个压力程序，每个压力程序均包括循环执行次数；基于设定的线程数量随机生成模式生成线程数量，并基于设定的进程生成规则和所述线程数量生成进程数量；从多个压力程序中选定目标压力程序，基于所述线程数量和进程数量生成相应数量的线程和进程，所述线程和进程执行所述目标压力程序；记录目标压力程序的执行次数，并在所述执行次数达到相应循环执行次数之后切换目标压力程序并更新线程数量和进程数量。本发明能够判断内存和CPU在动态负载下的可靠性。

摘要： 本发明公开了基于Spark Streaming的流式统计框架及其应用，包括数据获取计算模块和数据展示模块，数据获取计算模块的设计方法包括以下步骤：S11，基于TCP的Java Socket设置服务端，服务端从本地测试文件获取数据；S12，TCP Socket服务端利用线程控制，按照每秒50至100条交易记录的随机速度，发送给以Spark Streaming客户端进行数据实时计算处理；S13，客户端接收到数据利用MapToPair算子进行数据分组，再利用updateStateByKey算子进行数据有状态计算；当下一批数据计算完后，更新在缓存区与其key相同的状态的值；S14，由客户端将计算的数据按批次写入数据库，并且数据库按照key持续更新状态值。

摘要： 本发明是一种基于Spark Streaming实时检测锅炉壁温超限报警的方法，基于Spark大数据处理和计算框架，通过SparkStreaming驱动器程序订阅Kafka，贯通SIS实时数据库，利用离散化流DStream实现不间断7*24工作,将锅炉壁受热面金属监测的所有测点数据按批次间隔形成一个持续RDD序列，通过“Map”转化操作过滤出超限测点，再由“Reduce”滑动窗口操作进行聚合，实现实时检测锅炉壁温超限报警统计，对预防超温引发机组停机、提高发电设备可靠性和间接降低发电成本有着显著的作用。

摘要： 本发明提供的一种基于Spark Streaming的快速实时预警方法，将待处理车辆轨迹数据按照车牌号码分别存储到不同的存储分区中，将所有实时监测事件分别建立一个实时比对线程thread，每次将待处理车辆轨迹数据同时送入到所有的实时比对线程thread中并行计算；同时，因为待处理车辆轨迹数据是按照车牌号码存储的，每次计算时，车缓存队列消费线程将数据送入存储分区对应的过车数据缓存队列中，在每个实时比对线程thread中，因为是按照需要比对的待处理车辆轨迹数据对应的车牌范围从基础数据库和嫌疑车辆黑名单中提取对应车牌号码范围的数据，所以数据对比查找的命中率会提高，极大的提高了系统的计算效率，同时每个thread中每次需要计算的数据量有限，进一步的提高了计算速度。

摘要： 本发明涉及一种基于Aurora改进链路协议的AXI Stream协议高速并串转换系统，该系统包括：协议层：经AXI Stream接口实现和AXI Stream总线通信；链路层：数据发送、数据接收以及链路状态的控制；物理层：完成对数据的串行传输编解码和数据的串化/解串。此外，系统还包括低功耗管理单元，所述的低功耗管理单元根据不同工作状态需要将系统的工作时钟划分为不同时钟域，在系统不同工作状态下通过门控时钟技术实现对不同时钟域的控制。与现有技术相比，本发明具有传输可靠，实现开销小，功耗低等优点。

摘要： 本发明公开了一种基于spark streaming处理流动车辆数据的方法及系统，属于大数据处理领域，本发明要解决的技术问题为如何利用大数据技术实施检测车流量并能够快速发现目标车辆，采用的技术方案为：①该方法步骤如下：S1、获取卡口数据：获取设置卡口的各个路口通过的车辆信息，并将车辆信息进行处理后保存符合条件的数据，支持后续应用及对外服务；S2、数据处理；S3、数据应用：将经过数据处理的数据进行app推送、短信告警、邮件告警以及可视化分析。②该系统包括卡口数据获取模块、数据处理模块和数据应用模块，卡口数据获取模块通过数据传输通道kafka将获取的数据发送到数据处理模块，数据处理模块将经过处理并存储的数据发送到数据应用模块。

摘要： 本发明涉及数据集成技术领域，具体的说是一种基于stream的数据集成平台及其数据集成方法，其中基于stream的数据集成平台包括：协议网关的设计、限流设计、黑白名单设计、鉴权设计、组件库、API管理器和组件表单引擎；组件库包括数据库读组件、数据库写组件、http访问组件、feign组件、mq客户端组件、redis读组件、redis写组件、内容转义组件、字段转换组件、延时组件、EDI写组件、EDI读组件、IOT组件、ES2组件和SAP组件。本发明通过基于stream的数据集成平台，能够轻松面对不同场景下的数据集成需求，同时通过简单配置化的方式降低实施成本、缩短实施周期；通过分布式部署的方式，更能适应高可用、高并发的应用场景。