A B C D E F G H I K L M N O P R S T U V Z
All Classes All Packages

A

addSecurityProps(KafkaCrossDcConf, Properties) - Static method in class org.apache.solr.crossdc.common.KafkaCrossDcConf

ADMIN - org.apache.solr.crossdc.common.MirroredSolrRequest.Type

ALL - org.apache.solr.crossdc.common.CrossDcConf.CollapseUpdates

Always collapse update requests, as long as they have the same parameters.

asSolrException(Exception) - Static method in class org.apache.solr.crossdc.common.SolrExceptionUtil

B

baseHandleRequestBody(SolrQueryRequest, SolrQueryResponse) - Method in class org.apache.solr.crossdc.handler.MirroringCollectionsHandler

baseHandleRequestBody(SolrQueryRequest, SolrQueryResponse) - Method in class org.apache.solr.crossdc.handler.MirroringConfigSetsHandler

BATCH_SIZE_BYTES - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

BOOTSTRAP_SERVERS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

BUFFER_MEMORY_BYTES - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

byteArray() - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest.ExposedByteArrayContentStream

C

close() - Method in class org.apache.solr.crossdc.common.KafkaMirroringSink

close() - Method in class org.apache.solr.crossdc.common.MirroredSolrRequestSerializer

Close this serializer.

COLLAPSE_UPDATES - Static variable in class org.apache.solr.crossdc.common.CrossDcConf

CONFIG_PROPERTIES - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

ConfigProperty - Class in org.apache.solr.crossdc.common

ConfigProperty(String) - Constructor for class org.apache.solr.crossdc.common.ConfigProperty

ConfigProperty(String, String) - Constructor for class org.apache.solr.crossdc.common.ConfigProperty

ConfigProperty(String, String, boolean) - Constructor for class org.apache.solr.crossdc.common.ConfigProperty

CONFIGSET - org.apache.solr.crossdc.common.MirroredSolrRequest.Type

configure(Map<String, ?>, boolean) - Method in class org.apache.solr.crossdc.common.MirroredSolrRequestSerializer

Configure this class.

ConfUtil - Class in org.apache.solr.crossdc.common

ConfUtil() - Constructor for class org.apache.solr.crossdc.common.ConfUtil

CONSUMER_PROCESSING_THREADS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

createResponse(SolrClient) - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest.MirroredAdminRequest

createResponse(SolrClient) - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest.MirroredConfigSetRequest

CROSSDC_PROPERTIES - Static variable in class org.apache.solr.crossdc.common.CrossDcConf

CrossDcConf - Class in org.apache.solr.crossdc.common

CrossDcConf() - Constructor for class org.apache.solr.crossdc.common.CrossDcConf

CrossDcConf.CollapseUpdates - Enum in org.apache.solr.crossdc.common

Option to collapse multiple update requests in the Consumer application before sending to the target Solr.

CrossDcConf.ExpandDbq - Enum in org.apache.solr.crossdc.common

Option to expand Delete-By-Query requests on the producer side.

CrossDcConstants - Class in org.apache.solr.crossdc.common

CrossDcConstants() - Constructor for class org.apache.solr.crossdc.common.CrossDcConstants

D

DEFAULT_BATCH_SIZE_BYTES - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

DEFAULT_BUFFER_MEMORY_BYTES - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

DEFAULT_ENABLE_DATA_COMPRESSION - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

DEFAULT_FETCH_MAX_BYTES - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

DEFAULT_LINGER_MS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

DEFAULT_MAX_PARTITION_FETCH_BYTES - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

DEFAULT_MAX_POLL_INTERVAL_MS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

DEFAULT_MAX_POLL_RECORDS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

DEFAULT_MAX_REQUEST_SIZE - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

DEFAULT_NUM_RETRIES - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

DEFAULT_PORT - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

DEFAULT_REQUEST_TIMEOUT - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

DEFAULT_SESSION_TIMEOUT_MS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

