org.thales.punch.libraries.storm.bolt

Class AbstractKafkaOutput.Topic

java.lang.Object

org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput.Topic

All Implemented Interfaces:

Serializable

Enclosing class:

AbstractKafkaOutput

protected static class AbstractKafkaOutput.Topic
extends Object
implements Serializable

Gather any information related to a topic.
A new Topic is created for each Storm stream subscribed.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
com.codahale.metrics.Meter	messagesProducingRate
com.codahale.metrics.Counter	outgoingBytesRate

Constructor Summary

Constructors

Constructor and Description
Topic(String topic)

Method Summary

Modifier and Type	Method and Description
String	getName()

Methods inherited from class java.lang.Object

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

Field Detail

messagesProducingRate

public com.codahale.metrics.Meter messagesProducingRate

outgoingBytesRate

public com.codahale.metrics.Counter outgoingBytesRate

Constructor Detail

Topic

public Topic(String topic)

Method Detail

getName

public String getName()