码迷,mamicode.com
首页 >  
搜索关键字:sink    ( 408个结果
Flume内置channel,source,sink汇总
由于经常会使用到Flume的一些channel,source,sink,于是为了方便将这些channel,source,sink汇总出来,也共大家访问。 Component Interface Type Alias Implementation Class *.Channel memory *.ch ...
分类:Web程序   时间:2016-07-05 20:32:06    阅读次数:224
flume sink processor
sink groups使多个不同的sink组成一个整体,而sink processor提供了组内负载均衡和故障转移的功能。 有三种sink processor :default sink processor,failover sink processor,Load balancing Sink Pr ...
分类:Web程序   时间:2016-07-05 17:12:41    阅读次数:285
R语言 字符串写入文件
out_con<-file("out.txt","w") write(sprintf("Thisisline%d.\n",1),out_con,append=T) write("Thisisline2.",out_con,append=T) close(out_con)或者printer=file("out.txt","w") writeLines("Thisisline.",con=printer,sep="") writeLines("Thesameline.",con=printer) clo..
分类:编程语言   时间:2016-06-20 18:57:10    阅读次数:574
flume简介与监听文件目录并sink至hdfs实战
场景1. flume是什么1.1 背景  flume 作为 cloudera 开发的实时日志收集系统,受到了业界的认可与广泛应用。Flume 初始的发行版本目前被统称为 Flume OG(original generation),属于 cloudera。但随着 FLume 功能的扩展,Flume OG 代码工程臃肿、核心组件设计不合理、核心配置不标准等缺点暴露出来,尤其是在 Flume OG 的最后...
分类:Web程序   时间:2016-06-03 19:53:06    阅读次数:646
Apache Flink源码解析之stream-transformation
之前我们聊了Flink程序的source、sink就差transformation了。今天我们就来解读一下Flink的transformation。它们三者的关系如下图:当然这还是从Flink编程API的角度来看的(编程视角)。所谓的transformation,用于转换一个或多个DataStream从而形成一个新的DataStream对象。...
分类:Web程序   时间:2016-05-15 12:40:02    阅读次数:274
Apache Flink源码解析之stream-sink
上一篇我们谈论了Flink stream source,它作为流的数据入口是整个DAG(有向无环图)拓扑的起点。那么与此对应的,流的数据出口就是跟source对应的Sink。这是我们本篇解读的内容。...
分类:Web程序   时间:2016-05-13 02:56:37    阅读次数:3019
flume的source, channel, sink 列表
Flume Source Source类型 说明 Avro Source 支持Avro协议(实际上是Avro RPC),内置支持 Thrift Source 支持Thrift协议,内置支持 Exec Source 基于Unix的command在标准输出上生产数据 JMS Source 从JMS系...
分类:Web程序   时间:2016-05-12 18:15:00    阅读次数:174
java学习系列(一)Java中的IO操作
Java的IO流是实现输入/输出的基础,它可以方便地实现数据的输入\输出操作,在Java中把不同的输入\输出源抽象为"流",通过流的方式允许Java程序使用相同的方式来访问不同的输入/输出源。stream是从起源(source)到接收(sink)的有序数据。 Java把所有传统的流类型(类或抽象类) ...
分类:编程语言   时间:2016-05-11 01:20:03    阅读次数:184
基于Flume+LOG4J+Kafka的日志采集架构方案
使用 Flume、log4j、Kafka进行规范的日志采集。 Flume 基本概念 Flume是一个完善、强大的日志采集工具,关于它的配置,在网上有很多现成的例子和资料,这里仅做简单说明不再详细赘述。Flume包含Source、Channel、Sink三个最基本的概念: Source .. bbs.chinaacc.com/forum-2-26/topic-5640278.html bbs.c...
分类:Web程序   时间:2016-05-09 07:05:38    阅读次数:200
基于Flume+LOG4J+Kafka的日志采集架构方案
本文将会介绍如何使用 Flume、log4j、Kafka进行规范的日志采集。 Flume 基本概念 Flume是一个完善、强大的日志采集工具,关于它的配置,在网上有很多现成的例子和资料,这里仅做简单说明不再详细赘述。Flume包含Source、Channel、Sink三个最基本的概念: Source ...
分类:Web程序   时间:2016-05-08 22:22:06    阅读次数:394
408条   上一页 1 ... 23 24 25 26 27 ... 41 下一页
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!