| Modifier and Type | Method and Description | 
|---|---|
BinaryValue | 
ChunkedResponseIterator.getContinuation()
Returns the current value of the continuation. 
 | 
| Constructor and Description | 
|---|
ChunkedResponseIterator(StreamingRiakFuture<ChunkT,?> coreFuture,
                       int pollTimeout,
                       Function<CoreT,FinalT> createNextFn,
                       Function<ChunkT,Iterator<CoreT>> getNextIteratorFn,
                       Function<ChunkT,BinaryValue> getContinuationFn)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected ListBuckets.Response | 
ListBuckets.convertResponse(FutureOperation<ListBucketsOperation.Response,?,BinaryValue> request,
               ListBucketsOperation.Response coreResponse)  | 
protected ListBuckets.Response | 
ListBuckets.createResponse(int timeout,
              StreamingRiakFuture<ListBucketsOperation.Response,BinaryValue> coreFuture)  | 
| Constructor and Description | 
|---|
Builder(BinaryValue type)
Construct a Builder for a ListBuckets command. 
 | 
Response(BinaryValue type,
        List<BinaryValue> buckets)  | 
| Constructor and Description | 
|---|
Response(BinaryValue type,
        List<BinaryValue> buckets)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected BinaryValue | 
UpdateDatatype.key  | 
| Modifier and Type | Method and Description | 
|---|---|
BinaryValue | 
RegisterUpdate.get()
Get the register contained in this update. 
 | 
BinaryValue | 
UpdateDatatype.Response.getGeneratedKey()
Get the returned generated key. 
 | 
BinaryValue | 
Context.getValue()
Returns the context as a BinaryValue. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Set<BinaryValue> | 
SetUpdate.getAdds()
Get the set of additions contained in this update. 
 | 
Set<BinaryValue> | 
HllUpdate.getElementAdds()
Get the set of element additions contained in this update. 
 | 
Set<BinaryValue> | 
SetUpdate.getRemoves()
Get the set of removes contained in this update. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
SetUpdate | 
SetUpdate.add(BinaryValue value)
Add the provided value to the set in Riak. 
 | 
HllUpdate | 
HllUpdate.addBinary(BinaryValue element)
Add the provided element to the HyperLogLog in Riak. 
 | 
SetUpdate | 
SetUpdate.remove(BinaryValue value)
Remove the provided value from the set in Riak. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
HllUpdate | 
HllUpdate.addAllBinary(Collection<BinaryValue> elements)
Add the provided elements to the HyperLogLog in Riak. 
 | 
| Constructor and Description | 
|---|
Context(BinaryValue value)
Construct a new Context. 
 | 
RegisterUpdate(BinaryValue value)
Construct a RegisterUpdate with the provided BinaryValue. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
protected BinaryValue | 
SecondaryIndexQuery.continuation  | 
| Modifier and Type | Method and Description | 
|---|---|
BinaryValue | 
SecondaryIndexQuery.IndexConverter.convert(T input)  | 
BinaryValue | 
SecondaryIndexQuery.getContinuation()
Get the continuation supplied for this query. 
 | 
BinaryValue | 
SecondaryIndexQuery.Response.getContinuation()
Get the continuation from this response. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected SecondaryIndexQuery.IndexConverter<BinaryValue> | 
RawIndexQuery.getConverter()  | 
| Modifier and Type | Method and Description | 
|---|---|
T | 
SecondaryIndexQuery.IndexConverter.convert(BinaryValue input)  | 
T | 
SecondaryIndexQuery.Init.withContinuation(BinaryValue continuation)
Set the continuation for this query. 
 | 
| Constructor and Description | 
|---|
Builder(Namespace namespace,
       BinaryValue start,
       BinaryValue end)  | 
Builder(Namespace namespace,
       String indexName,
       SecondaryIndexQuery.Type type,
       BinaryValue match)
Construct a Builder for a RawIndexQuery with a single 2i key. 
 | 
Builder(Namespace namespace,
       String indexName,
       SecondaryIndexQuery.Type type,
       BinaryValue start,
       BinaryValue end)
Construct a Builder for a RawIndexQuery with a range. 
 | 
Entry(Location riakObjectLocation,
     BinaryValue indexKey,
     SecondaryIndexQuery.IndexConverter<T> converter)  | 
| Constructor and Description | 
|---|
RawIndexQuery(SecondaryIndexQuery.Init<BinaryValue,?> builder)  | 
Response(Namespace queryLocation,
        SecondaryIndexQueryOperation.Response coreResponse,
        SecondaryIndexQuery.IndexConverter<BinaryValue> converter)  | 
