com.basho.riak.client.core.codec

Class TermToBinaryCodec

java.lang.Object

com.basho.riak.client.core.codec.TermToBinaryCodec

public class TermToBinaryCodec
extends Object

Constructor Summary

Constructors

Constructor and Description
TermToBinaryCodec()

Method Summary

Modifier and Type	Method and Description
static QueryResult	decodeTsResultResponse(byte[] response)
static com.ericsson.otp.erlang.OtpOutputStream	encodeTsGetRequest(String tableName, Collection<Cell> keyValues, int timeout)
static com.ericsson.otp.erlang.OtpOutputStream	encodeTsPutRequest(String tableName, Collection<Row> rows)
static com.ericsson.otp.erlang.OtpOutputStream	encodeTsPutRequest(String tableName, Collection<String> columns, Collection<Row> rows)
static com.ericsson.otp.erlang.OtpOutputStream	encodeTsQueryRequest(String queryText, byte[] coverageContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TermToBinaryCodec

public TermToBinaryCodec()

Method Detail

encodeTsGetRequest

public static com.ericsson.otp.erlang.OtpOutputStream encodeTsGetRequest(String tableName,
                                                                         Collection<Cell> keyValues,
                                                                         int timeout)

decodeTsResultResponse

public static QueryResult decodeTsResultResponse(byte[] response)
                                          throws com.ericsson.otp.erlang.OtpErlangDecodeException,
                                                 InvalidTermToBinaryException

Throws:

com.ericsson.otp.erlang.OtpErlangDecodeException

InvalidTermToBinaryException

encodeTsQueryRequest

public static com.ericsson.otp.erlang.OtpOutputStream encodeTsQueryRequest(String queryText,
                                                                           byte[] coverageContext)

encodeTsPutRequest

public static com.ericsson.otp.erlang.OtpOutputStream encodeTsPutRequest(String tableName,
                                                                         Collection<Row> rows)

encodeTsPutRequest

public static com.ericsson.otp.erlang.OtpOutputStream encodeTsPutRequest(String tableName,
                                                                         Collection<String> columns,
                                                                         Collection<Row> rows)