storm-core maven

system

软件标签:  stormcore.jar   jar包   .jar
stormcore.jar是一款综合编程类应用程序，提供apache kafka集成改进、storm sql数据库、pmml（预测模型标记语言）支持、hdfs喷口等功能，是用户实现汇编语言的有效助手，绿色资源网欢迎大家下载官方最新版！
storm core maven官网介绍
storm-core1.1.0此版本是apache storm发展的重大里程碑，包括大量新功能，可用性和性能改进，其中一些在下面突出显示。



storm的sql支持包括以下功能：
通过isqltridentdatasource接口扩展附加数据源

从/到外部来源，包括apache kafka，hdfs，mongodb和redis

csv，tsv和avro输入/输出格式

生成组件的用户定义的平行

用户定义函数（udf）

元组过滤

预测
storm core.jar拓扑部署增强功能
在以前版本的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实例。

https://blog.51cto.com/u_16099270/9147646