| Modifier and Type | Method and Description | 
|---|---|
BinaryValue | 
StoreValue.Response.getGeneratedKey()  | 
| Modifier and Type | Method and Description | 
|---|---|
protected SecondaryIndexQuery.IndexConverter<BinaryValue> | 
FullBucketRead.getConverter()  | 
| Modifier and Type | Method and Description | 
|---|---|
FullBucketRead.Builder | 
FullBucketRead.Builder.withContinuation(BinaryValue continuation)
Set the continuation for this query. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected FullBucketRead.Response.Entry | 
FullBucketRead.Response.createEntry(Location location,
           SecondaryIndexQueryOperation.Response.Entry coreEntry,
           SecondaryIndexQuery.IndexConverter<BinaryValue> converter)  | 
| Constructor and Description | 
|---|
Response(Namespace namespace,
        List<BinaryValue> keys)  | 
Response(Namespace queryLocation,
        SecondaryIndexQuery.IndexConverter<BinaryValue> converter,
        int timeout,
        StreamingRiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query> coreFuture)  | 
Response(Namespace queryLocation,
        SecondaryIndexQueryOperation.Response coreResponse,
        SecondaryIndexQuery.IndexConverter<BinaryValue> converter)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
BinaryValueSerializer.serialize(BinaryValue binaryValue,
         com.fasterxml.jackson.core.JsonGenerator jg,
         com.fasterxml.jackson.databind.SerializerProvider serializerProvider)  | 
IndexMapReduce.Builder | 
IndexMapReduce.Builder.withMatchValue(BinaryValue value)
Set the query to a Match query on the builder. 
 | 
IndexMapReduce.Builder | 
IndexMapReduce.Builder.withRange(BinaryValue start,
         BinaryValue end)
Set the query to a Range query on the builder. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected MapReduce.Response | 
MapReduce.convertResponse(FutureOperation<MapReduceOperation.Response,?,BinaryValue> request,
               MapReduceOperation.Response coreResponse)  | 
protected MapReduce.Response | 
MapReduce.createResponse(int timeout,
              StreamingRiakFuture<MapReduceOperation.Response,BinaryValue> coreFuture)  | 
| Modifier and Type | Method and Description | 
|---|---|
BinaryValue | 
Converter.OrmExtracted.getKey()  | 
| Modifier and Type | Method and Description | 
|---|---|
Converter.OrmExtracted | 
PassThroughConverter.fromDomain(RiakObject domainObject,
          Namespace namespace,
          BinaryValue key)  | 
Converter.OrmExtracted | 
StringConverter.fromDomain(String domainObject,
          Namespace namespace,
          BinaryValue key)  | 
Converter.OrmExtracted | 
Converter.fromDomain(T domainObject,
          Namespace namespace,
          BinaryValue key)
Convert from a domain object to a RiakObject. 
 | 
String | 
StringConverter.toDomain(BinaryValue value,
        String contentType)  | 
RiakObject | 
PassThroughConverter.toDomain(BinaryValue value,
        String contentType)  | 
T | 
JSONConverter.toDomain(BinaryValue value,
        String contentType)  | 
abstract T | 
Converter.toDomain(BinaryValue value,
        String contentType)
Convert the value portion of a RiakObject to a domain object. 
 | 
| Constructor and Description | 
|---|
ContentAndType(BinaryValue content,
              String contentType)  | 
OrmExtracted(RiakObject riakObject,
            Namespace namespace,
            BinaryValue key)  | 
| Modifier and Type | Method and Description | 
|---|---|
static <T> BinaryValue | 
AnnotationUtil.getBucketName(T domainObject)  | 
static <T> BinaryValue | 
AnnotationUtil.getBucketName(T domainObject,
             BinaryValue defaultBucketName)  | 
static <T> BinaryValue | 
AnnotationUtil.getBucketType(T domainObject)  | 
static <T> BinaryValue | 
AnnotationUtil.getBucketType(T domainObject,
             BinaryValue defaultBucketType)  | 
static <T> BinaryValue | 
AnnotationUtil.getKey(T domainObject)
Attempts to get a key from  
domainObject by looking for a
 @RiakKey annotated member. | 
static <T> BinaryValue | 
AnnotationUtil.getKey(T domainObject,
      BinaryValue defaultKey)
Attempts to get a key from  
domainObject by looking for a
 @RiakKey annotated member. | 
