Package | Description |
---|---|
com.datastax.driver.core |
The main package for the DataStax Java driver for Cassandra.
|
com.datastax.driver.core.exceptions |
Exceptions thrown by the DataStax Java driver for Cassandra.
|
com.datastax.driver.core.querybuilder |
A CQL3 query builder.
|
Modifier and Type | Field and Description |
---|---|
static ProtocolVersion |
ProtocolVersion.NEWEST_SUPPORTED
The most recent protocol version supported by the driver.
|
Modifier and Type | Method and Description |
---|---|
static ProtocolVersion |
ProtocolVersion.fromInt(int i)
Returns the value matching an integer version.
|
ProtocolVersion |
ProtocolOptions.getProtocolVersion()
The protocol version used by the Cluster instance.
|
static ProtocolVersion |
ProtocolVersion.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ProtocolVersion[] |
ProtocolVersion.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static ByteBuffer[] |
CodecUtils.convert(Object[] values,
ProtocolVersion protocolVersion,
CodecRegistry codecRegistry)
Utility method to serialize user-provided values.
|
abstract T |
TypeCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion)
Deserialize the given
ByteBuffer instance according to the CQL type
handled by this codec. |
String |
TypeCodec.StringCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion)
Deserialize the given
ByteBuffer instance according to the CQL type
handled by this codec. |
Long |
TypeCodec.LongCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.BlobCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.CustomCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
Boolean |
TypeCodec.BooleanCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
BigDecimal |
TypeCodec.DecimalCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
Double |
TypeCodec.DoubleCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
Float |
TypeCodec.FloatCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
InetAddress |
TypeCodec.InetCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
Byte |
TypeCodec.TinyIntCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
Short |
TypeCodec.SmallIntCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
Integer |
TypeCodec.IntCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
Date |
TypeCodec.TimestampCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
LocalDate |
TypeCodec.DateCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
UUID |
TypeCodec.AbstractUUIDCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
BigInteger |
TypeCodec.VarintCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
C |
TypeCodec.CollectionCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
Map<K,V> |
TypeCodec.MapCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
UDTValue |
TypeCodec.UDTCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
TupleValue |
TypeCodec.TupleCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
T |
TypeCodec.StringParsingCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
T |
TypeCodec.MappingCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
E |
TypeCodec.EnumIntCodec.deserialize(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
boolean |
TypeCodec.PrimitiveBooleanCodec.deserializeNoBoxing(ByteBuffer v,
ProtocolVersion protocolVersion) |
byte |
TypeCodec.PrimitiveByteCodec.deserializeNoBoxing(ByteBuffer v,
ProtocolVersion protocolVersion) |
short |
TypeCodec.PrimitiveShortCodec.deserializeNoBoxing(ByteBuffer v,
ProtocolVersion protocolVersion) |
int |
TypeCodec.PrimitiveIntCodec.deserializeNoBoxing(ByteBuffer v,
ProtocolVersion protocolVersion) |
long |
TypeCodec.PrimitiveLongCodec.deserializeNoBoxing(ByteBuffer v,
ProtocolVersion protocolVersion) |
float |
TypeCodec.PrimitiveFloatCodec.deserializeNoBoxing(ByteBuffer v,
ProtocolVersion protocolVersion) |
double |
TypeCodec.PrimitiveDoubleCodec.deserializeNoBoxing(ByteBuffer v,
ProtocolVersion protocolVersion) |
long |
TypeCodec.LongCodec.deserializeNoBoxing(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
boolean |
TypeCodec.BooleanCodec.deserializeNoBoxing(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
double |
TypeCodec.DoubleCodec.deserializeNoBoxing(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
float |
TypeCodec.FloatCodec.deserializeNoBoxing(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
byte |
TypeCodec.TinyIntCodec.deserializeNoBoxing(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
short |
TypeCodec.SmallIntCodec.deserializeNoBoxing(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
int |
TypeCodec.IntCodec.deserializeNoBoxing(ByteBuffer bytes,
ProtocolVersion protocolVersion) |
static TupleType |
TupleType.of(ProtocolVersion protocolVersion,
CodecRegistry codecRegistry,
DataType... types)
Creates a "disconnected" tuple type (you should prefer
cluster.getMetadata().newTupleType(...)
whenever possible). |
static ByteBuffer |
CodecUtils.pack(List<ByteBuffer> buffers,
int elements,
ProtocolVersion version)
Utility method that "packs" together a list of
ByteBuffer s containing
serialized collection elements. |
static int |
CodecUtils.readCollectionSize(ByteBuffer input,
ProtocolVersion version)
Utility method that reads the collection size.
|
static ByteBuffer |
CodecUtils.readCollectionValue(ByteBuffer input,
ProtocolVersion version) |
ByteBuffer |
TypeCodec.DecimalCodec.serialize(BigDecimal value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.VarintCodec.serialize(BigInteger value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.BooleanCodec.serialize(Boolean value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.BlobCodec.serialize(ByteBuffer value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.CustomCodec.serialize(ByteBuffer value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.TinyIntCodec.serialize(Byte value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.CollectionCodec.serialize(C value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.TimestampCodec.serialize(Date value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.DoubleCodec.serialize(Double value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.EnumIntCodec.serialize(E value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.FloatCodec.serialize(Float value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.InetCodec.serialize(InetAddress value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.IntCodec.serialize(Integer value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.DateCodec.serialize(LocalDate value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.LongCodec.serialize(Long value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.MapCodec.serialize(Map<K,V> value,
ProtocolVersion protocolVersion) |
abstract ByteBuffer |
Token.serialize(ProtocolVersion protocolVersion)
Returns the serialized form of the current token,
using the appropriate codec depending on the
partitioner in use and the CQL datatype for
the token.
|
ByteBuffer |
TypeCodec.SmallIntCodec.serialize(Short value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.StringCodec.serialize(String value,
ProtocolVersion protocolVersion) |
abstract ByteBuffer |
TypeCodec.serialize(T value,
ProtocolVersion protocolVersion)
Serialize the given value according to the CQL type
handled by this codec.
|
ByteBuffer |
TypeCodec.StringParsingCodec.serialize(T value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.MappingCodec.serialize(T value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.TupleCodec.serialize(TupleValue value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.UDTCodec.serialize(UDTValue value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.AbstractUUIDCodec.serialize(UUID value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.TimeUUIDCodec.serialize(UUID value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.PrimitiveBooleanCodec.serializeNoBoxing(boolean v,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.BooleanCodec.serializeNoBoxing(boolean value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.PrimitiveByteCodec.serializeNoBoxing(byte v,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.TinyIntCodec.serializeNoBoxing(byte value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.PrimitiveDoubleCodec.serializeNoBoxing(double v,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.DoubleCodec.serializeNoBoxing(double value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.PrimitiveFloatCodec.serializeNoBoxing(float v,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.FloatCodec.serializeNoBoxing(float value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.PrimitiveIntCodec.serializeNoBoxing(int v,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.IntCodec.serializeNoBoxing(int value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.PrimitiveLongCodec.serializeNoBoxing(long v,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.LongCodec.serializeNoBoxing(long value,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.PrimitiveShortCodec.serializeNoBoxing(short v,
ProtocolVersion protocolVersion) |
ByteBuffer |
TypeCodec.SmallIntCodec.serializeNoBoxing(short value,
ProtocolVersion protocolVersion) |
Cluster.Builder |
Cluster.Builder.withProtocolVersion(ProtocolVersion version)
The native protocol version to use.
|
Constructor and Description |
---|
AbstractGettableData(ProtocolVersion protocolVersion)
Creates a new AbstractGettableData object.
|
ProtocolOptions(int port,
ProtocolVersion protocolVersion,
int maxSchemaAgreementWaitSeconds,
SSLOptions sslOptions,
AuthProvider authProvider)
Creates a new
ProtocolOptions instance using the provided port
and SSL context. |
Constructor and Description |
---|
UnsupportedFeatureException(ProtocolVersion currentVersion,
String msg) |
Constructor and Description |
---|
QueryBuilder(ProtocolVersion protocolVersion,
CodecRegistry codecRegistry)
Create a "disconnected" QueryBuilder instance (you should prefer
QueryBuilder.QueryBuilder(Cluster) whenever possible). |
Copyright © 2012–2015. All rights reserved.