|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Partition | |
---|---|
storm.kafka | |
storm.kafka.trident |
Uses of Partition in storm.kafka |
---|
Methods in storm.kafka that return Partition | |
---|---|
Partition |
PartitionManager.getPartition()
|
Methods in storm.kafka that return types with arguments of type Partition | |
---|---|
static List<Partition> |
KafkaUtils.calculatePartitionsForTask(GlobalPartitionInformation partitionInformation,
int totalTasks,
int taskIndex)
|
Methods in storm.kafka with parameters of type Partition | |
---|---|
static kafka.javaapi.message.ByteBufferMessageSet |
KafkaUtils.fetchMessages(KafkaConfig config,
kafka.javaapi.consumer.SimpleConsumer consumer,
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.setLatestEmittedOffset(Partition partition,
long offset)
|
void |
DynamicPartitionConnections.unregister(Partition partition)
|
Method parameters in storm.kafka with type arguments of type Partition | |
---|---|
void |
KafkaUtils.KafkaOffsetMetric.refreshPartitions(Set<Partition> partitions)
|
Constructors in storm.kafka with parameters of type Partition | |
---|---|
PartitionManager(DynamicPartitionConnections connections,
String topologyInstanceId,
ZkState state,
Map stormConf,
SpoutConfig spoutConfig,
Partition id)
|
Uses of Partition in storm.kafka.trident |
---|
Methods in storm.kafka.trident that return types with arguments of type Partition | |
---|---|
IOpaquePartitionedTridentSpout.Emitter<GlobalPartitionInformation,Partition,Map> |
TridentKafkaEmitter.asOpaqueEmitter()
|
IOpaquePartitionedTridentSpout.Emitter<GlobalPartitionInformation,Partition,Map> |
OpaqueTridentKafkaSpout.getEmitter(Map conf,
TopologyContext context)
|
List<Partition> |
GlobalPartitionInformation.getOrderedPartitions()
|
Iterator<Partition> |
GlobalPartitionInformation.iterator()
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |