B C G H K L M O P R S U
All Classes All Packages

B

BlockingQueue<E> - Class in org.apache.solr.crossdc.manager.consumer

BlockingQueue(int) - Constructor for class org.apache.solr.crossdc.manager.consumer.BlockingQueue

C

checkOffsetUpdates() - Method in class org.apache.solr.crossdc.manager.consumer.PartitionManager

close() - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer.SolrClientSupplier

Consumer - Class in org.apache.solr.crossdc.manager.consumer

Consumer() - Constructor for class org.apache.solr.crossdc.manager.consumer.Consumer

Consumer.CrossDcConsumer - Class in org.apache.solr.crossdc.manager.consumer

Abstract class for defining cross-dc consumer

createKafkaConsumer(Properties) - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

createKafkaMirroringSink(KafkaCrossDcConf) - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

createSolrClient() - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer.SolrClientSupplier

createSolrClientSupplier(KafkaCrossDcConf) - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

createSolrMessageProcessor() - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

CrossDcConsumer() - Constructor for class org.apache.solr.crossdc.manager.consumer.Consumer.CrossDcConsumer

G

get() - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer.SolrClientSupplier

getCrossDcConsumer(KafkaCrossDcConf, CountDownLatch) - Method in class org.apache.solr.crossdc.manager.consumer.Consumer

getPartitionWork(TopicPartition) - Method in class org.apache.solr.crossdc.manager.consumer.PartitionManager

getResubmitBackoffPolicy() - Method in class org.apache.solr.crossdc.manager.messageprocessor.MessageProcessor

H

handleItem(MirroredSolrRequest<?>) - Method in class org.apache.solr.crossdc.manager.messageprocessor.SolrMessageProcessor

K

KafkaCrossDcConsumer - Class in org.apache.solr.crossdc.manager.consumer

This is a Java class called KafkaCrossDcConsumer, which is part of the Apache Solr framework.

KafkaCrossDcConsumer(KafkaCrossDcConf, CountDownLatch) - Constructor for class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

KafkaCrossDcConsumer.SolrClientSupplier - Class in org.apache.solr.crossdc.manager.consumer

Supplier for creating and managing a working CloudSolrClient instance.

L

logMetrics(MetricRegistry) - Static method in class org.apache.solr.crossdc.manager.consumer.Util

M

main(String[]) - Static method in class org.apache.solr.crossdc.manager.consumer.Consumer

MessageProcessor - Class in org.apache.solr.crossdc.manager.messageprocessor

MessageProcessor(ResubmitBackoffPolicy) - Constructor for class org.apache.solr.crossdc.manager.messageprocessor.MessageProcessor

METRICS_REGISTRY - Static variable in class org.apache.solr.crossdc.manager.consumer.Consumer

O

offer(E) - Method in class org.apache.solr.crossdc.manager.consumer.BlockingQueue

org.apache.solr.crossdc.manager.consumer - package org.apache.solr.crossdc.manager.consumer

Logic for consuming information from Queues.

org.apache.solr.crossdc.manager.messageprocessor - package org.apache.solr.crossdc.manager.messageprocessor

Processing CrossDC replication messages.

P

PartitionManager - Class in org.apache.solr.crossdc.manager.consumer

printKafkaInfo(String, String) - Static method in class org.apache.solr.crossdc.manager.consumer.Util

processResult(MirroredSolrRequest.Type, IQueueHandler.Result<MirroredSolrRequest<?>>) - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

R

run() - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

This is where the magic happens.

S

sendBatch(SolrRequest<?>, MirroredSolrRequest.Type, ConsumerRecord<String, MirroredSolrRequest<?>>, PartitionManager.WorkUnit) - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

shutdown() - Method in class org.apache.solr.crossdc.manager.consumer.Consumer

shutdown() - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

Shutdown the Kafka consumer by calling wakeup.

solrClientSupplier - Variable in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

SolrClientSupplier(String) - Constructor for class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer.SolrClientSupplier

SolrMessageProcessor - Class in org.apache.solr.crossdc.manager.messageprocessor

Message processor implements all the logic to process a MirroredSolrRequest.

SolrMessageProcessor(Supplier<CloudSolrClient>, ResubmitBackoffPolicy) - Constructor for class org.apache.solr.crossdc.manager.messageprocessor.SolrMessageProcessor

start() - Method in class org.apache.solr.crossdc.manager.consumer.Consumer

start(Map<String, Object>) - Method in class org.apache.solr.crossdc.manager.consumer.Consumer

U

uncheckedSleep(long) - Method in class org.apache.solr.crossdc.manager.messageprocessor.SolrMessageProcessor

Util - Class in org.apache.solr.crossdc.manager.consumer

Util() - Constructor for class org.apache.solr.crossdc.manager.consumer.Util

B C G H K L M O P R S U
All Classes All Packages