List of routing() Examples

Examples of routing()

crate.elasticsearch.action.export.ExportRequest.routing()
A comma separated list of routing values to control the shards the search will be executed on.
crate.elasticsearch.action.searchinto.SearchIntoRequest.routing()
A comma separated list of routing values to control the shards the search will be executed on.
org.elasticsearch.action.DocumentRequest.routing()
Set the routing for this request @param routing @return the Request
org.elasticsearch.action.admin.cluster.shards.ClusterSearchShardsRequest.routing()
A comma separated list of routing values to control the shards the search will be executed on.
org.elasticsearch.action.admin.indices.alias.IndicesAliasesRequest.AliasActions.routing()
org.elasticsearch.action.count.CountRequest.routing()
A comma separated list of routing values to control the shards the search will be executed on.
org.elasticsearch.action.delete.DeleteRequest.routing()
Controls the shard routing of the request. Using this value to hash the shard and not the id.
org.elasticsearch.action.deletebyquery.DeleteByQueryRequest.routing()
A comma separated list of routing values to control the shards the search will be executed on.
org.elasticsearch.action.exists.ExistsRequest.routing()
A comma separated list of routing values to control the shards the search will be executed on.
org.elasticsearch.action.explain.ExplainRequest.routing()
org.elasticsearch.action.get.GetRequest.routing()
Controls the shard routing of the request. Using this value to hash the shard and not the id.
org.elasticsearch.action.index.IndexRequest.routing()
Controls the shard routing of the request. Using this value to hash the shard and not the id.
org.elasticsearch.action.mlt.MoreLikeThisRequest.routing()
@return The routing for this request. This used for the `get` part of the mlt request.
org.elasticsearch.action.search.SearchRequest.routing()
A comma separated list of routing values to control the shards the search will be executed on.
org.elasticsearch.action.suggest.SuggestRequest.routing()
A comma separated list of routing values to control the shards the search will be executed on.
org.elasticsearch.action.update.UpdateRequest.routing()
Controls the shard routing of the request. Using this value to hash the shard and not the id.
org.elasticsearch.cluster.metadata.AliasAction.routing()
org.elasticsearch.cluster.metadata.MappingMetaData.routing()
org.elasticsearch.index.fieldvisitor.UidAndRoutingFieldsVisitor.routing()
org.elasticsearch.river.cluster.RiverClusterState.routing()

Examples of org.elasticsearch.index.fieldvisitor.UidAndRoutingFieldsVisitor.routing()

            try {
                UidAndRoutingFieldsVisitor fieldsVisitor = new UidAndRoutingFieldsVisitor();
                context.reader().document(doc, fieldsVisitor);
                Uid uid = fieldsVisitor.uid();
                final long version = Versions.loadVersion(context.reader(), new Term(UidFieldMapper.NAME, uid.toBytesRef()));
                docsToPurge.add(new DocToPurge(uid.type(), uid.id(), version, fieldsVisitor.routing()));
            } catch (Exception e) {
                logger.trace("failed to collect doc", e);
            }
        }

View Full Code Here

Examples of org.elasticsearch.river.cluster.RiverClusterState.routing()

            DiscoveryNode localNode = clusterService.localNode();
            RiverClusterState state = event.state();


            // first, go over and delete ones that either don't exists or are not allocated
            for (RiverName riverName : rivers.keySet()) {
                RiverRouting routing = state.routing().routing(riverName);
                if (routing == null || !localNode.equals(routing.node())) {
                    // not routed at all, and not allocated here, clean it (we delete the relevant ones before)
                    closeRiver(riverName);
                }
            }

View Full Code Here

Examples of org.elasticsearch.river.cluster.RiverClusterState.routing()

                    // not routed at all, and not allocated here, clean it (we delete the relevant ones before)
                    closeRiver(riverName);
                }
            }


            for (final RiverRouting routing : state.routing()) {
                // not allocated
                if (routing.node() == null) {
                    continue;
                }
                // only apply changes to the local node

View Full Code Here

Examples of org.elasticsearch.river.cluster.RiverClusterState.routing()

            DiscoveryNode localNode = clusterService.localNode();
            RiverClusterState state = event.state();


            // first, go over and delete ones that either don't exists or are not allocated
            for (final RiverName riverName : rivers.keySet()) {
                RiverRouting routing = state.routing().routing(riverName);
                if (routing == null || !localNode.equals(routing.node())) {
                    // not routed at all, and not allocated here, clean it (we delete the relevant ones before)
                    closeRiver(riverName);
                    // also, double check and delete the river content if it was deleted (_meta does not exists)
                    try {

View Full Code Here

Examples of org.elasticsearch.river.cluster.RiverClusterState.routing()

                        logger.warn("unexpected failure when trying to verify river [{}] deleted", e, riverName.name());
                    }
                }
            }


            for (final RiverRouting routing : state.routing()) {
                // not allocated
                if (routing.node() == null) {
                    logger.trace("river {} has no routing node", routing.riverName().getName());
                    continue;
                }

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.