public class ShardedDocumentQuery<T> extends DocumentQuery<T>
afterQueryExecutedCallback, afterStreamExecutedCallback, allowMultipleIndexEntriesForSameDocumentToResultTransformer, beforeQueryExecutionAction, clazz, cutoff, cutoffEtag, defaultField, defaultOperator, disableCaching, disableEntitiesTracking, distanceErrorPct, distinct, fieldsToFetch, groupByFields, highlightedFields, highlighterKeyName, highlighterPostTags, highlighterPreTags, highlightings, includes, indexName, isMapReduce, isSpatialQuery, lastEquality, negate, orderByFields, pageSize, projectionFields, queryListeners, queryOperation, queryShape, queryStats, queryText, resultsTransformer, rootTypes, shouldExplainScores, showQueryTimings, sortByHints, spatialFieldName, spatialRelation, spatialUnits, start, theDatabaseCommands, theSession, theWaitForNonStaleResults, theWaitForNonStaleResultsAsOfNow, timeout, transformerParameters, transformResultsFunc
Constructor and Description |
---|
ShardedDocumentQuery(Class<T> clazz,
InMemoryDocumentSessionOperations session,
Function1<ShardRequestData,List<Tuple<String,IDatabaseCommands>>> getShardsToOperateOn,
ShardStrategy shardStrategy,
String indexName,
String[] fieldsToFetch,
String[] projectionFields,
List<IDocumentQueryListener> queryListeneres,
boolean isMapReduce) |
Modifier and Type | Method and Description |
---|---|
protected static void |
assertNoDuplicateIdsInResults(List<QueryOperation> shardQueryOperations) |
Lazy<Integer> |
countLazily()
Register the query as a lazy-count query in the session and return a lazy
instance that will evaluate the query only when needed
|
protected void |
executeActualQuery() |
IDatabaseCommands |
getDatabaseCommands()
Grant access to the database commands
|
void |
initSync() |
Lazy<List<T>> |
lazily(Action1<List<T>> onEval)
Register the query as a lazy query in the session and return a lazy
instance that will evaluate the query only when needed
|
<TProjection> |
selectFields(Class<TProjection> projectionClass,
String[] fields,
String[] projections)
Selects the specified fields directly from the index
|
addOrder, any, containsAll, containsAny, distinct, explainScores, first, firstOrDefault, highlight, highlight, highlight, isDistinct, not, orderBy, orderByDescending, orderByScore, orderByScoreDescending, relatesToShape, relatesToShape, search, search, selectFields, selectFields, setResultTransformer, setResultTransformer, setTransformerParameters, single, singleOrDefault, sortByDistance, sortByDistance, sortByDistance, spatial, spatial, toFacets, toFacets, toFacets, toFacets, toFacets, toFacets, toFacetsLazy, toFacetsLazy, toFacetsLazy, toFacetsLazy, toFacetsLazy, toFacetsLazy, toList, toString, whereBetween, whereBetweenOrEqual, whereEndsWith, whereEquals, whereEquals, whereGreaterThan, whereGreaterThanOrEqual, whereIn, whereLessThan, whereLessThanOrEqual, whereStartsWith, withinRadiusOf, withinRadiusOf, withinRadiusOf, withinRadiusOf
addOrder, addOrder, addRootType, afterQueryExecuted, afterStreamExecuted, andAlso, beforeQueryExecution, boost, clearSortHints, closeSubclause, containsAll, containsAny, customSortUsing, customSortUsing, executeBeforeQueryListeners, fuzzy, generateIndexQuery, generateQueryWithinRadiusOf, generateQueryWithinRadiusOf, generateQueryWithinRadiusOf, generateSpatialQueryData, generateSpatialQueryData, generateSpatialQueryData, generateSpatialQueryData, generateSpatialQueryData, getDocumentConvention, getElementType, getFacets, getFacets, getIndexQueried, getIndexQuery, getLastEqualityTerm, getMemberQueryPath, getMemberQueryPathForOrderBy, getMemberQueryPaths, getMemberQueryPathsForOrderBy, getProjectionFields, getQueryResult, getSession, highlight, highlight, highlight, include, include, include, initializeQueryOperation, intersect, invokeAfterQueryExecuted, invokeAfterStreamExecuted, iterator, lazily, negateNext, noCaching, noTracking, openSubclause, orderBy, orderByDescending, orElse, proximity, randomOrdering, randomOrdering, search, search, setAllowMultipleIndexEntriesForSameDocumentToResultTransformer, setHighlighterTags, setHighlighterTags, setOriginalQueryType, showTimings, skip, statistics, take, transformResults, updateStatsAndHighlightings, usingDefaultField, usingDefaultOperator, waitForNonStaleResults, waitForNonStaleResults, waitForNonStaleResultsAsOf, waitForNonStaleResultsAsOf, waitForNonStaleResultsAsOf, waitForNonStaleResultsAsOf, waitForNonStaleResultsAsOfLastWrite, waitForNonStaleResultsAsOfLastWrite, waitForNonStaleResultsAsOfNow, waitForNonStaleResultsAsOfNow, where, whereBetween, whereBetweenOrEqual, whereEndsWith, whereEquals, whereEquals, whereEquals, whereGreaterThan, whereGreaterThanOrEqual, whereIn, whereLessThan, whereLessThanOrEqual, whereStartsWith
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getFacets, getFacets, getIndexQuery, getQueryResult, lazily
addOrder, addOrder, afterQueryExecuted, afterStreamExecuted, andAlso, beforeQueryExecution, boost, closeSubclause, containsAll, containsAny, customSortUsing, fuzzy, getDocumentConvention, highlight, highlight, highlight, include, include, intersect, invokeAfterQueryExecuted, invokeAfterStreamExecuted, negateNext, noCaching, noTracking, openSubclause, orderBy, orderByDescending, orElse, proximity, randomOrdering, randomOrdering, search, search, setAllowMultipleIndexEntriesForSameDocumentToResultTransformer, setHighlighterTags, setHighlighterTags, showTimings, skip, statistics, take, usingDefaultField, usingDefaultOperator, waitForNonStaleResults, waitForNonStaleResults, waitForNonStaleResultsAsOf, waitForNonStaleResultsAsOf, waitForNonStaleResultsAsOf, waitForNonStaleResultsAsOf, waitForNonStaleResultsAsOfLastWrite, waitForNonStaleResultsAsOfLastWrite, waitForNonStaleResultsAsOfNow, waitForNonStaleResultsAsOfNow, where, whereBetween, whereBetweenOrEqual, whereEndsWith, whereEquals, whereEquals, whereEquals, whereGreaterThan, whereGreaterThanOrEqual, whereIn, whereLessThan, whereLessThanOrEqual, whereStartsWith
public ShardedDocumentQuery(Class<T> clazz, InMemoryDocumentSessionOperations session, Function1<ShardRequestData,List<Tuple<String,IDatabaseCommands>>> getShardsToOperateOn, ShardStrategy shardStrategy, String indexName, String[] fieldsToFetch, String[] projectionFields, List<IDocumentQueryListener> queryListeneres, boolean isMapReduce)
public void initSync()
initSync
in class AbstractDocumentQuery<T,DocumentQuery<T>>
public <TProjection> IDocumentQuery<TProjection> selectFields(Class<TProjection> projectionClass, String[] fields, String[] projections)
DocumentQuery
selectFields
in interface IDocumentQuery<T>
selectFields
in class DocumentQuery<T>
projectionClass
- The class of the projectionfields
- Array of fields to load.projections
- Array of field projections.protected void executeActualQuery()
executeActualQuery
in class AbstractDocumentQuery<T,DocumentQuery<T>>
protected static void assertNoDuplicateIdsInResults(List<QueryOperation> shardQueryOperations)
public IDatabaseCommands getDatabaseCommands()
AbstractDocumentQuery
getDatabaseCommands
in interface IRavenQueryInspector
getDatabaseCommands
in class AbstractDocumentQuery<T,DocumentQuery<T>>
public Lazy<List<T>> lazily(Action1<List<T>> onEval)
lazily
in interface IDocumentQuery<T>
lazily
in class AbstractDocumentQuery<T,DocumentQuery<T>>
public Lazy<Integer> countLazily()
countLazily
in interface IDocumentQuery<T>
countLazily
in class AbstractDocumentQuery<T,DocumentQuery<T>>
Copyright © 2016. All Rights Reserved.