storm core.jar是一款综合编程类应用程序,提供Apache Kafka集成改进、Storm SQL数据库、PMML(预测模型标记语言)支持、HDFS喷口等功能,是用户实现汇编语言的有效助手,52z飞翔下载中心为你提供下载。
官网介绍
storm-core1.1.0此版本是Apache Storm发展的重大里程碑,包括大量新功能,可用性和性能改进,其中一些在下面突出显示。
软件功能
通过ISqlTridentDataSource接口扩展附加数据源
从/到外部来源,包括Apache Kafka,HDFS,MongoDB和Redis
CSV,TSV和Avro输入/输出格式
生成组件的用户定义的平行
用户定义函数(UDF)
元组过滤
预测
增强功能
在以前版本的Storm中,通常需要将所有拓扑依赖关系包含在阴影的“uber jar”中,或者通过使其在Storm的类路径上可用。在Storm 1.1.0中,该storm jar命令现在包括在拓扑提交期间上传附加依赖项的选项。该--jars命令行选项允许用户指定本地的jar文件上传。或者,该storm jar命令提供了--artifacts通过其Maven坐标来指定其他jar文件依赖关系的选项。最后,对于Maven Central之外的Maven工件,该--artifactRepository选项允许用户指定附加存储库以进行依赖性解析。
资源意识调度(RAS)改进
在Storm 1.0中引入的资源感知调度程序添加了一个考虑了集群中可用的内存(堆和堆)和CPU资源的调度程序实现。在风暴1.1.0中,RAS算法进行了大修,大大提高了集群资源利用率,并将机架知名度引入了调度策略。
有关RAS新功能的更多信息,请参见RAS文档和引入新的机架感知算法的JIRA故障单。
外部组件移动到Maven Central
大多数外部组件现在仅在Maven Central中托管。外部组件目录将包含README.md文件,但不包含jar文件。我们鼓励用户用Maven风格依赖解析(Maven,Gradle等)构建系统来构建拓扑jar,并避免手动构建拓扑。
这些组件的Maven坐标可以如下确定:
组ID:org.apache.storm Artifact ID:组件目录名称 版本:1.1.0
二进制分配的重要变化
为了最小化二进制分发的文件大小,不再包含外部组件(即“连接器”)二进制文件和已编译的示例。示例仅包含在源代码中,但可以使用Maven mvn install命令轻松编译。
HDFS喷口
Storm的HDFS集成现在包括一个从HDFS文件系统连续流式传输数据的喷口。Storm的HDFS端口监视新文件的可配置目录,并将数据馈入拓扑。当spout完成处理文件时,它将被移动到已配置的归档目录。如果文件已损坏或以其他方式不可处理,相应的文件将被移动到特定目录。通过一个确保每个文件由单个喷口实例“拥有”的锁定机制可以实现喷口的并行性。HDFS端口支持连接到使用Kerberos身份验证保护的HDFS实例。
更多精彩APP,尽在52z飞翔下载网!
最新发布 本类热门