/*
* 本程序用于测试Socket中的一个中断的方法
* 对于进行的线程可以对其进行停止的中断
* 是通过SocketChannel channel = SocketChannel.open(new InetSocketAddress(host, port));
* */
package interruptible;
import java.awt.BorderLay...
分类：
其他好文 时间：
2015-03-09 16:20:20
阅读次数：
171
从官方下载的flume-ng的源码里有单元测试的代码，本文就通过单元测试来体验下flume中avro的性能如何
本文中的一个event的body内容大小是1KB，读者可自行组织文本，达到1KB即可，方便测试时，性能的计算
for (int i = 0; i < client.getBatchSize(); i++) {
Event event = channel.take()...
分类：
Web程序 时间：
2015-03-09 16:16:56
阅读次数：
5816
org.apache.flume.channel.ChannelProcessor用于实际的Event到Channel的操作（在Source中用到），可以把它想象成channel的proxy，用于控制把Eventput到哪些Channel中，以及怎么put(bacth或者单个)，同时在put之前会使用Interceptor对Event进行处理。把Eventput到哪些Channel中..
分类：
其他好文 时间：
2015-03-09 01:48:39
阅读次数：
176
在agent启动时，会启动Channel,SourceRunner,SinkRunner，比如在org.apache.flume.agent.embedded.EmbeddedAgent类的doStart方法中：privatevoiddoStart(){
booleanerror=true;
try{
channel.start();//调用Channel.start启动Channel
sinkRunner.start();//调用SinkRunner.star..
分类：
其他好文 时间：
2015-03-08 17:24:39
阅读次数：
521
??
一、Accessingpixel values访问像素值。（用类自带的方法：方便，但效率不高）
cv::Mat has the a template methodat(int y, int x)
用法image.at(j,i)[channel]= value;
注意事项：the programmer needs to specify the retur...
分类：
其他好文 时间：
2015-03-08 17:12:04
阅读次数：
234
数据分页： $Data = M('Channel'); // 实例化Data数据模型 $content = $Data->page($page, 4)->select(); $totalCount = $Data->count...
分类：
其他好文 时间：
2015-03-06 16:56:41
阅读次数：
111
1.decode的用法：(select max(DECODE(logicSn,null,physicalid+1,logicSn+1)) from m_logic_channel where physicalid=#{physicalId}),2.nvl的用法：(select nvl(max(t.l...
分类：
数据库 时间：
2015-03-06 13:59:50
阅读次数：
154
HDFSEventSink用于把数据从channel中拿出来（主动pull的形式）然后放到hdfs中，HDFSEventSink在启动时会启动两个线程池callTimeoutPool和timedRollerPool，callTimeoutPool用于运行append/flush等操作hdfs的task（通过callWithTimeout方法调用，并实现timeout功能），用于运行..
分类：
Web程序 时间：
2015-03-06 06:24:34
阅读次数：
254
flume的主要组件包括：Source,SourceRunner,Interceptor,Channel,ChannelSelector，ChannelProcessor，Sink,SinkRunner,SinkProcessor,SinkSelector等工作流程包含两个部分：source->channel，数据由source写入channel，主动模式，主要步骤如下：一个SourceRunner包含一个So..
分类：
Web程序 时间：
2015-03-06 06:24:30
阅读次数：
217
remoting提供一种允许对象通过应用程序域去与另一对象进行交互的框架。如果要通过应用程序域进行通信，在remoting中要通过信道（channel）来实现。信道信道是跨越远程处理边界（应用程序域，进程，计算间之间）在应用程序之间传递消息的对象。信道可以在终结点监听入站消息，向基他终结点发送出站消...
分类：
Web程序 时间：
2015-03-05 10:36:10
阅读次数：
138
