org.apache.solr.update.processor

Class DistributedZkUpdateProcessor

java.lang.Object

org.apache.solr.update.processor.UpdateRequestProcessor

org.apache.solr.update.processor.DistributedUpdateProcessor

org.apache.solr.update.processor.DistributedZkUpdateProcessor

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

CdcrUpdateProcessor

public class DistributedZkUpdateProcessor
extends DistributedUpdateProcessor

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.solr.update.processor.DistributedUpdateProcessor

DistributedUpdateProcessor.DistribPhase, DistributedUpdateProcessor.DistributedUpdatesAsyncException, DistributedUpdateProcessor.LeaderRequestReplicationTracker, DistributedUpdateProcessor.RollupRequestReplicationTracker

Field Summary

Fields

Modifier and Type	Field and Description
protected ClusterState	clusterState
protected List<SolrCmdDistributor.Node>	nodes

Fields inherited from class org.apache.solr.update.processor.DistributedUpdateProcessor

COMMIT_END_POINT, DISTRIB_FROM, DISTRIB_FROM_COLLECTION, DISTRIB_FROM_PARENT, DISTRIB_FROM_SHARD, DISTRIB_INPLACE_PREVVERSION, forwardToLeader, isIndexChanged, isLeader, isSubShardLeader, LOG_REPLAY, maxRetriesOnForward, maxRetriesToFollowers, replicaType, req, rsp, TEST_DISTRIB_SKIP_SERVERS, updateCommand

Fields inherited from class org.apache.solr.update.processor.UpdateRequestProcessor

next

Constructor Summary

Constructors

Constructor and Description
DistributedZkUpdateProcessor(SolrQueryRequest req, SolrQueryResponse rsp, UpdateRequestProcessor next)

Method Summary

Modifier and Type	Method and Description
protected boolean	amISubShardLeader(DocCollection coll, Slice parentSlice, String id, SolrInputDocument doc) For CollectionParams.CollectionAction.SPLITSHARD
protected Replica.Type	computeReplicaType()
protected void	doClose() Override to implement resource release logic that *must* be called at the end of a request.
protected void	doDeleteById(DeleteUpdateCommand cmd)
protected void	doDeleteByQuery(DeleteUpdateCommand cmd) for implementing classes to setup request data(nodes, replicas)
protected void	doDistribAdd(AddUpdateCommand cmd)
protected void	doDistribDeleteById(DeleteUpdateCommand cmd) This method can be overridden to tamper with the cmd after the localDeleteById operation
protected void	doDistribDeleteByQuery(DeleteUpdateCommand cmd, List<SolrCmdDistributor.Node> replicas, DocCollection coll) This runs after versionDeleteByQuery is invoked, should be used to tamper or forward DeleteCommand
protected void	doDistribFinish()
protected String	getLeaderUrl(String id)
protected List<SolrCmdDistributor.Node>	getNodesByRoutingRules(ClusterState cstate, DocCollection coll, String id, SolrInputDocument doc) For CollectionParams.CollectionAction.MIGRATE
protected List<SolrCmdDistributor.Node>	getReplicaNodesForLeader(String shardId, Replica leaderReplica)
protected List<SolrCmdDistributor.Node>	getSubShardLeaders(DocCollection coll, String shardId, String docId, SolrInputDocument doc) For CollectionParams.CollectionAction.SPLITSHARD
void	processAdd(AddUpdateCommand cmd)
void	processCommit(CommitUpdateCommand cmd)
void	processDelete(DeleteUpdateCommand cmd)
void	processMergeIndexes(MergeIndexesCommand cmd)
void	processRollback(RollbackUpdateCommand cmd)
protected List<SolrCmdDistributor.Node>	setupRequest(String id, SolrInputDocument doc)
protected List<SolrCmdDistributor.Node>	setupRequest(String id, SolrInputDocument doc, String route)
protected boolean	shouldCloneCmdDoc()

Methods inherited from class org.apache.solr.update.processor.DistributedUpdateProcessor

bucketHash, doDeleteByQuery, doLocalCommit, filterParams, finish, getNonZkLeaderAssumption, versionAdd, versionDelete, versionDeleteByQuery

Methods inherited from class org.apache.solr.update.processor.UpdateRequestProcessor

close

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

nodes

protected List<SolrCmdDistributor.Node> nodes

clusterState

protected ClusterState clusterState

Constructor Detail

DistributedZkUpdateProcessor

public DistributedZkUpdateProcessor(SolrQueryRequest req,
                                    SolrQueryResponse rsp,
                                    UpdateRequestProcessor next)

Method Detail

computeReplicaType

protected Replica.Type computeReplicaType()

Overrides:

computeReplicaType in class DistributedUpdateProcessor