<T> BinaryValue | 
AnnotationInfo.getRiakBucketName(T obj)  | 
<T> BinaryValue | 
AnnotationHelper.getRiakBucketName(T obj)  | 
<T> BinaryValue | 
AnnotationInfo.getRiakBucketType(T obj)  | 
<T> BinaryValue | 
AnnotationHelper.getRiakBucketType(T obj)  | 
<T> BinaryValue | 
AnnotationInfo.getRiakKey(T obj)
Returns the key. 
 | 
<T> BinaryValue | 
AnnotationHelper.getRiakKey(T obj)  | 
| Modifier and Type | Method and Description | 
|---|---|
static <T> BinaryValue | 
AnnotationUtil.getBucketName(T domainObject,
             BinaryValue defaultBucketName)  | 
static <T> BinaryValue | 
AnnotationUtil.getBucketType(T domainObject,
             BinaryValue defaultBucketType)  | 
static <T> BinaryValue | 
AnnotationUtil.getKey(T domainObject,
      BinaryValue defaultKey)
Attempts to get a key from  
domainObject by looking for a
 @RiakKey annotated member. | 
static <T> T | 
AnnotationUtil.setBucketName(T domainObject,
             BinaryValue bucketName)  | 
static <T> T | 
AnnotationUtil.setBucketType(T domainObject,
             BinaryValue bucketType)  | 
static <T> T | 
AnnotationUtil.setKey(T domainObject,
      BinaryValue key)
Attempts to inject  
key as the value of the @RiakKey
 annotated member of domainObject | 
<T> void | 
AnnotationInfo.setRiakBucketName(T obj,
                 BinaryValue bucketName)  | 
<T> T | 
AnnotationHelper.setRiakBucketName(T obj,
                 BinaryValue bucketName)  | 
<T> void | 
AnnotationInfo.setRiakBucketType(T obj,
                 BinaryValue bucketType)  | 
<T> T | 
AnnotationHelper.setRiakBucketType(T obj,
                 BinaryValue bucketType)  | 
<T> void | 
AnnotationInfo.setRiakKey(T obj,
          BinaryValue key)  | 
<T> T | 
AnnotationHelper.setRiakKey(T obj,
          BinaryValue key)  | 
| Constructor and Description | 
|---|
StoreValueHealthCheck(Location location,
                     BinaryValue value)  | 
| Modifier and Type | Method and Description | 
|---|---|
BinaryValue | 
ListBucketsOperation.Response.getBucketType()  | 
BinaryValue | 
DtFetchOperation.Response.getContext()  | 
BinaryValue | 
SecondaryIndexQueryOperation.Query.getContinuation()  | 
BinaryValue | 
SecondaryIndexQueryOperation.Response.getContinuation()  | 
BinaryValue | 
StoreOperation.Response.getGeneratedKey()  | 
BinaryValue | 
DtUpdateOperation.Response.getGeneratedKey()  | 
BinaryValue | 
SecondaryIndexQueryOperation.Query.getIndexKey()  | 
BinaryValue | 
SecondaryIndexQueryOperation.Response.Entry.getIndexKey()  | 
BinaryValue | 
SecondaryIndexQueryOperation.Query.getIndexName()  | 
BinaryValue | 
SecondaryIndexQueryOperation.Response.Entry.getObjectKey()  | 
BinaryValue | 
SearchOperation.getQueryInfo()  | 
BinaryValue | 
MapReduceOperation.getQueryInfo()  | 
BinaryValue | 
ListBucketsOperation.getQueryInfo()  | 
BinaryValue | 
SecondaryIndexQueryOperation.Query.getRangeEnd()  | 
BinaryValue | 
SecondaryIndexQueryOperation.Query.getRangeStart()  | 
BinaryValue | 
SecondaryIndexQueryOperation.Query.getTermFilter()  | 
| Modifier and Type | Method and Description | 
|---|---|
List<BinaryValue> | 
ListBucketsOperation.Response.getBuckets()  | 
List<BinaryValue> | 
ListKeysOperation.Response.getKeys()  | 
Iterator<BinaryValue> | 
ListKeysOperation.Response.iterator()  | 
Iterator<BinaryValue> | 
ListBucketsOperation.Response.iterator()  | 
| Modifier and Type | Method and Description | 
|---|---|
ListBucketsOperation.Builder | 
ListBucketsOperation.Builder.withBucketType(BinaryValue bucketType)
Set the bucket type. 
 | 
DtUpdateOperation.Builder | 
DtUpdateOperation.Builder.withContext(BinaryValue ctx)
Set the context for this operation. 
 | 
SecondaryIndexQueryOperation.Query.Builder | 
SecondaryIndexQueryOperation.Query.Builder.withContinuation(BinaryValue continuation)
Set the continuation for this query. 
 | 