DEFAULT_SLOW_SEND_THRESHOLD - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

DELIVERY_TIMEOUT_MS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

deserialize(String, byte[]) - Method in class org.apache.solr.crossdc.common.MirroredSolrRequestSerializer

DLQ_TOPIC_NAME - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

E

ENABLE_DATA_COMPRESSION - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

equals(Object) - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest

EXPAND - org.apache.solr.crossdc.common.CrossDcConf.ExpandDbq

Expand DBQs into multiple Delete-By-Id requests using matching documents on the producer side.

EXPAND_DBQ - Static variable in class org.apache.solr.crossdc.common.CrossDcConf

ExposedByteArrayContentStream(byte[], String, String) - Constructor for class org.apache.solr.crossdc.common.MirroredSolrRequest.ExposedByteArrayContentStream

F

FAILED_NO_RETRY - org.apache.solr.crossdc.common.IQueueHandler.ResultStatus

Item processing failed, and the item should not be retried (unsuccessfully processed)

FAILED_RESUBMIT - org.apache.solr.crossdc.common.IQueueHandler.ResultStatus

Item processing failed, and the item should be re-queued

FAILED_RETRY - org.apache.solr.crossdc.common.IQueueHandler.ResultStatus

Item processing failed, and the item should be retried immediately

FETCH_MAX_BYTES - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

FETCH_MAX_WAIT_MS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

FETCH_MIN_BYTES - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

fillProperties(SolrZkClient, Map<String, Object>) - Static method in class org.apache.solr.crossdc.common.ConfUtil

finish() - Method in class org.apache.solr.crossdc.update.processor.MirroringUpdateProcessor

flattenAndRedactForLogging(Map<String, Object>) - Static method in class org.apache.solr.crossdc.common.SensitivePropRedactionUtils

G

get(String) - Method in class org.apache.solr.crossdc.common.KafkaCrossDcConf

get(String) - Static method in enum org.apache.solr.crossdc.common.MirroredSolrRequest.Type

getAdditionalProperties() - Method in class org.apache.solr.crossdc.common.KafkaCrossDcConf

getAttempt() - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest

getBackoffTimeMs(MirroredSolrRequest<?>) - Method in interface org.apache.solr.crossdc.common.ResubmitBackoffPolicy

getBool(String) - Method in class org.apache.solr.crossdc.common.KafkaCrossDcConf

getContentStreams() - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest.MirroredConfigSetRequest

getDefaultValue() - Method in class org.apache.solr.crossdc.common.ConfigProperty

getDocumentSize() - Method in class org.apache.solr.crossdc.update.processor.ProducerMetrics

Histogram of the processed document size.

getDocumentTooLarge() - Method in class org.apache.solr.crossdc.update.processor.ProducerMetrics

Counter representing the number of documents that were too large to send to the Kafka topic.

getInstance(SolrQueryRequest, SolrQueryResponse, UpdateRequestProcessor) - Method in class org.apache.solr.crossdc.update.processor.MirroringUpdateRequestProcessorFactory

getInt(String) - Method in class org.apache.solr.crossdc.common.KafkaCrossDcConf

getItem() - Method in class org.apache.solr.crossdc.common.IQueueHandler.Result

getKey() - Method in class org.apache.solr.crossdc.common.ConfigProperty

getLocal() - Method in class org.apache.solr.crossdc.update.processor.ProducerMetrics

Counter representing the number of local documents processed successfully.

getLocalError() - Method in class org.apache.solr.crossdc.update.processor.ProducerMetrics

Counter representing the number of local documents processed with error.

getOrDefault(String, CrossDcConf.CollapseUpdates) - Static method in enum org.apache.solr.crossdc.common.CrossDcConf.CollapseUpdates

getOrDefault(String, CrossDcConf.ExpandDbq) - Static method in enum org.apache.solr.crossdc.common.CrossDcConf.ExpandDbq

