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 to TypeSerializer.toCQLLiteral(ByteBuffer) for native types as most CQL literal representations work fine with the default TypeSerializer.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 by JavaBasedUDFunction and script executor ScriptBasedUDFunction) 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 by JavaBasedUDFunction and script executor ScriptBasedUDFunction) 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)	Like ScalarFunction.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)
default ScalarFunction	ScalarFunction.partialApplication(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> partialParameters)	Does a partial application of the function.
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 given ByteBuffer 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 (see TypeCodec.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 (see TypeCodec.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 prefer Metadata#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 of ByteBuffers 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 (see TypeCodec.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 (see TypeCodec.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, Selector.InputRow input)	Add the current value from the specified ResultSetBuilder.
void	SimpleSelector.addInput(ProtocolVersion protocolVersion, Selector.InputRow input)
void	TermSelector.addInput(ProtocolVersion protocolVersion, Selector.InputRow input)
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	DynamicCompositeType.FixedValueComparator.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 from input between startPos (inclusive) and endPos (exclusive), assuming that data holds count 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.readNonNullValue(V input, ValueAccessor<V> accessor, int offset, 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 versions
protected 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 enumset
static java.util.EnumSet<ProtocolVersion>	ProtocolVersion.UNSUPPORTED	Old unsupported versions, this is OK as long as we never add newer unsupported versions

Methods 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, ServerConnection serverConnection, 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)