Flume+Kafka收集Docker容器内分布式日志应用实践 经验
缓冲通道，这里使用内存队列缓冲区，Sink就是槽，是个消费的地方。容器内的Source就是执行tail -F这个命令的去利用linux的标准输出读取增量日志，Sink是一个Kafka的实现，用于推送消息到分布式消息中间件。
NadineOzc 你一定需要 六款大数据采集平台的架构分析 资讯
一个Agent的网络，支持数据路由。 每一个agent都由Source，Channel和Sink组成。 Source Source负责接收输入数据，并将数据写入管道。Flume的Sourc
jopen 大数据系统数据采集产品的架构分析 经验
ent的网络，支持数据路由。 每一个agent都由Source，Channel和Sink组成。 Source Source负责接收输入数据，并将数据写入管道。Flume的Sou
flume的安装使用 经验
agent1.sources = avro-source1 agent1.sinks = log-sink1 agent1.channels.ch1.type = memory # Define an
baihu Spring XD 1.0 里程碑1发布，简化大数据应用开发 资讯
Source, (optional) Processing Steps, and an Output Sink. As a simple example consider the collection of
OkHttp源码解析——HTTP请求的逻辑流程 经验
Okio.buffer(Okio.source(rawSocket)); sink = Okio.buffer(Okio.sink(rawSocket)); //用Okio封装了socket的输入和输出流
P17 Hadoop1.x以及2.x安装 文档
properties *.sink.ganglia.class=org.apache.hadoop.metrics2.sink.ganglia.GangliaSink31 *.sink.ganglia.period=10
优先队列实现原理分析 经验
和它两个子结点中较小的结点相比较，如果小于子结点，我们就交换两者，然后继续 sink(5) 。 private static void sink(Comparable[] pq, int k, int n){
P29 搜索离线生产集群中的流计算 文档
Stream Sink：Stream Worker的数据输出终端 Stream Master：负责调度管理Stream Workers8 9. 拓扑结构9Stream SourceStream Sink/SourceStream
记录一下互联网日志实时收集和实时计算的简单方案 经验
ader，供Sink使用； 一处是在LogServer上部署的Flume Source，它从原始日志中提取出用户ID，然后加入到Header中，Flume Sink（Kafka Sink）再入Kafk
Kafka实战－Flume到Kafka 经验
数据源加载 预览 下面开始今天的分享内容。 2.数据来源 Kafka生产的数据，是由Flume的Sink提供的，这里我们需要用到Flume集群，通过Flume集群将Agent的日志收集分发到 Kafk
Spring Cloud Data Flow:来自被重构的SpringXD 资讯
器 （binder），然后会用这个绑定器来创建信道适配器。它有一个接口类型的参数，Source、Sink和Processor是已经定义好的，你也可以 定义其它的。这个示例中，Source自身仅仅是一个消息信道接口：
深入解析OkHttp3 经验
writeTo(BufferedSink sink) throws IOException { sink.writeUtf8("Numbers\n"); sink.writeUtf8("-------\n");
深入解析OkHttp3 经验
writeTo(BufferedSink sink) throws IOException { sink.writeUtf8("Numbers\n"); sink.writeUtf8("-------\n");
Scala 的 HTTP 服务接口：http4s 经验
frames, and, on completion, notify the console val sink: Sink[Task, WSFrame] = Process.constant { case Text(t)
搭建 Spark 源码研读和代码调试的开发环境 经验
从Github上获取Spark源码 导入源码到Intellij IDEA 16 2. 添加缺失的flume sink源代码 3. 添加运行依赖的jars 工欲善其事，必先利其器，第一篇笔记介绍如何搭建源码研读和代码调试的开发环境。
使用React开发混搭移动应用：Reapp 经验
ct组件绑定到一个跨平台的UI-Kit来创建混搭应用。 读者可通过该项目的 Kitchen Sink 样例应用来感受Reapp UI-Kit的表现力与强大。特别是该应用的“Mailbox”效果，它
Apache Beam：一个开源的统一的分布式数据处理编程库 经验
Source and Sink Apache Beam提供了Source和Sink的API，用来表示读取和写入数据。Source表示从一个外部的数据源读入数据到Pipeline，而Sink表示经过Pipeline处理后将数据写入到外部存储系统
多媒体开发框架，GStreamer 1.6.0 发布 资讯
OpenGL-based QML video sink, Gtk GL video sink, CoreAnimation CAOpenGLLayerSink video sink gst-libav switched