getParams() - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest.MirroredAdminRequest

getParams() - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest.MirroredConfigSetRequest

getSolrRequest() - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest

getStream() - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest.ExposedByteArrayContentStream

getSubmitError() - Method in class org.apache.solr.crossdc.update.processor.ProducerMetrics

Counter representing the number of documents that were not submitted to the Kafka topic because of exception during execution.

getSubmitted() - Method in class org.apache.solr.crossdc.update.processor.ProducerMetrics

Counter representing the number of documents submitted to the Kafka topic.

getSubmitTimeNanos() - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest

getThis() - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest.MirroredConfigSetRequest

getType() - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest

getValue(Map<?, ?>) - Method in class org.apache.solr.crossdc.common.ConfigProperty

getValueAsBoolean(Map<?, ?>) - Method in class org.apache.solr.crossdc.common.ConfigProperty

getValueAsInt(Map<?, ?>) - Method in class org.apache.solr.crossdc.common.ConfigProperty

GROUP_ID - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

H

HANDLED - org.apache.solr.crossdc.common.IQueueHandler.ResultStatus

Item was successfully processed

handleItem(T) - Method in interface org.apache.solr.crossdc.common.IQueueHandler

handleRequestBody(SolrQueryRequest, SolrQueryResponse) - Method in class org.apache.solr.crossdc.handler.MirroringCollectionsHandler

handleRequestBody(SolrQueryRequest, SolrQueryResponse) - Method in class org.apache.solr.crossdc.handler.MirroringConfigSetsHandler

hashCode() - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest

I

INDEX_UNMIRRORABLE_DOCS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

inform(SolrCore) - Method in class org.apache.solr.crossdc.update.processor.MirroringUpdateRequestProcessorFactory

init(NamedList<?>) - Method in class org.apache.solr.crossdc.update.processor.MirroringUpdateRequestProcessorFactory

IQueueHandler<T> - Interface in org.apache.solr.crossdc.common

IQueueHandler.Result<T> - Class in org.apache.solr.crossdc.common

IQueueHandler.ResultStatus - Enum in org.apache.solr.crossdc.common

isRequired() - Method in class org.apache.solr.crossdc.common.ConfigProperty

K

KafkaCrossDcConf - Class in org.apache.solr.crossdc.common

KafkaCrossDcConf(Map<String, Object>) - Constructor for class org.apache.solr.crossdc.common.KafkaCrossDcConf

KafkaMirroringSink - Class in org.apache.solr.crossdc.common

KafkaMirroringSink(KafkaCrossDcConf) - Constructor for class org.apache.solr.crossdc.common.KafkaMirroringSink

KafkaRequestMirroringHandler - Class in org.apache.solr.crossdc.update.processor

KafkaRequestMirroringHandler(KafkaMirroringSink) - Constructor for class org.apache.solr.crossdc.update.processor.KafkaRequestMirroringHandler

L

LINGER_MS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

M

MAX_ATTEMPTS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

MAX_COLLAPSE_RECORDS - Static variable in class org.apache.solr.crossdc.common.CrossDcConf

MAX_PARTITION_FETCH_BYTES - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

MAX_POLL_INTERVAL_MS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

The maximum delay between invocations of poll() when using consumer group management.

MAX_POLL_RECORDS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

MAX_REQUEST_SIZE_BYTES - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

mirror(UpdateRequest) - Method in class org.apache.solr.crossdc.update.processor.KafkaRequestMirroringHandler

When called, should handle submitting the request to the queue

mirror(UpdateRequest) - Method in interface org.apache.solr.crossdc.update.processor.RequestMirroringHandler

When called, should handle submitting the request to the replica clusters

MIRROR_COLLECTIONS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

MIRROR_COMMITS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

MirroredAdminRequest(CollectionParams.CollectionAction, ModifiableSolrParams) - Constructor for class org.apache.solr.crossdc.common.MirroredSolrRequest.MirroredAdminRequest

