Uses of Class
org.apache.cassandra.transport.ProtocolVersion
-
Packages that use ProtocolVersion Package Description org.apache.cassandra.cql3 org.apache.cassandra.cql3.functions org.apache.cassandra.cql3.functions.types Contains pieces of the Java Driver that are needed to handle data types in C* User-Defined-Functions/Aggregates.org.apache.cassandra.cql3.selection org.apache.cassandra.db org.apache.cassandra.db.marshal org.apache.cassandra.serializers org.apache.cassandra.service.pager org.apache.cassandra.transport org.apache.cassandra.transport.messages -
-
Uses of ProtocolVersion in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 that return ProtocolVersion Modifier and Type Method Description abstract ProtocolVersion
QueryOptions. getProtocolVersion()
The protocol version for the query.Methods in org.apache.cassandra.cql3 with parameters of type ProtocolVersion Modifier and Type Method Description static QueryOptions
QueryOptions. create(ConsistencyLevel consistency, java.util.List<java.nio.ByteBuffer> values, boolean skipMetadata, int pageSize, PagingState pagingState, ConsistencyLevel serialConsistency, ProtocolVersion version, java.lang.String keyspace)
static QueryOptions
QueryOptions. create(ConsistencyLevel consistency, java.util.List<java.nio.ByteBuffer> values, boolean skipMetadata, int pageSize, PagingState pagingState, ConsistencyLevel serialConsistency, ProtocolVersion version, java.lang.String keyspace, long timestamp, int nowInSeconds)
ResultSet
ResultSet.Codec. decode(io.netty.buffer.ByteBuf body, ProtocolVersion version)
void
ResultSet.Codec. encode(ResultSet rs, io.netty.buffer.ByteBuf dest, ProtocolVersion version)
int
ResultSet.Codec. encodedSize(ResultSet rs, ProtocolVersion version)
static QueryOptions
QueryOptions. forProtocolVersion(ProtocolVersion protocolVersion)
static Lists.Value
Lists.Value. fromSerialized(java.nio.ByteBuffer value, ListType type, ProtocolVersion version)
static Maps.Value
Maps.Value. fromSerialized(java.nio.ByteBuffer value, MapType type, ProtocolVersion version)
static Sets.Value
Sets.Value. fromSerialized(java.nio.ByteBuffer value, SetType type, ProtocolVersion version)
java.nio.ByteBuffer
Constants.Value. get(ProtocolVersion protocolVersion)
java.nio.ByteBuffer
Lists.Value. get(ProtocolVersion protocolVersion)
java.nio.ByteBuffer
Maps.Value. get(ProtocolVersion protocolVersion)
java.nio.ByteBuffer
Sets.Value. get(ProtocolVersion protocolVersion)
abstract java.nio.ByteBuffer
Term.Terminal. get(ProtocolVersion protocolVersion)
java.nio.ByteBuffer
Tuples.InValue. get(ProtocolVersion protocolVersion)
java.nio.ByteBuffer
Tuples.Value. get(ProtocolVersion protocolVersion)
java.nio.ByteBuffer
UserTypes.Value. get(ProtocolVersion protocolVersion)
java.lang.String
CQL3Type.Collection. toCQLLiteral(java.nio.ByteBuffer buffer, ProtocolVersion version)
java.lang.String
CQL3Type.Custom. toCQLLiteral(java.nio.ByteBuffer buffer, ProtocolVersion version)
java.lang.String
CQL3Type.Native. toCQLLiteral(java.nio.ByteBuffer buffer, ProtocolVersion version)
Delegate toTypeSerializer.toCQLLiteral(ByteBuffer)
for native types as most CQL literal representations work fine with the defaultTypeSerializer.toString(Object)
TypeSerializer.deserialize(ByteBuffer)
implementations.java.lang.String
CQL3Type. toCQLLiteral(java.nio.ByteBuffer bytes, ProtocolVersion version)
Generates CQL literal from a binary value of this type.java.lang.String
CQL3Type.Tuple. toCQLLiteral(java.nio.ByteBuffer buffer, ProtocolVersion version)
java.lang.String
CQL3Type.UserDefined. toCQLLiteral(java.nio.ByteBuffer buffer, ProtocolVersion version)
-
Uses of ProtocolVersion in org.apache.cassandra.cql3.functions
Methods in org.apache.cassandra.cql3.functions with parameters of type ProtocolVersion Modifier and Type Method Description void
AggregateFunction.Aggregate. addInput(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> values)
Adds the specified input to this aggregate.protected java.lang.Object
JavaUDF. compose(ProtocolVersion protocolVersion, int argIndex, java.nio.ByteBuffer value)
protected static java.lang.Object
UDFunction. compose(TypeCodec<java.lang.Object>[] codecs, ProtocolVersion protocolVersion, int argIndex, java.nio.ByteBuffer value)
protected java.lang.Object
UDFunction. compose(ProtocolVersion protocolVersion, int argIndex, java.nio.ByteBuffer value)
Used by UDF implementations (both Java code generated byJavaBasedUDFunction
and script executorScriptBasedUDFunction
) to convert the C* serialized representation to the Java object representation.protected boolean
JavaUDF. compose_boolean(ProtocolVersion protocolVersion, int argIndex, java.nio.ByteBuffer value)
protected byte
JavaUDF. compose_byte(ProtocolVersion protocolVersion, int argIndex, java.nio.ByteBuffer value)
protected double
JavaUDF. compose_double(ProtocolVersion protocolVersion, int argIndex, java.nio.ByteBuffer value)
protected float
JavaUDF. compose_float(ProtocolVersion protocolVersion, int argIndex, java.nio.ByteBuffer value)
protected int
JavaUDF. compose_int(ProtocolVersion protocolVersion, int argIndex, java.nio.ByteBuffer value)
protected long
JavaUDF. compose_long(ProtocolVersion protocolVersion, int argIndex, java.nio.ByteBuffer value)
protected short
JavaUDF. compose_short(ProtocolVersion protocolVersion, int argIndex, java.nio.ByteBuffer value)
java.nio.ByteBuffer
AggregateFunction.Aggregate. compute(ProtocolVersion protocolVersion)
Computes and returns the aggregate current value.protected java.nio.ByteBuffer
JavaUDF. decompose(ProtocolVersion protocolVersion, java.lang.Object value)
protected static java.nio.ByteBuffer
UDFunction. decompose(TypeCodec<java.lang.Object> codec, ProtocolVersion protocolVersion, java.lang.Object value)
protected java.nio.ByteBuffer
UDFunction. decompose(ProtocolVersion protocolVersion, java.lang.Object value)
Used by UDF implementations (both Java code generated byJavaBasedUDFunction
and script executorScriptBasedUDFunction
) to convert the Java object representation for the return value to the C* serialized representation.static java.lang.Object
UDHelper. deserialize(TypeCodec<?> codec, ProtocolVersion protocolVersion, java.nio.ByteBuffer value)
java.nio.ByteBuffer
FromJsonFct. execute(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> parameters)
java.nio.ByteBuffer
ScalarFunction. execute(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> parameters)
Applies this function to the specified parameter.java.nio.ByteBuffer
ToJsonFct. execute(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> parameters)
java.nio.ByteBuffer
TokenFct. execute(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> parameters)
java.nio.ByteBuffer
UDFunction. execute(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> parameters)
protected abstract java.lang.Object
JavaUDF. executeAggregateImpl(ProtocolVersion protocolVersion, java.lang.Object firstParam, java.util.List<java.nio.ByteBuffer> params)
protected java.lang.Object
JavaBasedUDFunction. executeAggregateUserDefined(ProtocolVersion protocolVersion, java.lang.Object firstParam, java.util.List<java.nio.ByteBuffer> params)
protected abstract java.lang.Object
UDFunction. executeAggregateUserDefined(ProtocolVersion protocolVersion, java.lang.Object firstParam, java.util.List<java.nio.ByteBuffer> parameters)
java.lang.Object
UDFunction. executeForAggregate(ProtocolVersion protocolVersion, java.lang.Object firstParam, java.util.List<java.nio.ByteBuffer> parameters)
LikeScalarFunction.execute(ProtocolVersion, List)
but the first parameter is already in non-serialized form.protected abstract java.nio.ByteBuffer
JavaUDF. executeImpl(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> params)
protected java.nio.ByteBuffer
JavaBasedUDFunction. executeUserDefined(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> params)
protected abstract java.nio.ByteBuffer
UDFunction. executeUserDefined(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> parameters)
static java.nio.ByteBuffer
UDHelper. serialize(TypeCodec<?> codec, ProtocolVersion protocolVersion, java.lang.Object value)
-
Uses of ProtocolVersion in org.apache.cassandra.cql3.functions.types
Fields in org.apache.cassandra.cql3.functions.types declared as ProtocolVersion Modifier and Type Field Description protected ProtocolVersion
AbstractGettableByIndexData. protocolVersion
protected ProtocolVersion
AbstractGettableByIndexData. protocolVersion
protected ProtocolVersion
AbstractGettableByIndexData. protocolVersion
Methods in org.apache.cassandra.cql3.functions.types with parameters of type ProtocolVersion Modifier and Type Method Description C
TypeCodec.AbstractCollectionCodec. deserialize(java.nio.ByteBuffer bytes, ProtocolVersion protocolVersion)
java.util.Map<K,V>
TypeCodec.AbstractMapCodec. deserialize(java.nio.ByteBuffer bytes, ProtocolVersion protocolVersion)
T
TypeCodec.AbstractTupleCodec. deserialize(java.nio.ByteBuffer bytes, ProtocolVersion protocolVersion)
T
TypeCodec.AbstractUDTCodec. deserialize(java.nio.ByteBuffer bytes, ProtocolVersion protocolVersion)
abstract T
TypeCodec. deserialize(java.nio.ByteBuffer bytes, ProtocolVersion protocolVersion)
Deserialize the givenByteBuffer
instance according to the CQL type handled by this codec.java.lang.Boolean
TypeCodec.PrimitiveBooleanCodec. deserialize(java.nio.ByteBuffer bytes, ProtocolVersion protocolVersion)
java.lang.Byte
TypeCodec.PrimitiveByteCodec. deserialize(java.nio.ByteBuffer bytes, ProtocolVersion protocolVersion)
java.lang.Double
TypeCodec.PrimitiveDoubleCodec. deserialize(java.nio.ByteBuffer bytes, ProtocolVersion protocolVersion)
java.lang.Float
TypeCodec.PrimitiveFloatCodec. deserialize(java.nio.ByteBuffer bytes, ProtocolVersion protocolVersion)
java.lang.Integer
TypeCodec.PrimitiveIntCodec. deserialize(java.nio.ByteBuffer bytes, ProtocolVersion protocolVersion)
java.lang.Long
TypeCodec.PrimitiveLongCodec. deserialize(java.nio.ByteBuffer bytes, ProtocolVersion protocolVersion)
java.lang.Short
TypeCodec.PrimitiveShortCodec. deserialize(java.nio.ByteBuffer bytes, ProtocolVersion protocolVersion)
protected abstract T
TypeCodec.AbstractTupleCodec. deserializeAndSetField(java.nio.ByteBuffer input, T target, int index, ProtocolVersion protocolVersion)
Deserialize an individual field and set it on an object, as part of deserializing the whole object from a CQL tuple (seeTypeCodec.AbstractTupleCodec.deserialize(ByteBuffer, ProtocolVersion)
).protected abstract T
TypeCodec.AbstractUDTCodec. deserializeAndSetField(java.nio.ByteBuffer input, T target, java.lang.String fieldName, ProtocolVersion protocolVersion)
Deserialize an individual field and set it on an object, as part of deserializing the whole object from a CQL UDT (seeTypeCodec.AbstractUDTCodec.deserialize(ByteBuffer, ProtocolVersion)
).abstract boolean
TypeCodec.PrimitiveBooleanCodec. deserializeNoBoxing(java.nio.ByteBuffer v, ProtocolVersion protocolVersion)
abstract byte
TypeCodec.PrimitiveByteCodec. deserializeNoBoxing(java.nio.ByteBuffer v, ProtocolVersion protocolVersion)
abstract double
TypeCodec.PrimitiveDoubleCodec. deserializeNoBoxing(java.nio.ByteBuffer v, ProtocolVersion protocolVersion)
abstract float
TypeCodec.PrimitiveFloatCodec. deserializeNoBoxing(java.nio.ByteBuffer v, ProtocolVersion protocolVersion)
abstract int
TypeCodec.PrimitiveIntCodec. deserializeNoBoxing(java.nio.ByteBuffer v, ProtocolVersion protocolVersion)
abstract long
TypeCodec.PrimitiveLongCodec. deserializeNoBoxing(java.nio.ByteBuffer v, ProtocolVersion protocolVersion)
abstract short
TypeCodec.PrimitiveShortCodec. deserializeNoBoxing(java.nio.ByteBuffer v, ProtocolVersion protocolVersion)
static TupleType
TupleType. of(ProtocolVersion protocolVersion, CodecRegistry codecRegistry, DataType... types)
Creates a "disconnected" tuple type (you should preferMetadata#newTupleType(DataType...) cluster.getMetadata().newTupleType(...)
whenever possible).static java.nio.ByteBuffer
CodecUtils. pack(java.nio.ByteBuffer[] buffers, int elements, ProtocolVersion version)
Utility method that "packs" together a list ofByteBuffer
s containing serialized collection elements.static DataType
DataTypeClassNameParser. parseOne(java.lang.String className, ProtocolVersion protocolVersion, CodecRegistry codecRegistry)
static java.nio.ByteBuffer
CodecUtils. readValue(java.nio.ByteBuffer input, ProtocolVersion version)
Utility method that reads a value.java.nio.ByteBuffer
TypeCodec.AbstractCollectionCodec. serialize(C value, ProtocolVersion protocolVersion)
java.nio.ByteBuffer
TypeCodec.AbstractMapCodec. serialize(java.util.Map<K,V> value, ProtocolVersion protocolVersion)
java.nio.ByteBuffer
TypeCodec.AbstractTupleCodec. serialize(T value, ProtocolVersion protocolVersion)
java.nio.ByteBuffer
TypeCodec.AbstractUDTCodec. serialize(T value, ProtocolVersion protocolVersion)
java.nio.ByteBuffer
TypeCodec.PrimitiveBooleanCodec. serialize(java.lang.Boolean value, ProtocolVersion protocolVersion)
java.nio.ByteBuffer
TypeCodec.PrimitiveByteCodec. serialize(java.lang.Byte value, ProtocolVersion protocolVersion)
java.nio.ByteBuffer
TypeCodec.PrimitiveDoubleCodec. serialize(java.lang.Double value, ProtocolVersion protocolVersion)
java.nio.ByteBuffer
TypeCodec.PrimitiveFloatCodec. serialize(java.lang.Float value, ProtocolVersion protocolVersion)
java.nio.ByteBuffer
TypeCodec.PrimitiveIntCodec. serialize(java.lang.Integer value, ProtocolVersion protocolVersion)
java.nio.ByteBuffer
TypeCodec.PrimitiveLongCodec. serialize(java.lang.Long value, ProtocolVersion protocolVersion)
java.nio.ByteBuffer
TypeCodec.PrimitiveShortCodec. serialize(java.lang.Short value, ProtocolVersion protocolVersion)
abstract java.nio.ByteBuffer
TypeCodec. serialize(T value, ProtocolVersion protocolVersion)
Serialize the given value according to the CQL type handled by this codec.protected abstract java.nio.ByteBuffer
TypeCodec.AbstractTupleCodec. serializeField(T source, int index, ProtocolVersion protocolVersion)
Serialize an individual field in an object, as part of serializing the whole object to a CQL tuple (seeTypeCodec.AbstractTupleCodec.serialize(Object, ProtocolVersion)
).protected abstract java.nio.ByteBuffer
TypeCodec.AbstractUDTCodec. serializeField(T source, java.lang.String fieldName, ProtocolVersion protocolVersion)
Serialize an individual field in an object, as part of serializing the whole object to a CQL UDT (seeTypeCodec.AbstractUDTCodec.serialize(Object, ProtocolVersion)
).abstract java.nio.ByteBuffer
TypeCodec.PrimitiveBooleanCodec. serializeNoBoxing(boolean v, ProtocolVersion protocolVersion)
abstract java.nio.ByteBuffer
TypeCodec.PrimitiveByteCodec. serializeNoBoxing(byte v, ProtocolVersion protocolVersion)
abstract java.nio.ByteBuffer
TypeCodec.PrimitiveDoubleCodec. serializeNoBoxing(double v, ProtocolVersion protocolVersion)
abstract java.nio.ByteBuffer
TypeCodec.PrimitiveFloatCodec. serializeNoBoxing(float v, ProtocolVersion protocolVersion)
abstract java.nio.ByteBuffer
TypeCodec.PrimitiveIntCodec. serializeNoBoxing(int v, ProtocolVersion protocolVersion)
abstract java.nio.ByteBuffer
TypeCodec.PrimitiveLongCodec. serializeNoBoxing(long v, ProtocolVersion protocolVersion)
abstract java.nio.ByteBuffer
TypeCodec.PrimitiveShortCodec. serializeNoBoxing(short v, ProtocolVersion protocolVersion)
static void
CodecUtils. writeValue(java.nio.ByteBuffer output, java.nio.ByteBuffer value, ProtocolVersion version)
Utility method that writes a value. -
Uses of ProtocolVersion in org.apache.cassandra.cql3.selection
Methods in org.apache.cassandra.cql3.selection with parameters of type ProtocolVersion Modifier and Type Method Description abstract void
Selector. addInput(ProtocolVersion protocolVersion, ResultSetBuilder rs)
Add the current value from the specifiedResultSetBuilder
.void
SimpleSelector. addInput(ProtocolVersion protocolVersion, ResultSetBuilder rs)
void
TermSelector. addInput(ProtocolVersion protocolVersion, ResultSetBuilder rs)
abstract java.nio.ByteBuffer
Selector. getOutput(ProtocolVersion protocolVersion)
Returns the selector output.java.nio.ByteBuffer
SimpleSelector. getOutput(ProtocolVersion protocolVersion)
java.nio.ByteBuffer
TermSelector. getOutput(ProtocolVersion protocolVersion)
-
Uses of ProtocolVersion in org.apache.cassandra.db
Methods in org.apache.cassandra.db with parameters of type ProtocolVersion Modifier and Type Method Description default QueryPager
PartitionRangeReadQuery. getPager(PagingState pagingState, ProtocolVersion protocolVersion)
QueryPager
ReadQuery. getPager(PagingState pagingState, ProtocolVersion protocolVersion)
Returns a pager for the query.default SinglePartitionPager
SinglePartitionReadQuery. getPager(PagingState pagingState, ProtocolVersion protocolVersion)
QueryPager
SinglePartitionReadQuery.Group. getPager(PagingState pagingState, ProtocolVersion protocolVersion)
-
Uses of ProtocolVersion in org.apache.cassandra.db.marshal
Methods in org.apache.cassandra.db.marshal with parameters of type ProtocolVersion Modifier and Type Method Description java.nio.ByteBuffer
CollectionType. serializeForNativeProtocol(java.util.Iterator<Cell<?>> cells, ProtocolVersion version)
java.nio.ByteBuffer
UserType. serializeForNativeProtocol(java.util.Iterator<Cell<?>> cells, ProtocolVersion protocolVersion)
static java.lang.String
ListType. setOrListToJsonString(java.nio.ByteBuffer buffer, AbstractType elementsType, ProtocolVersion protocolVersion)
java.lang.String
AbstractCompositeType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
AbstractType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
Converts the specified value into its JSON representation.<V> java.lang.String
AbstractType. toJSONString(V value, ValueAccessor<V> accessor, ProtocolVersion protocolVersion)
java.lang.String
AsciiType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
BooleanType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
BytesType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
ByteType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
CounterColumnType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
DateType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
Deprecated.java.lang.String
DecimalType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
DoubleType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
EmptyType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
FloatType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
FrozenType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
InetAddressType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
Int32Type. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
IntegerType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
ListType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
LongType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
MapType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
PartitionerDefinedOrder. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
ReversedType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
SetType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
ShortType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
SimpleDateType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
TimestampType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
TimeType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
TupleType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
UserType. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
java.lang.String
UTF8Type. toJSONString(java.nio.ByteBuffer buffer, ProtocolVersion protocolVersion)
-
Uses of ProtocolVersion in org.apache.cassandra.serializers
Methods in org.apache.cassandra.serializers with parameters of type ProtocolVersion Modifier and Type Method Description protected java.nio.ByteBuffer
CollectionSerializer. copyAsNewCollection(java.nio.ByteBuffer input, int count, int startPos, int endPos, ProtocolVersion version)
Creates a new serialized map composed from the data frominput
betweenstartPos
(inclusive) andendPos
(exclusive), assuming that data holdscount
elements.T
CollectionSerializer. deserializeForNativeProtocol(java.nio.ByteBuffer value, ProtocolVersion version)
abstract <V> T
CollectionSerializer. deserializeForNativeProtocol(V value, ValueAccessor<V> accessor, ProtocolVersion version)
<V> java.util.List<T>
ListSerializer. deserializeForNativeProtocol(V input, ValueAccessor<V> accessor, ProtocolVersion version)
<I> java.util.Map<K,V>
MapSerializer. deserializeForNativeProtocol(I input, ValueAccessor<I> accessor, ProtocolVersion version)
<V> java.util.Set<T>
SetSerializer. deserializeForNativeProtocol(V input, ValueAccessor<V> accessor, ProtocolVersion version)
static java.nio.ByteBuffer
CollectionSerializer. pack(java.util.Collection<java.nio.ByteBuffer> values, int elements, ProtocolVersion version)
static <V> V
CollectionSerializer. pack(java.util.Collection<V> values, ValueAccessor<V> accessor, int elements, ProtocolVersion version)
static int
CollectionSerializer. readCollectionSize(java.nio.ByteBuffer input, ProtocolVersion version)
static <V> int
CollectionSerializer. readCollectionSize(V value, ValueAccessor<V> accessor, ProtocolVersion version)
static <V> V
CollectionSerializer. readValue(V input, ValueAccessor<V> accessor, int offset, ProtocolVersion version)
static int
CollectionSerializer. sizeOfCollectionSize(int elements, ProtocolVersion version)
static <V> int
CollectionSerializer. sizeOfValue(V value, ValueAccessor<V> accessor, ProtocolVersion version)
protected static void
CollectionSerializer. skipValue(java.nio.ByteBuffer input, ProtocolVersion version)
static <V> int
CollectionSerializer. skipValue(V input, ValueAccessor<V> accessor, int offset, ProtocolVersion version)
abstract <V> void
CollectionSerializer. validateForNativeProtocol(V value, ValueAccessor<V> accessor, ProtocolVersion version)
<V> void
ListSerializer. validateForNativeProtocol(V input, ValueAccessor<V> accessor, ProtocolVersion version)
<T> void
MapSerializer. validateForNativeProtocol(T input, ValueAccessor<T> accessor, ProtocolVersion version)
<V> void
SetSerializer. validateForNativeProtocol(V input, ValueAccessor<V> accessor, ProtocolVersion version)
protected static void
CollectionSerializer. writeCollectionSize(java.nio.ByteBuffer output, int elements, ProtocolVersion version)
static <V> void
CollectionSerializer. writeValue(java.nio.ByteBuffer output, V value, ValueAccessor<V> accessor, ProtocolVersion version)
-
Uses of ProtocolVersion in org.apache.cassandra.service.pager
Fields in org.apache.cassandra.service.pager declared as ProtocolVersion Modifier and Type Field Description protected ProtocolVersion
AbstractQueryPager. protocolVersion
protected ProtocolVersion
AbstractQueryPager. protocolVersion
Methods in org.apache.cassandra.service.pager with parameters of type ProtocolVersion Modifier and Type Method Description static PagingState.RowMark
PagingState.RowMark. create(TableMetadata metadata, Row row, ProtocolVersion protocolVersion)
static PagingState
PagingState. deserialize(java.nio.ByteBuffer bytes, ProtocolVersion protocolVersion)
It's possible to receive a V3 paging state on a V4 client session, and vice versa - so we cannot blindly rely on the protocol version provided.java.nio.ByteBuffer
PagingState. serialize(ProtocolVersion protocolVersion)
int
PagingState. serializedSize(ProtocolVersion protocolVersion)
Constructors in org.apache.cassandra.service.pager with parameters of type ProtocolVersion Constructor Description MultiPartitionPager(SinglePartitionReadQuery.Group<T> group, PagingState state, ProtocolVersion protocolVersion)
PartitionRangeQueryPager(PartitionRangeReadQuery query, PagingState state, ProtocolVersion protocolVersion)
PartitionRangeQueryPager(PartitionRangeReadQuery query, ProtocolVersion protocolVersion, DecoratedKey lastReturnedKey, PagingState.RowMark lastReturnedRow, int remaining, int remainingInPartition)
SinglePartitionPager(SinglePartitionReadQuery query, PagingState state, ProtocolVersion protocolVersion)
-
Uses of ProtocolVersion in org.apache.cassandra.transport
Fields in org.apache.cassandra.transport declared as ProtocolVersion Modifier and Type Field Description static ProtocolVersion
ProtocolVersion. CURRENT
The preferred versionsprotected ProtocolVersion
Message. forcedProtocolVersion
ProtocolVersion
Event.Type. minimumVersion
ProtocolVersion
Envelope.Header. version
protected ProtocolVersion
SimpleClient. version
Fields in org.apache.cassandra.transport with type parameters of type ProtocolVersion Modifier and Type Field Description static java.util.Optional<ProtocolVersion>
ProtocolVersion. BETA
static java.util.EnumSet<ProtocolVersion>
ProtocolVersion. SUPPORTED
All supported versions, published as an enumsetstatic java.util.EnumSet<ProtocolVersion>
ProtocolVersion. UNSUPPORTED
Old unsupported versions, this is OK as long as we never add newer unsupported versionsMethods in org.apache.cassandra.transport that return ProtocolVersion Modifier and Type Method Description static ProtocolVersion
ProtocolVersion. decode(int versionNum, boolean allowOlderProtocols)
ProtocolVersion
ProtocolException. getForcedProtocolVersion()
ProtocolVersion
DataType. getProtocolVersion()
ProtocolVersion
Connection. getVersion()
static ProtocolVersion
ProtocolVersion. valueOf(java.lang.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.Methods in org.apache.cassandra.transport that return types with arguments of type ProtocolVersion Modifier and Type Method Description static java.util.List<ProtocolVersion>
ProtocolVersion. supportedVersionsStartingWith(ProtocolVersion smallestVersion)
Methods in org.apache.cassandra.transport with parameters of type ProtocolVersion Modifier and Type Method Description void
PipelineConfigurator. configureModernPipeline(io.netty.channel.ChannelHandlerContext ctx, org.apache.cassandra.transport.ClientResourceLimits.Allocator resourceAllocator, ProtocolVersion version, java.util.Map<java.lang.String,java.lang.String> options)
static Envelope
Envelope. create(Message.Type type, int streamId, ProtocolVersion version, java.util.EnumSet<Envelope.Header.Flag> flags, io.netty.buffer.ByteBuf body)
T
CBCodec. decode(io.netty.buffer.ByteBuf body, ProtocolVersion version)
Pair<DataType,java.lang.Object>
DataType.Codec. decodeOne(io.netty.buffer.ByteBuf body, ProtocolVersion version)
static Event
Event. deserialize(io.netty.buffer.ByteBuf cb, ProtocolVersion version)
static Event.SchemaChange
Event.SchemaChange. deserializeEvent(io.netty.buffer.ByteBuf cb, ProtocolVersion version)
void
CBCodec. encode(T t, io.netty.buffer.ByteBuf dest, ProtocolVersion version)
Envelope
Message. encode(ProtocolVersion version)
int
CBCodec. encodedSize(T t, ProtocolVersion version)
protected abstract int
Event. eventSerializedSize(ProtocolVersion version)
int
Event.SchemaChange. eventSerializedSize(ProtocolVersion version)
protected int
Event.StatusChange. eventSerializedSize(ProtocolVersion version)
protected int
Event.TopologyChange. eventSerializedSize(ProtocolVersion version)
static Pair<DataType,java.lang.Object>
DataType. fromType(AbstractType type, ProtocolVersion version)
int
DataType. getId(ProtocolVersion version)
boolean
ProtocolVersion. isGreaterOrEqualTo(ProtocolVersion other)
boolean
ProtocolVersion. isGreaterThan(ProtocolVersion other)
boolean
ProtocolVersion. isSmallerOrEqualTo(ProtocolVersion other)
boolean
ProtocolVersion. isSmallerThan(ProtocolVersion other)
Connection
Connection.Factory. newConnection(io.netty.channel.Channel channel, ProtocolVersion version)
int
DataType.Codec. oneSerializedSize(Pair<DataType,java.lang.Object> option, ProtocolVersion version)
static io.netty.channel.ChannelInboundHandlerAdapter
ExceptionHandlers. postV5Handler(FrameEncoder.PayloadAllocator allocator, ProtocolVersion version)
SimpleClient.Builder
SimpleClient.Builder. protocolVersion(ProtocolVersion version)
static java.nio.ByteBuffer
CBUtil. readBoundValue(io.netty.buffer.ByteBuf cb, ProtocolVersion protocolVersion)
static Pair<java.util.List<java.lang.String>,java.util.List<java.nio.ByteBuffer>>
CBUtil. readNameAndValueList(io.netty.buffer.ByteBuf cb, ProtocolVersion protocolVersion)
java.lang.Object
DataType. readValue(io.netty.buffer.ByteBuf cb, ProtocolVersion version)
static java.util.List<java.nio.ByteBuffer>
CBUtil. readValueList(io.netty.buffer.ByteBuf cb, ProtocolVersion protocolVersion)
void
Event. serialize(io.netty.buffer.ByteBuf dest, ProtocolVersion version)
int
Event. serializedSize(ProtocolVersion version)
int
DataType. serializedValueSize(java.lang.Object value, ProtocolVersion version)
void
Event.SchemaChange. serializeEvent(io.netty.buffer.ByteBuf dest, ProtocolVersion version)
protected abstract void
Event. serializeEvent(io.netty.buffer.ByteBuf dest, ProtocolVersion version)
protected void
Event.StatusChange. serializeEvent(io.netty.buffer.ByteBuf dest, ProtocolVersion version)
protected void
Event.TopologyChange. serializeEvent(io.netty.buffer.ByteBuf dest, ProtocolVersion version)
static java.util.List<ProtocolVersion>
ProtocolVersion. supportedVersionsStartingWith(ProtocolVersion smallestVersion)
void
DataType.Codec. writeOne(Pair<DataType,java.lang.Object> option, io.netty.buffer.ByteBuf dest, ProtocolVersion version)
void
DataType. writeValue(java.lang.Object value, io.netty.buffer.ByteBuf cb, ProtocolVersion version)
Constructors in org.apache.cassandra.transport with parameters of type ProtocolVersion Constructor Description Client(java.lang.String host, int port, ProtocolVersion version, EncryptionOptions encryptionOptions)
Connection(io.netty.channel.Channel channel, ProtocolVersion version, Connection.Tracker tracker)
ProtocolException(java.lang.String msg, ProtocolVersion forcedProtocolVersion)
SimpleClient(java.lang.String host, int port, ProtocolVersion version)
SimpleClient(java.lang.String host, int port, ProtocolVersion version, boolean useBeta, EncryptionOptions encryptionOptions)
SimpleClient(java.lang.String host, int port, ProtocolVersion version, EncryptionOptions encryptionOptions)
-
Uses of ProtocolVersion in org.apache.cassandra.transport.messages
Methods in org.apache.cassandra.transport.messages with parameters of type ProtocolVersion Modifier and Type Method Description T
UnsupportedMessageCodec. decode(io.netty.buffer.ByteBuf body, ProtocolVersion version)
void
UnsupportedMessageCodec. encode(T t, io.netty.buffer.ByteBuf dest, ProtocolVersion version)
int
UnsupportedMessageCodec. encodedSize(T t, ProtocolVersion version)
-