com.taobao.metamorphosis.storm.spout
类 MetaSpout

java.lang.Object
  backtype.storm.topology.base.BaseComponent
      backtype.storm.topology.base.BaseRichSpout
          com.taobao.metamorphosis.storm.spout.MetaSpout

所有已实现的接口：

backtype.storm.spout.ISpout, backtype.storm.topology.IComponent, backtype.storm.topology.IRichSpout, Serializable

public class MetaSpout
extends backtype.storm.topology.base.BaseRichSpout

支持metamorphosis消息消费的storm spout

作者：

boyan(boyan@taobao.com)

另请参见：

序列化表格

字段摘要

static int	DEFAULT_MAX_SIZE
static String	FETCH_MAX_SIZE
static String	TOPIC
static long	WAIT_FOR_NEXT_MESSAGE Time in milliseconds to wait for a message from the queue if there is no message ready when the topology requests a tuple (via nextTuple()).

构造方法摘要

MetaSpout(MetaClientConfig metaClientConfig, ConsumerConfig consumerConfig, backtype.storm.spout.Scheme scheme)

方法摘要

void	ack(Object msgId)
void	close()
void	declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer)
void	fail(Object msgId)
boolean	isDistributed()
void	nextTuple()
void	open(Map conf, backtype.storm.task.TopologyContext context, backtype.storm.spout.SpoutOutputCollector collector)

从类 backtype.storm.topology.base.BaseRichSpout 继承的方法

activate, deactivate

从类 backtype.storm.topology.base.BaseComponent 继承的方法

getComponentConfiguration

从类 java.lang.Object 继承的方法

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口 backtype.storm.topology.IComponent 继承的方法

getComponentConfiguration

字段详细信息

FETCH_MAX_SIZE

public static final String FETCH_MAX_SIZE

另请参见：

常量字段值

TOPIC

public static final String TOPIC

另请参见：

常量字段值

DEFAULT_MAX_SIZE

public static final int DEFAULT_MAX_SIZE

另请参见：

常量字段值

WAIT_FOR_NEXT_MESSAGE

public static final long WAIT_FOR_NEXT_MESSAGE

Time in milliseconds to wait for a message from the queue if there is no message ready when the topology requests a tuple (via nextTuple()).

另请参见：

常量字段值

构造方法详细信息

MetaSpout

public MetaSpout(MetaClientConfig metaClientConfig,
                 ConsumerConfig consumerConfig,
                 backtype.storm.spout.Scheme scheme)

方法详细信息

open

public void open(Map conf,
                 backtype.storm.task.TopologyContext context,
                 backtype.storm.spout.SpoutOutputCollector collector)

close

public void close()

指定者：

接口 backtype.storm.spout.ISpout 中的 close

覆盖：

类 backtype.storm.topology.base.BaseRichSpout 中的 close

nextTuple

public void nextTuple()

ack

public void ack(Object msgId)

指定者：

接口 backtype.storm.spout.ISpout 中的 ack

覆盖：

类 backtype.storm.topology.base.BaseRichSpout 中的 ack

fail

public void fail(Object msgId)

指定者：

接口 backtype.storm.spout.ISpout 中的 fail

覆盖：

类 backtype.storm.topology.base.BaseRichSpout 中的 fail

declareOutputFields

public void declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer)

isDistributed

public boolean isDistributed()