Uses of Class
org.apache.storm.kafka.Partition

Packages that use Partition

Package	Description
org.apache.storm.kafka
org.apache.storm.kafka.trident

Uses of Partition in org.apache.storm.kafka

Methods in org.apache.storm.kafka that return Partition

Modifier and Type	Method and Description
Partition	PartitionManager.getPartition()

Methods in org.apache.storm.kafka that return types with arguments of type Partition

Modifier and Type	Method and Description
static List<Partition>	KafkaUtils.calculatePartitionsForTask(List<GlobalPartitionInformation> partitons, int totalTasks, int taskIndex, int taskId)

Methods in org.apache.storm.kafka with parameters of type Partition

Modifier and Type	Method and Description
List<Object>	StringMessageAndMetadataScheme.deserializeMessageWithMetadata(ByteBuffer message, Partition partition, long offset)
Iterable<List<Object>>	MessageMetadataSchemeAsMultiScheme.deserializeMessageWithMetadata(ByteBuffer message, Partition partition, long offset)
List<Object>	MessageMetadataScheme.deserializeMessageWithMetadata(ByteBuffer message, Partition partition, long offset)
static kafka.javaapi.message.ByteBufferMessageSet	KafkaUtils.fetchMessages(KafkaConfig config, kafka.javaapi.consumer.SimpleConsumer consumer, Partition partition, long offset)
static Iterable<List<Object>>	KafkaUtils.generateTuples(MessageMetadataSchemeAsMultiScheme scheme, kafka.message.Message msg, Partition partition, long offset)
kafka.javaapi.consumer.SimpleConsumer	DynamicPartitionConnections.getConnection(Partition partition)
PartitionManager	ZkCoordinator.getManager(Partition partition)
PartitionManager	StaticCoordinator.getManager(Partition partition)
PartitionManager	PartitionCoordinator.getManager(Partition partition)
kafka.javaapi.consumer.SimpleConsumer	DynamicPartitionConnections.register(Partition partition)
void	KafkaUtils.KafkaOffsetMetric.setOffsetData(Partition partition, PartitionManager.OffsetData offsetData)
void	DynamicPartitionConnections.unregister(Partition partition)

Method parameters in org.apache.storm.kafka with type arguments of type Partition

Modifier and Type	Method and Description
void	KafkaUtils.KafkaOffsetMetric.refreshPartitions(Set<Partition> partitions)

Constructors in org.apache.storm.kafka with parameters of type Partition

Constructor and Description
PartitionManager(DynamicPartitionConnections connections, String topologyInstanceId, ZkState state, Map stormConf, SpoutConfig spoutConfig, Partition id)
PartitionManager(DynamicPartitionConnections connections, String topologyInstanceId, ZkState state, Map stormConf, SpoutConfig spoutConfig, Partition id, PartitionManager previousManager)

Uses of Partition in org.apache.storm.kafka.trident

Methods in org.apache.storm.kafka.trident that return types with arguments of type Partition

Modifier and Type	Method and Description
IOpaquePartitionedTridentSpout.Emitter<List<GlobalPartitionInformation>,Partition,Map>	TridentKafkaEmitter.asOpaqueEmitter()
IOpaquePartitionedTridentSpout.Emitter<List<GlobalPartitionInformation>,Partition,Map>	OpaqueTridentKafkaSpout.getEmitter(Map conf, TopologyContext context) Deprecated.
List<Partition>	GlobalPartitionInformation.getOrderedPartitions()
Iterator<Partition>	GlobalPartitionInformation.iterator()