AI 助理
备案控制台
开发者社区 大数据 文章 正文

Storm之LocalCluster.clj

2015-12-17 2960
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

       此类初始化了一些配置参数，实现了ILocalCluster接口，将拓扑结构提交到nimbus，最终通过nimbus来执行

其中最重要的看


gen-class中定义了init的函数名为”init”，继承了ILocalCluster接口

下面看init函数：


定义了3种init函数

  1. 无参数 设置了TOPOLOGY-ENABLE-MESSAGE-TIMEOUTS，返回ret作为state
  1. String 和 Long 两个参数，分别制定zookeeper的Host和Port，返回ret作为state
  1. java中的Map，直接返回，将map当做state
文章标签：
Java
流计算
子沭
目录
相关文章
小目标青年
|
Java
Java Exception异常信息怎么打印、记录，几种方式自己选
Java Exception异常信息怎么打印、记录，几种方式自己选
小目标青年
905 0
Java Exception异常信息怎么打印、记录，几种方式自己选
c的前世今生
|
10月前
|
缓存 供应链 物联网
如何将 Salesforce IoT Cloud 与其他系统集成
Salesforce IoT Cloud 可通过其开放的 API 和集成云平台轻松与外部系统集成，实现数据交换和流程自动化，支持多种协议和标准，帮助企业构建智能物联网应用。
c的前世今生
179 4
软件求生
|
11月前
|
存储 Java 程序员
Java面试加分点！一文读懂HashMap底层实现与扩容机制
本文详细解析了Java中经典的HashMap数据结构，包括其底层实现、扩容机制、put和查找过程、哈希函数以及JDK 1.7与1.8的差异。通过数组、链表和红黑树的组合，HashMap实现了高效的键值对存储与检索。文章还介绍了HashMap在不同版本中的优化，帮助读者更好地理解和应用这一重要工具。
软件求生
543 5
磊哥聊Java
|
消息中间件 存储 网络协议
拼多多面试：Netty如何解决粘包问题？
粘包和拆包问题也叫做粘包和半包问题，**它是指在数据传输时，接收方未能正常读取到一条完整数据的情况（只读取了部分数据，或多读取到了另一条数据的情况）就叫做粘包或拆包问题。** 从严格意义上来说，粘包问题和拆包问题属于两个不同的问题，接下来我们分别来看。 ## 1.粘包问题 粘包问题是指在网络通信中，发送方连续发送的多个小数据包被接收方一次性接收的现象。这可能是因为底层传输层协议（如 TCP）会将多个小数据包合并成一个大的数据块进行传输，导致接收方在接收数据时一次性接收了多个数据包，造成粘连。 例如以下案例，正常情况下客户端发送了两条消息，分别为“ABC”和“DEF”，那么接收端也应该收到两
磊哥聊Java
114 0
拼多多面试：Netty如何解决粘包问题？
郑小健
|
机器学习/深度学习 PyTorch 算法框架/工具
PyTorch中的自动微分机制：深入理解反向传播
【8月更文第27天】PyTorch 是一个强大的机器学习框架，它因其灵活性和易用性而受到广泛欢迎。其中一个关键特性就是它的自动微分机制，这个机制使得 PyTorch 能够自动计算任何张量操作的梯度，这对于训练深度学习模型至关重要。本文将详细介绍 PyTorch 中自动微分机制的工作原理，并通过具体的代码示例来展示如何使用这一机制来实现反向传播。
郑小健
711 1
Echo_Wish
|
供应链 监控 调度
ERP系统中的销售订单处理与交付跟踪解析
【7月更文挑战第25天】 ERP系统中的销售订单处理与交付跟踪解析
Echo_Wish
865 0
ERP系统中的销售订单处理与交付跟踪解析
aliyun7689123603-22772
|
11月前
|
数据采集 人工智能 运维
云应用开发平台CAP
云应用开发平台CAP
aliyun7689123603-22772
207 1
zkool
|
Web App开发 移动开发 小程序
看我如何让手机秒变扫码枪
为解决无扫码枪问题，作者受到微信小程序“超级扫码枪”启发，决定自制手机扫码到电脑的应用。项目需求是手机扫描条形码或二维码后实时传送到电脑。实现步骤包括：电脑端用Java Swing和Robot模拟键盘输入，手机端H5调用摄像头扫码（借助html5-qrcode库），并通过WebSocket服务将结果发送至电脑。项目源码及演示视频链接提供。
zkool
2322 5
卡尔特斯
|
缓存 数据可视化 数据安全/隐私保护
Mac 系统占用100G+解决办法（详细步骤）
Mac 系统占用100G+解决办法（详细步骤）
卡尔特斯
2840 32
公众号：堆栈future
|
缓存 负载均衡 算法
Nginx：为什么高性能？Master&worker如何配合？负载均衡算法有哪些？七层和四层负载均衡了解吗？
Nginx：为什么高性能？Master&worker如何配合？负载均衡算法有哪些？七层和四层负载均衡了解吗？
公众号：堆栈future
538 0

热门文章

最新文章

  • 1
    CentOs7 安装 Mysql5.7
  • 2
    B站被删除的视频，该如何找回来？
  • 3
    轻量应用服务器支持带宽套餐升级至流量包套餐流程说明
  • 4
    MySQL数据库备份和恢复操作的步骤和注意事项
  • 5
    PostgreSQL 并行计算解说 之18 - parallel merge join
  • 6
    QT的密码输入框以及国际化的一些问题
  • 7
    .NET开发之快捷键篇
  • 8
    css padding 填充
  • 9
    iOS - 3DTouch 3D 触摸
  • 10
    嵌入式 hi3518平台指定网卡测试是否通外网
  • 1
    《用AI重构工业设备故障预警系统：从“被动维修”到“主动预判”的协作实践》
    36
  • 2
    《从0到1搭建客户画像系统：AI工具矩阵如何解决开发困局》
    31
  • 3
    快应用报错Module Error 分包要求 app.json#minPlatformVersion 不小于 1061, 当前值为 21解决方案-优雅草卓伊凡
    23
  • 4
    快应用打包rpk同时生成了rpk和rpks是为什么？怎么用？-优雅草卓伊凡
    17
  • 5
    Parameter ‘**‘ not found. Available parameters are [0, 1, param1, param2]解决办法
    21
  • 6
    【多光谱滤波器阵列设计的最优球体填充】使用MSFA设计方法进行各种重建算法时，图像质量可以提高至多2 dB，并在光谱相似性方面实现了显著提升（Matlab代码实现）
    20
  • 7
    【高创新】基于优化的自适应差分导纳算法的改进最大功率点跟踪研究（Matlab代码实现）
    36
  • 8
    机器会“看病”？深度学习正在颠覆医学成像！
    29
  • 9
    金融系统宕机一分钟，损失就是百万？聊聊智能化运维该怎么玩！
    31
  • 10
    【概率Copula分类器】实现d维阿基米德Copula相关的函数、HACs相关的函数研究（Matlab代码实现）
    20

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    2025云栖大会，阿里云百炼邀请您的参与和见证