MirroredConfigSetRequest(SolrRequest.METHOD, SolrParams, Collection<ContentStream>) - Constructor for class org.apache.solr.crossdc.common.MirroredSolrRequest.MirroredConfigSetRequest

MirroredSolrRequest<T extends org.apache.solr.client.solrj.SolrResponse> - Class in org.apache.solr.crossdc.common

Class to encapsulate a mirrored Solr request.

MirroredSolrRequest(int, long) - Constructor for class org.apache.solr.crossdc.common.MirroredSolrRequest

MirroredSolrRequest(SolrRequest<T>) - Constructor for class org.apache.solr.crossdc.common.MirroredSolrRequest

MirroredSolrRequest(MirroredSolrRequest.Type, int, SolrRequest<T>) - Constructor for class org.apache.solr.crossdc.common.MirroredSolrRequest

MirroredSolrRequest(MirroredSolrRequest.Type, int, SolrRequest<T>, long) - Constructor for class org.apache.solr.crossdc.common.MirroredSolrRequest

MirroredSolrRequest(MirroredSolrRequest.Type, SolrRequest<T>) - Constructor for class org.apache.solr.crossdc.common.MirroredSolrRequest

MirroredSolrRequest.ExposedByteArrayContentStream - Class in org.apache.solr.crossdc.common

MirroredSolrRequest.MirroredAdminRequest - Class in org.apache.solr.crossdc.common

MirroredSolrRequest.MirroredConfigSetRequest - Class in org.apache.solr.crossdc.common

MirroredSolrRequest.Type - Enum in org.apache.solr.crossdc.common

MirroredSolrRequestSerializer - Class in org.apache.solr.crossdc.common

MirroredSolrRequestSerializer() - Constructor for class org.apache.solr.crossdc.common.MirroredSolrRequestSerializer

MirroringCollectionsHandler - Class in org.apache.solr.crossdc.handler

MirroringCollectionsHandler(CoreContainer) - Constructor for class org.apache.solr.crossdc.handler.MirroringCollectionsHandler

MirroringCollectionsHandler(CoreContainer, KafkaMirroringSink) - Constructor for class org.apache.solr.crossdc.handler.MirroringCollectionsHandler

MirroringConfigSetsHandler - Class in org.apache.solr.crossdc.handler

MirroringConfigSetsHandler(CoreContainer) - Constructor for class org.apache.solr.crossdc.handler.MirroringConfigSetsHandler

Overloaded ctor to inject CoreContainer into the handler.

MirroringConfigSetsHandler(CoreContainer, KafkaMirroringSink) - Constructor for class org.apache.solr.crossdc.handler.MirroringConfigSetsHandler

MirroringException - Exception in org.apache.solr.crossdc.common

Exception thrown during cross-dc mirroring

MirroringException - Exception in org.apache.solr.crossdc.update.processor

Wrapper class for Mirroring exceptions.

MirroringException() - Constructor for exception org.apache.solr.crossdc.common.MirroringException

MirroringException() - Constructor for exception org.apache.solr.crossdc.update.processor.MirroringException

MirroringException(String) - Constructor for exception org.apache.solr.crossdc.common.MirroringException

MirroringException(String) - Constructor for exception org.apache.solr.crossdc.update.processor.MirroringException

MirroringException(String, Throwable) - Constructor for exception org.apache.solr.crossdc.common.MirroringException

MirroringException(String, Throwable) - Constructor for exception org.apache.solr.crossdc.update.processor.MirroringException

MirroringException(Throwable) - Constructor for exception org.apache.solr.crossdc.common.MirroringException

MirroringException(Throwable) - Constructor for exception org.apache.solr.crossdc.update.processor.MirroringException

MirroringUpdateProcessor - Class in org.apache.solr.crossdc.update.processor

