《欢聚集团》专题

并非所有的都会是文章或页面。也许您想要记录您开源项目中涉及的各种解决方案，团队成员，或是某次会议记录。集合（Collection）允许您定义一种新的文档类型，它既可以像页面和文章那样工作，也可以拥有它们特有的属性和命名空间。 使用集合 第一步：让 Jekyll 读取您的集合 将下面的代码加入您的 _config.yml 文件，将 my_collection 替换为您集合的名字。 collectio

{ "name": "...", "type": "...", "connect_timeout_ms": "...", "per_connection_buffer_limit_bytes": "...", "lb_type": "...", "ring_hash_lb_config": "{...}", "hosts": [], "service_name":

1.简介 为了避免单点故障，现在的应用通常至少会部署在两台服务器上。对于一些负载比较高的服务，会部署更多的服务器。这样，在同一环境下的服务提供者数量会大于1。对于服务消费者来说，同一环境下出现了多个服务提供者。这时会出现一个问题，服务消费者需要决定选择哪个服务提供者进行调用。另外服务调用失败时的处理措施也是需要考虑的，是重试呢，还是抛出异常，亦或是只打印异常等。为了处理这些问题，Dubbo 定义了

本页介绍如何使用Storm消费来自Kestrel集群的项目。 准备阶段 Storm 本教程使用的示例来自于 storm-kestrel 项目和 storm-starter 项目。建议你克隆这些项目并根着示例走。 阅读 Setting up development environment 和 Creating a new Storm project 来设置你的机器。 Kestrel 它假设您可以在本

该模块提供了将数据写入Druid 数据存储的核心Strom和Trident bolt(螺栓)的实现。 该实现使用Druid's的Tranquility库向druid发送消息。 一些实施细节从现有的借用 Tranquility Storm Bolt. 这个新的Bolt(螺栓)增加了支持最新的storm释放，并保持在storm回购的bolt(螺栓)。 Core Bolt 下面的例子描述了使用 org.

#Storm Kinesis Spout 提供的核心storm spout(喷口)，用户从Amzon Kinesis Streams 中的流中消费数据。它存储可以在zookeeper中提交的序列号，并在重新启动后默认启动消息记录。下面是创建使用spout的示例拓扑的代码示例。下面说明配置spout(喷口)时使用的每个对象。理想情况下，spout(喷口)任务的数量应等于运动时间碎片的数量。但是，每个

OpenTSDB 为时间序列数据提供了可扩展且高可用性的存储. 它由 Time Series Daemon (TSD) servers 以及命令行工具组成. 每个 TSD 连接到配置的 HBase 集群以 push/query（推送/查询） 数据. 时间序列数据点包括: a metric name. a UNIX timestamp (seconds or milliseconds since E

Storm/Trident集成MongoDB。该包中包括核心bolts和trident states，允许storm topology将storm tuples插入到数据库集合中，或者针storm topology中的数据库集合执行更新查询。 Insert into Database 此包中包含用于将数据插入数据库集合的bolt和trident state。 MongoMapper 使用Mongo

About MQTT是IoT(Internet of Things)应用程序中经常使用的轻量经发布/订阅协议。 Further information can be found at http://mqtt.org. The HiveMQ website has a great series on MQTT Essentials. 功能点如下： 完整的MQTT支持 (e.g. last will,

EdIndexBolt，EsPercolateBolt和Estate允许用户将storm中的数据直接传输到Elasticsearch。 详细说明请参考以下内容。 EsIndexBolt (org.apache.storm.elasticsearch.bolt.EsIndexBolt) EsIndexBolt将tuples直接流入Elasticsearch索。 Tuples以指定的索引和类型组合进行

Storm/Trident 集成 Redis Storm-redis使用Jedis为Redis客户端。 用法 如何使用它？ 使用它作为一个maven依赖： <dependency> <groupId>org.apache.storm</groupId> <artifactId>storm-redis</artifactId> <version>${storm.vers

关于 Storm JMS Storm JMS是在Storm框架内集成JMS消息传递的通过框架。 Storm-JMS 允许您通过JMS spout(喷口)将数据注入到Storm，并通过通用JMS bolt(螺栓)从Storm 消费数据。 JMS Spout(喷口)和Bolt(螺栓)都是数据不可知的。要使用它们，您需要提供一个简单的Java类，用于桥接JMS和Storm API 以及封装和特定域的逻辑

Storm/Trident集成JDBC.该包中包含的核心bolts 和 trident states ，允许storm topology把storm tuples插入数据库表中或者执行数据库查询，并且丰富了storm topology 中的tuples. 注：在下面的示例中，我们使用com.google.common.collect.Lists和com.google.common.collect.

有序集合和集合一样也是元素的集合,且不允许重复的成员。不同的是每个元素都会关联一个可以被排序的分数。 有序集合是通过分数来为集合中的成员进行从小到大的排序。有序集合的成员是唯一的,但分数却可以重复。 下面的示例代码中:abc/10表示TElement为abc,TSource为10 构造有序集 var sorset = new SortSet<string, int>(); 函数原型 SortSe

尽量用 map 而不是 collect。 尽量用 detect 而不是 find。 find 容易和 ActiveRecord 的 find 搞混 - detect 则是明确的说明了 是要操作 Ruby 的集合, 而不是 ActiveRecord 对象。 尽量用 reduce 而不是 inject。 尽量用 size， 而不是 length 或者 count， 出于性能理由。 尽量用数组和 has