SecondaryIndexQueryOperation.Query.Builder | 
SecondaryIndexQueryOperation.Query.Builder.withIndexKey(BinaryValue key)
Set a single secondary index key to use for query. 
 | 
SecondaryIndexQueryOperation.Query.Builder | 
SecondaryIndexQueryOperation.Query.Builder.withRangeEnd(BinaryValue endIndex)
Set the ending value for a range query. 
 | 
SecondaryIndexQueryOperation.Query.Builder | 
SecondaryIndexQueryOperation.Query.Builder.withRangeStart(BinaryValue startingIndex)
Set the start value for a range query. 
 | 
SecondaryIndexQueryOperation.Query.Builder | 
SecondaryIndexQueryOperation.Query.Builder.withRegexTermFilter(BinaryValue filter)
Set the regex to filter result terms by for this query. 
 | 
| Constructor and Description | 
|---|
Builder(BinaryValue mapReduce)
Create a MapReduce operation builder with the given function. 
 | 
Builder(BinaryValue indexName,
       String queryString)  | 
Builder(Namespace namespace,
       BinaryValue indexName)
Constructs a builder for a (2i) Query. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
BinaryValue | 
Namespace.getBucketName()
Returns the bucket name for this Namespace. 
 | 
BinaryValue | 
Namespace.getBucketType()
Returns the bucket type for this Namespace. 
 | 
BinaryValue | 
Location.getKey()
Returns the key for this location. 
 | 
BinaryValue | 
RiakObject.getValue()
Returns the value of this RiakObject. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
RiakObject | 
RiakObject.setValue(BinaryValue value)
Set the value for this RiakObject 
 | 
| Constructor and Description | 
|---|
Location(Namespace namespace,
        BinaryValue key)
Construct a new Location with the provided Namespace and key. 
 | 
Namespace(BinaryValue bucketName)
Construct a new Namespace with the provided bucket name and the default bucket type. 
 | 
Namespace(BinaryValue bucketType,
         BinaryValue bucketName)
Construct a new Namespace with the provided bucket type and name. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
BinaryValue | 
MapOp.MapField.key  | 
| Modifier and Type | Method and Description | 
|---|---|
BinaryValue | 
RegisterOp.getValue()  | 
| Modifier and Type | Method and Description | 
|---|---|
Set<BinaryValue> | 
SetOp.getAdds()  | 
Set<BinaryValue> | 
HllOp.getElements()  | 
Set<BinaryValue> | 
SetOp.getRemoves()  | 
| Modifier and Type | Method and Description | 
|---|---|
SetOp | 
SetOp.add(BinaryValue element)  | 
HllOp | 
HllOp.add(BinaryValue element)  | 
SetOp | 
SetOp.remove(BinaryValue element)  | 
MapOp | 
MapOp.remove(BinaryValue key,
      MapOp.FieldType type)  | 
MapOp | 
MapOp.update(BinaryValue key,
      CounterOp op)  | 
MapOp | 
MapOp.update(BinaryValue key,
      FlagOp op)  | 
MapOp | 
MapOp.update(BinaryValue key,
      MapOp op)  | 
MapOp | 
MapOp.update(BinaryValue key,
      RegisterOp op)  | 
MapOp | 
MapOp.update(BinaryValue key,
      SetOp op)  | 
| Modifier and Type | Method and Description | 
|---|---|
HllOp | 
HllOp.addAll(Collection<BinaryValue> elements)  | 
| Constructor and Description | 
|---|
MapField(MapOp.FieldType type,
        BinaryValue key)  | 
RegisterOp(BinaryValue value)  | 
| Constructor and Description | 
|---|
HllOp(Collection<BinaryValue> elements)  | 
SetOp(Set<BinaryValue> adds,
     Set<BinaryValue> removes)  | 
SetOp(Set<BinaryValue> adds,
     Set<BinaryValue> removes)  | 
| Modifier and Type | Method and Description | 
|---|---|
BinaryValue | 
RiakMap.MapEntry.getField()  | 
BinaryValue | 
RiakRegister.getValue()
Returns the RiakRegister as a BinaryValue. 
 | 
BinaryValue | 
RiakRegister.view()
Returns the RiakRegister as a BinaryValue. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Set<BinaryValue> | 
RiakSet.view()
Get this set as a  
Set. | 
Map<BinaryValue,List<RiakDatatype>> | 
RiakMap.view()
Get this RiakMap as a  
Map. | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
RiakSet.contains(BinaryValue element)
Check to see if the supplied value exists in this RiakSet. 
 | 
List<RiakDatatype> | 
RiakMap.get(BinaryValue key)
Returns the value(s) to which the specified key is mapped, or null
 if the map contains no mapping for the key. 
 | 