MirroringUpdateProcessor(UpdateRequestProcessor, boolean, boolean, boolean, CrossDcConf.ExpandDbq, long, SolrParams, DistributedUpdateProcessor.DistribPhase, RequestMirroringHandler, ProducerMetrics) - Constructor for class org.apache.solr.crossdc.update.processor.MirroringUpdateProcessor

MirroringUpdateRequestProcessorFactory - Class in org.apache.solr.crossdc.update.processor

An update processor that works with the UpdateRequestProcessorFactory to mirror update requests by submitting them to a sink that implements a queue producer.

MirroringUpdateRequestProcessorFactory() - Constructor for class org.apache.solr.crossdc.update.processor.MirroringUpdateRequestProcessorFactory

MirroringUpdateRequestProcessorFactory.NoOpUpdateRequestProcessor - Class in org.apache.solr.crossdc.update.processor

N

NONE - org.apache.solr.crossdc.common.CrossDcConf.CollapseUpdates

Don't collapse any update requests, send them directly as-is.

NONE - org.apache.solr.crossdc.common.CrossDcConf.ExpandDbq

Don't expand DBQs, mirror them as-is.

NOT_HANDLED_SHUTDOWN - org.apache.solr.crossdc.common.IQueueHandler.ResultStatus

Item was not processed, and the consumer should shutdown

NUM_RETRIES - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

O

of(ContentStream) - Static method in class org.apache.solr.crossdc.common.MirroredSolrRequest.ExposedByteArrayContentStream

org.apache.solr.crossdc.common - package org.apache.solr.crossdc.common

Common code for managing Cross DC replication.

org.apache.solr.crossdc.handler - package org.apache.solr.crossdc.handler

Admin Handlers for Cross DC replication.

org.apache.solr.crossdc.update.processor - package org.apache.solr.crossdc.update.processor

UpdateRequestProcessors for Cross DC replication.

P

PARTIAL - org.apache.solr.crossdc.common.CrossDcConf.CollapseUpdates

Collapse only update requests that don't contain any delete operations.

PORT - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

processAdd(AddUpdateCommand) - Method in class org.apache.solr.crossdc.update.processor.MirroringUpdateProcessor

processCommit(CommitUpdateCommand) - Method in class org.apache.solr.crossdc.update.processor.MirroringUpdateProcessor

processDelete(DeleteUpdateCommand) - Method in class org.apache.solr.crossdc.update.processor.MirroringUpdateProcessor

processRollback(RollbackUpdateCommand) - Method in class org.apache.solr.crossdc.update.processor.MirroringUpdateProcessor

ProducerMetrics - Class in org.apache.solr.crossdc.update.processor

Metrics presented for each SolrCore using `crossdc.producer.` path.

ProducerMetrics(SolrMetricsContext, SolrCore) - Constructor for class org.apache.solr.crossdc.update.processor.ProducerMetrics

propertyRequiresRedaction(String) - Static method in class org.apache.solr.crossdc.common.SensitivePropRedactionUtils

R

readZkProps(Map<String, Object>, Properties) - Static method in class org.apache.solr.crossdc.common.KafkaCrossDcConf

redactPropertyIfNecessary(String, String) - Static method in class org.apache.solr.crossdc.common.SensitivePropRedactionUtils

Redacts a property value if necessary, and returns the result.

REQUEST_TIMEOUT_MS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

RequestMirroringHandler - Interface in org.apache.solr.crossdc.update.processor

Plugin classes must implement this interface to be usable as the handlers for request mirroring

RequestMirroringSink - Interface in org.apache.solr.crossdc.common

ResubmitBackoffPolicy - Interface in org.apache.solr.crossdc.common

Result(IQueueHandler.ResultStatus) - Constructor for class org.apache.solr.crossdc.common.IQueueHandler.Result

Result(IQueueHandler.ResultStatus, Throwable) - Constructor for class org.apache.solr.crossdc.common.IQueueHandler.Result

Result(IQueueHandler.ResultStatus, Throwable, T) - Constructor for class org.apache.solr.crossdc.common.IQueueHandler.Result