Returns:

the replica type of the collection.

processCommit

public void processCommit(CommitUpdateCommand cmd)
                   throws IOException

Overrides:

processCommit in class DistributedUpdateProcessor

Throws:

IOException

processAdd

public void processAdd(AddUpdateCommand cmd)
                throws IOException

Overrides:

processAdd in class DistributedUpdateProcessor

Throws:

IOException

doDistribAdd

protected void doDistribAdd(AddUpdateCommand cmd)
                     throws IOException

Overrides:

doDistribAdd in class DistributedUpdateProcessor

Throws:

IOException

processDelete

public void processDelete(DeleteUpdateCommand cmd)
                   throws IOException

Overrides:

processDelete in class DistributedUpdateProcessor

Throws:

IOException

doDeleteById

protected void doDeleteById(DeleteUpdateCommand cmd)
                     throws IOException

Overrides:

doDeleteById in class DistributedUpdateProcessor

Throws:

IOException

doDistribDeleteById

protected void doDistribDeleteById(DeleteUpdateCommand cmd)
                            throws IOException

Description copied from class: DistributedUpdateProcessor

This method can be overridden to tamper with the cmd after the localDeleteById operation

Overrides:

doDistribDeleteById in class DistributedUpdateProcessor

Parameters:

cmd - the delete command

Throws:

IOException - in case post processing failed

doDeleteByQuery

protected void doDeleteByQuery(DeleteUpdateCommand cmd)
                        throws IOException

Description copied from class: DistributedUpdateProcessor

for implementing classes to setup request data(nodes, replicas)

Overrides:

doDeleteByQuery in class DistributedUpdateProcessor

Parameters:

cmd - the delete command being processed

Throws:

IOException

doDistribDeleteByQuery

protected void doDistribDeleteByQuery(DeleteUpdateCommand cmd,
                                      List<SolrCmdDistributor.Node> replicas,
                                      DocCollection coll)
                               throws IOException

Description copied from class: DistributedUpdateProcessor

This runs after versionDeleteByQuery is invoked, should be used to tamper or forward DeleteCommand

Overrides:

doDistribDeleteByQuery in class DistributedUpdateProcessor

Parameters:

cmd - delete command

replicas - list of Nodes replicas

coll - the collection in zookeeper DocCollection.

Throws:

IOException - in case post processing failed

getLeaderUrl

protected String getLeaderUrl(String id)

Overrides:

getLeaderUrl in class DistributedUpdateProcessor

Parameters:

id - id of doc

Returns:

url of leader, or null if not found.

setupRequest

protected List<SolrCmdDistributor.Node> setupRequest(String id,
                                                     SolrInputDocument doc)

setupRequest

protected List<SolrCmdDistributor.Node> setupRequest(String id,
                                                     SolrInputDocument doc,
                                                     String route)

shouldCloneCmdDoc

protected boolean shouldCloneCmdDoc()

Overrides:

shouldCloneCmdDoc in class DistributedUpdateProcessor

Returns:

whether cmd doc should be cloned before localAdd

amISubShardLeader

protected boolean amISubShardLeader(DocCollection coll,
                                    Slice parentSlice,
                                    String id,
                                    SolrInputDocument doc)
                             throws InterruptedException

For CollectionParams.CollectionAction.SPLITSHARD

Throws:

InterruptedException

getReplicaNodesForLeader

protected List<SolrCmdDistributor.Node> getReplicaNodesForLeader(String shardId,
                                                                 Replica leaderReplica)

getSubShardLeaders

protected List<SolrCmdDistributor.Node> getSubShardLeaders(DocCollection coll,
                                                           String shardId,
                                                           String docId,
                                                           SolrInputDocument doc)

For CollectionParams.CollectionAction.SPLITSHARD

getNodesByRoutingRules

protected List<SolrCmdDistributor.Node> getNodesByRoutingRules(ClusterState cstate,
                                                               DocCollection coll,
                                                               String id,
                                                               SolrInputDocument doc)

For CollectionParams.CollectionAction.MIGRATE

doClose

protected void doClose()

Description copied from class: UpdateRequestProcessor

Override to implement resource release logic that *must* be called at the end of a request.

Overrides:

doClose in class UpdateRequestProcessor

processMergeIndexes

public void processMergeIndexes(MergeIndexesCommand cmd)
                         throws IOException

Overrides:

processMergeIndexes in class UpdateRequestProcessor

Throws:

IOException

processRollback

public void processRollback(RollbackUpdateCommand cmd)
                     throws IOException

Overrides:

processRollback in class UpdateRequestProcessor

Throws:

IOException

doDistribFinish

protected void doDistribFinish()

Overrides:

doDistribFinish in class DistributedUpdateProcessor