moaikids

import java.util.Queue;
import java.util.concurrent.PriorityBlockingQueue;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

public class EventExecutor {
	private static Log log = LogFactory.getLog(EventExecutor.class);
	private final Queue<Event> queues;
	private Thread running;

moaikids

import lombok.Getter;

public class Event implements Comparable<Event> {
	@Getter
	private volatile Runnable runnable;
	@Getter
	private final long time;
	@Getter
	private boolean canceled = false;
	@Getter

moaikids

        // receive ack for connect
        pipelineStatus = blockReplyStream.readShort();
        firstBadLink = Text.readString(blockReplyStream);
        if (pipelineStatus != DataTransferProtocol.OP_STATUS_SUCCESS) {
          if (pipelineStatus == DataTransferProtocol.OP_STATUS_ERROR_ACCESS_TOKEN) {
            throw new InvalidBlockTokenException(
                "Got access token error for connect ack with firstBadLink as "
                    + firstBadLink);
          } else {
            throw new IOException("Bad connect ack with firstBadLink as "

moaikids

 int count = conf.getInt("dfs.client.block.write.retries", 3);

moaikids

#!/usr/bin/env python
# encoding: utf-8
import sys
from optparse import OptionParser
sys.path.append('/usr/local/hive/lib/py')
from hive_service import ThriftHive
from hive_service.ttypes import HiveServerException
from thrift import Thrift
from thrift.transport import TSocket
from thrift.transport import TTransport

moaikids

• architecture 结构

• http://baike.baidu.com/view/64565.htm

• icon 图标

• http://baike.baidu.com/view/393245.htm

• accessory 附件／配件

• http://baike.baidu.com/view/731671.htm

moaikids

$ diff {HIVE_0.10.0_HOME}/lib/py/hive_service/ThriftHive.py {HIVE_0.9.0_HOME}/lib/py/hive_service/ThriftHive.py
2c2
< # Autogenerated by Thrift Compiler (0.9.0)
---
> # Autogenerated by Thrift Compiler (0.7.0)
6,7d5
< #  options string: py
< #
9c7
< from thrift.Thrift import TType, TMessageType, TException, TApplicationException

moaikids

//https://github.com/fluent/fluentd/blob/master/lib/fluent/command/fluentd.rb 
//line 81-91

op.on('-v', '--verbose', "increase verbose level (-v: debug, -vv: trace)", TrueClass) {|b|
  if b
    opts[:log_level] = [opts[:log_level] - 1, Fluent::Log::LEVEL_TRACE].max
  end
}

op.on('-q', '--quiet', "decrease verbose level (-q: warn, -qq: error)", TrueClass) {|b|

moaikids

#import

• 导入(dao3ru4)
• http://baike.baidu.com/view/2117022.htm#2
• “在高级编程语言中，如果你想使用某个类或接口，那就要用import导入这个类”

#netsky

• netsky，�mimail, blaster, sobig等等 都就是“电脑病毒"的一种
• http://www.ipa.go.jp/security/topics/newvirus/netsky-b.html
• http://www.ipa.go.jp/security/topics/newvirus/mimail.html

moaikids

explain

explain select * from user limit 10;

explain select * from (select * from user) u sort by user_id limit 10 ;

local mode

select count(*) from user;

set mapred.job.tracker = local;