org.apache.flume.sink.AvroSink是用来通过网络来传输数据的，可以将event发送到RPC服务器（比如AvroSource），使用AvroSink和AvroSource可以组成分层结构。它继承自AbstractRpcSink
extends AbstractSinkim.....
分类：
其他好文 时间：
2014-06-29 14:29:54
阅读次数：
392
下面内容摘自互联网并作了整理。名词：BI(Business
Intelligence)：商业智能，DW(Data Warehouse)：数据仓库，详见正文Q1部分。OLTP(On-Line Transaction
Processing)：联机事务处理也称为面向交易的处理系统，其基本特征是顾客的原始数...
分类：
其他好文 时间：
2014-06-07 05:32:53
阅读次数：
263
事务（Transaction）是并发控制的单位，是用户定义的一个操作序列。这些操作要么都做，要么都不做，是一个不可分割的工作单位。通过事务，SQL
Server能将逻辑相关的一组操作绑定在一起，以便服务器保持数据的完整性。在sql server+ .net 开发环境下，有两种方法能够完成事务的...
分类：
数据库 时间：
2014-05-29 09:33:19
阅读次数：
365
#导出大表：mysqldump --add-drop-table
--single-transaction --triggers -R -quick --disable-keys -utest -ptest -P5616
test > test.sql#仅导出表结构mysqldump --add-....
分类：
数据库 时间：
2014-05-29 00:03:48
阅读次数：
458
SinkRunner.java 开启线程调用相应的Processor(Policy) , 根据
Policy调用process的返回值来决定线程睡眠时间，每次默认延后1s，最大默认为5s。public class SinkRunner implements
LifecycleAware { pri....
分类：
其他好文 时间：
2014-05-28 02:14:36
阅读次数：
524
在AbstractConfigurationProvider类中loadSources方法会将所有的source进行封装成SourceRunner放到了Map
sourceRunnerMap之中。相关代码如下： 1 Map selectorConfig = context.getSu...
分类：
其他好文 时间：
2014-05-27 15:57:09
阅读次数：
347
System.Transactions 命名空间中除了上一节中提到的基于 Transaction
类的显式编程模型，还提供使用 TransactionScope 类的隐式编程模型，它与显示编程模型相比，更加方便简单，它也是MSDN中建议使用的编程模型。
下面，我们基于TransactionScope...
分类：
其他好文 时间：
2014-05-26 20:19:42
阅读次数：
312
不介绍背景，直接上例子首先我们创建这样的一张表，没有主键，添加下面的数据然后我们分别创建下面的连个连接查询查询1：SET TRANSACTION
ISOLATION LEVEL READ UNCOMMITTED--SERIALIZABLE--READ UNCOMMITTEDbegin tran pr...
分类：
其他好文 时间：
2014-05-26 19:18:04
阅读次数：
388
写在前面一：
本文总结“Hadoop生态系统”中的其中一员——Apache Flume
写在前面二：
所用软件说明：
一、什么是Apache Flume
官网：Flume is a distributed, reliable, and available
service for efficiently
collecting, aggregating, and m...
分类：
其他好文 时间：
2014-05-26 04:32:10
阅读次数：
359
在AbstractConfigurationProvider类中loadSinks方法会调用loadSinkGroups方法将所有的sink和sinkgroup放到了Map
sinkRunnerMap之中。 SinkRunner可能对应一个sink也可能对应一个sinkgroup。因为如果配置...
分类：
其他好文 时间：
2014-05-25 22:05:04
阅读次数：
398
