B C E G H I O P R S T W

B

baseURI - Variable in class org.apache.streams.riak.http.RiakHttpClient

C

cleanUp() - Method in class org.apache.streams.riak.binary.RiakBinaryPersistReader

cleanUp() - Method in class org.apache.streams.riak.binary.RiakBinaryPersistWriter

cleanUp() - Method in class org.apache.streams.riak.http.RiakHttpPersistReader

cleanUp() - Method in class org.apache.streams.riak.http.RiakHttpPersistWriter

client() - Method in class org.apache.streams.riak.binary.RiakBinaryClient

client - Variable in class org.apache.streams.riak.binary.RiakBinaryPersistReader

client - Variable in class org.apache.streams.riak.http.RiakHttpClient

client() - Method in class org.apache.streams.riak.http.RiakHttpClient

config - Variable in class org.apache.streams.riak.binary.RiakBinaryClient

config() - Method in class org.apache.streams.riak.binary.RiakBinaryClient

config - Variable in class org.apache.streams.riak.http.RiakHttpClient

config() - Method in class org.apache.streams.riak.http.RiakHttpClient

E

equals(Object) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

G

getAdditionalProperties() - Method in class org.apache.streams.riak.pojo.RiakConfiguration

getDefaultBucket() - Method in class org.apache.streams.riak.pojo.RiakConfiguration

getDefaultBucketType() - Method in class org.apache.streams.riak.pojo.RiakConfiguration

getDefaultCharset() - Method in class org.apache.streams.riak.pojo.RiakConfiguration

getDefaultContentType() - Method in class org.apache.streams.riak.pojo.RiakConfiguration

getHosts() - Method in class org.apache.streams.riak.pojo.RiakConfiguration

getId() - Method in class org.apache.streams.riak.binary.RiakBinaryPersistReader

getId() - Method in class org.apache.streams.riak.binary.RiakBinaryPersistWriter

getId() - Method in class org.apache.streams.riak.http.RiakHttpPersistReader

getId() - Method in class org.apache.streams.riak.http.RiakHttpPersistWriter

getInstance(RiakConfiguration) - Static method in class org.apache.streams.riak.binary.RiakBinaryClient

getInstance(RiakConfiguration) - Static method in class org.apache.streams.riak.http.RiakHttpClient

getPort() - Method in class org.apache.streams.riak.pojo.RiakConfiguration

getScheme() - Method in class org.apache.streams.riak.pojo.RiakConfiguration

H

hashCode() - Method in class org.apache.streams.riak.pojo.RiakConfiguration

I

isRunning() - Method in class org.apache.streams.riak.binary.RiakBinaryPersistReader

isRunning() - Method in class org.apache.streams.riak.http.RiakHttpPersistReader

O

org.apache.streams.riak.binary - package org.apache.streams.riak.binary

org.apache.streams.riak.http - package org.apache.streams.riak.http

org.apache.streams.riak.pojo - package org.apache.streams.riak.pojo

P

prepare(Object) - Method in class org.apache.streams.riak.binary.RiakBinaryPersistReader

prepare(Object) - Method in class org.apache.streams.riak.binary.RiakBinaryPersistWriter

prepare(Object) - Method in class org.apache.streams.riak.http.RiakHttpPersistReader

prepare(Object) - Method in class org.apache.streams.riak.http.RiakHttpPersistWriter

R

readAll() - Method in class org.apache.streams.riak.binary.RiakBinaryPersistReader

readAll() - Method in class org.apache.streams.riak.http.RiakHttpPersistReader

readCurrent() - Method in class org.apache.streams.riak.binary.RiakBinaryPersistReader

readCurrent() - Method in class org.apache.streams.riak.http.RiakHttpPersistReader

readNew(BigInteger) - Method in class org.apache.streams.riak.binary.RiakBinaryPersistReader

readNew(BigInteger) - Method in class org.apache.streams.riak.http.RiakHttpPersistReader

readRange(DateTime, DateTime) - Method in class org.apache.streams.riak.binary.RiakBinaryPersistReader

readRange(DateTime, DateTime) - Method in class org.apache.streams.riak.http.RiakHttpPersistReader

RiakBinaryClient - Class in org.apache.streams.riak.binary

RiakBinaryClient maintains shared connections to riak via binary protocol.

RiakBinaryPersistReader - Class in org.apache.streams.riak.binary

RiakBinaryPersistReader reads documents from riak via binary protocol.

RiakBinaryPersistReader(RiakConfiguration) - Constructor for class org.apache.streams.riak.binary.RiakBinaryPersistReader

RiakBinaryPersistWriter - Class in org.apache.streams.riak.binary

RiakBinaryPersistWriter writes documents to riak via binary protocol.

RiakBinaryPersistWriter(RiakConfiguration) - Constructor for class org.apache.streams.riak.binary.RiakBinaryPersistWriter

RiakConfiguration - Class in org.apache.streams.riak.pojo

RiakConfiguration() - Constructor for class org.apache.streams.riak.pojo.RiakConfiguration

RiakHttpClient - Class in org.apache.streams.riak.http

RiakHttpClient maintains shared connections to riak via http.

RiakHttpPersistReader - Class in org.apache.streams.riak.http

RiakHttpPersistReader reads documents from riak via http.

RiakHttpPersistReader(RiakConfiguration) - Constructor for class org.apache.streams.riak.http.RiakHttpPersistReader

RiakHttpPersistWriter - Class in org.apache.streams.riak.http

RiakHttpPersistWriter writes documents to riak via http.

RiakHttpPersistWriter(RiakConfiguration) - Constructor for class org.apache.streams.riak.http.RiakHttpPersistWriter

S

setAdditionalProperty(String, Object) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

setDefaultBucket(String) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

setDefaultBucketType(String) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

setDefaultCharset(String) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

setDefaultContentType(String) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

setHosts(List<String>) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

setPort(Long) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

setScheme(String) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

start() - Method in class org.apache.streams.riak.binary.RiakBinaryClient

start() - Method in class org.apache.streams.riak.http.RiakHttpClient

startStream() - Method in class org.apache.streams.riak.binary.RiakBinaryPersistReader

startStream() - Method in class org.apache.streams.riak.http.RiakHttpPersistReader

stop() - Method in class org.apache.streams.riak.binary.RiakBinaryClient

stop() - Method in class org.apache.streams.riak.http.RiakHttpClient

T

toString() - Method in class org.apache.streams.riak.pojo.RiakConfiguration

W

withAdditionalProperty(String, Object) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

withDefaultBucket(String) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

withDefaultBucketType(String) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

withDefaultCharset(String) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

withDefaultContentType(String) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

withHosts(List<String>) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

withPort(Long) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

withScheme(String) - Method in class org.apache.streams.riak.pojo.RiakConfiguration

write(StreamsDatum) - Method in class org.apache.streams.riak.binary.RiakBinaryPersistWriter

write(StreamsDatum) - Method in class org.apache.streams.riak.http.RiakHttpPersistWriter

B C E G H I O P R S T W