Package | Description |
---|---|
org.apache.storm.kafka | |
org.apache.storm.kafka.trident |
Modifier and Type | Method and Description |
---|---|
Partition |
PartitionManager.getPartition() |
Modifier and Type | Method and Description |
---|---|
static List<Partition> |
KafkaUtils.calculatePartitionsForTask(List<GlobalPartitionInformation> partitons,
int totalTasks,
int taskIndex,
int taskId) |
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) |
Modifier and Type | Method and Description |
---|---|
void |
KafkaUtils.KafkaOffsetMetric.refreshPartitions(Set<Partition> partitions) |
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) |
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() |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.