1. DefaultMQPushConsumer属性
public class DefaultMQPushConsumer extends ClientConfig implements MQPushConsumer {private final InternalLogger log ClientLogger.getLog();// 消费者实现对象protected final transient DefaultMQPushConsumerImpl defaultMQPushConsu…
MapReduce的一些高级特性
如果一个类实现了的Hadoop的序列化机制(接口:Writable),这个类的对象就可以作为输入和输出的值
public class Employee implements Writable举例1:使用Employee类来封装员工信息,…