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.