Modifier and Type | Method and Description |
---|---|
static <T> T |
CollectionUtils.firstOrDefault(Collection<? extends T> collection,
Function1<T,Boolean> predicate) |
Modifier and Type | Interface and Description |
---|---|
interface |
Predicate<T> |
Modifier and Type | Class and Description |
---|---|
static class |
Functions.AlwaysFalse<S> |
static class |
Functions.AlwaysTrue<S> |
static class |
Functions.StaticFunction1<S,T>
Function that takes 1 parameter and returns always the same value
|
static class |
Predicates.AndPredicate<T> |
static class |
Predicates.False<T> |
static class |
Predicates.True<T> |
Modifier and Type | Method and Description |
---|---|
static <T> Function1<T,Boolean> |
Functions.alwaysFalse() |
static <T> Function1<T,Boolean> |
Functions.alwaysTrue() |
static <X,Y> Function1<X,Y> |
Delegates.combine(Function1<X,Y> first,
Function1<X,Y> second) |
Modifier and Type | Method and Description |
---|---|
static <X,Y> Function1<X,Y> |
Delegates.combine(Function1<X,Y> first,
Function1<X,Y> second) |
static <X,Y> Function1<X,Y> |
Delegates.combine(Function1<X,Y> first,
Function1<X,Y> second) |
Modifier and Type | Method and Description |
---|---|
T |
AtomicDictionary.getOrAdd(String key,
Function1<String,T> valueGenerator) |
Modifier and Type | Method and Description |
---|---|
void |
IDocumentQueryBase.afterStreamExecuted(Function1<Reference<RavenJObject>,Boolean> afterStreamExecutedCallback)
Callback to get the results of the stream
|
Modifier and Type | Method and Description |
---|---|
<S> S |
ServerClient.executeWithReplication(HttpMethods method,
Function1<OperationMetadata,S> operation) |
<S> S |
IReplicationInformerBase.executeWithReplication(HttpMethods method,
String primaryUrl,
OperationCredentials primaryCredentials,
int currentRequest,
int currentReadStripingBase,
Function1<OperationMetadata,S> operation) |
<S> S |
ReplicationInformerBase.executeWithReplication(HttpMethods method,
String primaryUrl,
OperationCredentials primaryCredentials,
int currentRequest,
int currentReadStripingBase,
Function1<OperationMetadata,S> operation) |
protected <S> ReplicationInformerBase.OperationResult<S> |
ReplicationInformerBase.tryOperation(Function1<OperationMetadata,S> operation,
OperationMetadata operationMetadata,
OperationMetadata primaryOperationMetadata,
boolean avoidThrowing) |
static RavenJObjectIterator |
ServerClient.yieldStreamResults(org.apache.http.client.methods.CloseableHttpResponse webResponse,
int start,
int pageSize,
RavenPagingInformation pagingInformation,
Function1<org.codehaus.jackson.JsonParser,Boolean> customizedEndResult) |
Constructor and Description |
---|
Operation(Function1<Long,RavenJToken> statusFetcher,
long id) |
RavenJObjectIterator(org.apache.http.client.methods.CloseableHttpResponse response,
int start,
int pageSize,
RavenPagingInformation pagingInformation,
Function1<org.codehaus.jackson.JsonParser,Boolean> customizedEndResult) |
ServerClient(String url,
DocumentConvention convention,
OperationCredentials credentials,
HttpJsonRequestFactory httpJsonRequestFactory,
UUID sessionId,
Function1<String,IDocumentStoreReplicationInformer> replicationInformerGetter,
String databaseName,
IDocumentConflictListener[] conflictListeners,
boolean incrementReadStripe) |
Modifier and Type | Method and Description |
---|---|
T |
ConcurrentLruSet.firstOrDefault(Function1<T,Boolean> predicate) |
Modifier and Type | Class and Description |
---|---|
protected class |
DocumentStore.ReplicationInformerGetter |
Modifier and Type | Field and Description |
---|---|
protected Function1<Reference<RavenJObject>,Boolean> |
AbstractDocumentQuery.afterStreamExecutedCallback |
Modifier and Type | Method and Description |
---|---|
void |
AbstractDocumentQuery.afterStreamExecuted(Function1<Reference<RavenJObject>,Boolean> afterStreamExecutedCallback)
Callback to get the results of the stream
|
Constructor and Description |
---|
GenerateEntityIdOnTheClient(DocumentConvention conventions,
Function1<Object,String> generateKey) |
Modifier and Type | Interface and Description |
---|---|
interface |
ShardFieldForQueryingFunc |
Modifier and Type | Method and Description |
---|---|
<T,S> ShardStrategy |
ShardStrategy.shardingOn(com.mysema.query.types.Path<S> shardingProperty,
Function1<S,String> valueTranslator)
Instructs the sharding strategy to shard the T instances based on
the property specified in shardingProperty
|
<T,S> ShardStrategy |
ShardStrategy.shardingOn(com.mysema.query.types.Path<S> shardingProperty,
Function1<S,String> valueTranslator,
Function1<String,String> queryTranslator)
Instructs the sharding strategy to shard the T instances based on
the property specified in shardingProperty
|
<T,S> ShardStrategy |
ShardStrategy.shardingOn(com.mysema.query.types.Path<S> shardingProperty,
Function1<S,String> valueTranslator,
Function1<String,String> queryTranslator)
Instructs the sharding strategy to shard the T instances based on
the property specified in shardingProperty
|
<TResult> DefaultShardResolutionStrategy |
DefaultShardResolutionStrategy.shardingOn(com.mysema.query.types.Path<TResult> shardingProperty,
Function1<TResult,String> valueTranslator,
Function1<String,String> queryTranslator) |
<TResult> DefaultShardResolutionStrategy |
DefaultShardResolutionStrategy.shardingOn(com.mysema.query.types.Path<TResult> shardingProperty,
Function1<TResult,String> valueTranslator,
Function1<String,String> queryTranslator) |
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) |
Copyright © 2016. All Rights Reserved.