RiakCounter | 
RiakMap.getCounter(BinaryValue key)
Returns a RiakCounter to which the specified key is mapped, or null
 if no RiakCounter is present. 
 | 
RiakFlag | 
RiakMap.getFlag(BinaryValue key)
Returns a RiakFlag to which the specified key is mapped, or null
 if no RiakFlag is present. 
 | 
RiakMap | 
RiakMap.getMap(BinaryValue key)
Returns a RiakMap to which the specified key is mapped, or null
 if no RiakMap is present. 
 | 
RiakRegister | 
RiakMap.getRegister(BinaryValue key)
Returns a RiakRegister to which the specified key is mapped, or null
 if no RiakRegister is present. 
 | 
RiakSet | 
RiakMap.getSet(BinaryValue key)
Returns a RiakSet to which the specified key is mapped, or null
 if no RiakSet is present. 
 | 
| Constructor and Description | 
|---|
MapEntry(BinaryValue field,
        RiakDatatype element)  | 
RiakRegister(BinaryValue value)  | 
| Constructor and Description | 
|---|
RiakSet(List<BinaryValue> elements)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected BinaryValue | 
BigIntIndex.convert(BigInteger value)  | 
protected BinaryValue | 
RawIndex.convert(BinaryValue value)  | 
protected BinaryValue | 
LongIntIndex.convert(Long value)  | 
protected BinaryValue | 
StringBinIndex.convert(String value)  | 
protected abstract BinaryValue | 
RiakIndex.convert(T value)
Convert a value to a BinaryValue. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Set<BinaryValue> | 
RiakIndex.rawValues()
Return the values in this index as raw bytes. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected String | 
StringBinIndex.convert(BinaryValue value)  | 
protected abstract T | 
RiakIndex.convert(BinaryValue value)
Convert bytes to a value type. 
 | 
protected BinaryValue | 
RawIndex.convert(BinaryValue value)  | 
protected Long | 
LongIntIndex.convert(BinaryValue value)  | 
protected BigInteger | 
BigIntIndex.convert(BinaryValue value)  | 
| Modifier and Type | Method and Description | 
|---|---|
BinaryValue | 
RiakLink.getBucketAsBytes()
Get the bucket as a wrapped byte array 
 | 
BinaryValue | 
RiakLink.getKeyAsBytes()
Return the key as a wrapped byte array 
 | 
BinaryValue | 
RiakLink.getTagAsBytes()
Get the tag as bytes 
 | 
| Constructor and Description | 
|---|
RiakLink(BinaryValue bucket,
        BinaryValue key,
        BinaryValue tag)
Create a RiakLink from the specified parameters. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
BinaryValue | 
Cell.getVarcharValue()  | 
| Constructor and Description | 
|---|
Cell(BinaryValue varcharValue)
Creates a new "Varchar" cell from the provided BinaryValue. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
BinaryValue | 
RiakUserMetadata.get(BinaryValue key)
Get a user metadata entry. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Set<Map.Entry<BinaryValue,BinaryValue>> | 
RiakUserMetadata.getUserMetadata()
Get the user metadata entries 
 | 
Set<Map.Entry<BinaryValue,BinaryValue>> | 
RiakUserMetadata.getUserMetadata()
Get the user metadata entries 
 | 
| Modifier and Type | Method and Description | 
|---|---|
BinaryValue | 
RiakUserMetadata.get(BinaryValue key)
Get a user metadata entry. 
 | 
void | 
RiakUserMetadata.put(BinaryValue key,
   BinaryValue value)
Set a user metadata entry using raw bytes. 
 | 
void | 
RiakUserMetadata.remove(BinaryValue key)  | 
| Modifier and Type | Method and Description | 
|---|---|
static BinaryValue | 
BinaryValue.create(byte[] data)
Create a BinaryValue containing a copy of the supplied  
byte[] | 
static BinaryValue | 
BinaryValue.create(String data)
Create a BinaryValue containing a copy of the supplied String
 encoded using the default character asSet. 
 | 
static BinaryValue | 
BinaryValue.create(String data,
      Charset charset)
Create a BinaryValue containing a copy of the supplied string
 encoded using the supplied Charset. 
 | 
static BinaryValue | 
BinaryValue.createFromUtf8(String data)
Create a BinaryValue containing a copy of the supplied String
 encoded using UTF-8. 
 | 
static BinaryValue | 
BinaryValue.unsafeCreate(byte[] data)
Create a BinaryValue containing the supplied  
byte[] | 
Copyright © 2016. All rights reserved.