RETRY_BACKOFF_MS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

S

SECURITY_CONFIG_PROPERTIES - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

SensitivePropRedactionUtils - Class in org.apache.solr.crossdc.common

Helper functionality related to redacting arbitrary properties which may contain sensitive password information.

SensitivePropRedactionUtils() - Constructor for class org.apache.solr.crossdc.common.SensitivePropRedactionUtils

serialize(String, MirroredSolrRequest<?>) - Method in class org.apache.solr.crossdc.common.MirroredSolrRequestSerializer

Convert data into a byte array.

SERVER_SHOULD_MIRROR - Static variable in class org.apache.solr.crossdc.update.processor.MirroringUpdateRequestProcessorFactory

SESSION_TIMEOUT_MS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

setAttempt(int) - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest

setParams(SolrRequest<?>, ModifiableSolrParams) - Static method in class org.apache.solr.crossdc.common.MirroredSolrRequest

setParams(ModifiableSolrParams) - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest.MirroredAdminRequest

setParams(ModifiableSolrParams) - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest.MirroredConfigSetRequest

setSubmitTimeNanos(long) - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest

SHOULD_MIRROR - Static variable in class org.apache.solr.crossdc.common.CrossDcConstants

SLOW_SUBMIT_THRESHOLD_MS - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

SolrExceptionUtil - Class in org.apache.solr.crossdc.common

SolrExceptionUtil() - Constructor for class org.apache.solr.crossdc.common.SolrExceptionUtil

status() - Method in class org.apache.solr.crossdc.common.IQueueHandler.Result

submit(MirroredSolrRequest<?>) - Method in class org.apache.solr.crossdc.common.KafkaMirroringSink

submit(MirroredSolrRequest<?>) - Method in interface org.apache.solr.crossdc.common.RequestMirroringSink

Submits a mirrored solr request to the appropriate end-point such that it is eventually received by solr A direct sink may simply use CloudSolrServer to process requests directly.

submitToDlq(MirroredSolrRequest<?>) - Method in class org.apache.solr.crossdc.common.KafkaMirroringSink

submitToDlq(MirroredSolrRequest<?>) - Method in interface org.apache.solr.crossdc.common.RequestMirroringSink

T

throwable() - Method in class org.apache.solr.crossdc.common.IQueueHandler.Result

TOPIC_NAME - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

toString() - Method in class org.apache.solr.crossdc.common.KafkaCrossDcConf

toString() - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest.ExposedByteArrayContentStream

toString() - Method in class org.apache.solr.crossdc.common.MirroredSolrRequest

U

UNKNOWN - org.apache.solr.crossdc.common.MirroredSolrRequest.Type

UPDATE - org.apache.solr.crossdc.common.MirroredSolrRequest.Type

V

valueOf(String) - Static method in enum org.apache.solr.crossdc.common.CrossDcConf.CollapseUpdates

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.solr.crossdc.common.CrossDcConf.ExpandDbq

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.solr.crossdc.common.IQueueHandler.ResultStatus

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.solr.crossdc.common.MirroredSolrRequest.Type

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.solr.crossdc.common.CrossDcConf.CollapseUpdates

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.solr.crossdc.common.CrossDcConf.ExpandDbq

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.solr.crossdc.common.IQueueHandler.ResultStatus

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.solr.crossdc.common.MirroredSolrRequest.Type

Returns an array containing the constants of this enum type, in the order they are declared.

verifyProperties(Map<String, Object>) - Static method in class org.apache.solr.crossdc.common.ConfUtil

Z

ZK_CONNECT_STRING - Static variable in class org.apache.solr.crossdc.common.KafkaCrossDcConf

ZK_CROSSDC_PROPS_PATH - Static variable in class org.apache.solr.crossdc.common.CrossDcConf

A B C D E F G H I K L M N O P R S T U V Z
All Classes All Packages