Uses of Interface
org.apache.cassandra.io.util.DataInputPlus

Packages that use DataInputPlus

Package	Description
org.apache.cassandra.batchlog
org.apache.cassandra.cache
org.apache.cassandra.cql3.selection
org.apache.cassandra.db
org.apache.cassandra.db.aggregation
org.apache.cassandra.db.commitlog
org.apache.cassandra.db.filter
org.apache.cassandra.db.marshal
org.apache.cassandra.db.partitions
org.apache.cassandra.db.rows
org.apache.cassandra.db.streaming	File transfer
org.apache.cassandra.exceptions
org.apache.cassandra.gms
org.apache.cassandra.hints	Hints subsystem consists of several components.
org.apache.cassandra.index.sai.disk.v1.vector
org.apache.cassandra.io
org.apache.cassandra.io.sstable
org.apache.cassandra.io.sstable.format
org.apache.cassandra.io.sstable.format.big
org.apache.cassandra.io.sstable.indexsummary
org.apache.cassandra.io.sstable.keycache
org.apache.cassandra.io.sstable.metadata
org.apache.cassandra.io.util
org.apache.cassandra.locator
org.apache.cassandra.net
org.apache.cassandra.repair
org.apache.cassandra.schema
org.apache.cassandra.serializers
org.apache.cassandra.service
org.apache.cassandra.service.paxos
org.apache.cassandra.service.paxos.cleanup
org.apache.cassandra.streaming
org.apache.cassandra.streaming.async	Non-blocking streaming with netty
org.apache.cassandra.streaming.compress
org.apache.cassandra.streaming.messages
org.apache.cassandra.utils
org.apache.cassandra.utils.streamhist
org.apache.cassandra.utils.vint

Uses of DataInputPlus in org.apache.cassandra.batchlog

Methods in org.apache.cassandra.batchlog with parameters of type DataInputPlus

Modifier and Type	Method	Description
Batch	Batch.Serializer.deserialize(DataInputPlus in, int version)

Uses of DataInputPlus in org.apache.cassandra.cache

Methods in org.apache.cassandra.cache with parameters of type DataInputPlus

Modifier and Type	Method	Description
abstract Future<Pair<K,V>>	AutoSavingCache.CacheSerializer.deserialize(DataInputPlus in)
IRowCacheEntry	SerializingCacheProvider.RowCacheSerializer.deserialize(DataInputPlus in)
void	AutoSavingCache.CacheSerializer.deserializeMetadata(DataInputPlus in)
static CounterCacheKey	CounterCacheKey.read(TableMetadata tableMetadata, DataInputPlus in)
protected ColumnFamilyStore	AutoSavingCache.CacheSerializer.readCFS(DataInputPlus in)

Uses of DataInputPlus in org.apache.cassandra.cql3.selection

Methods in org.apache.cassandra.cql3.selection with parameters of type DataInputPlus

Modifier and Type	Method	Description
protected abstract Selector	Selector.SelectorDeserializer.deserialize(DataInputPlus in, int version, TableMetadata metadata)
Selector	Selector.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata)
protected final AbstractType<?>	Selector.SelectorDeserializer.readType(KeyspaceMetadata keyspace, DataInputPlus in)
protected final AbstractType<?>	Selector.SelectorDeserializer.readType(TableMetadata metadata, DataInputPlus in)

Uses of DataInputPlus in org.apache.cassandra.db

Fields in org.apache.cassandra.db declared as DataInputPlus

Modifier and Type	Field	Description
protected final DataInputPlus	UnfilteredDeserializer.in

Methods in org.apache.cassandra.db with parameters of type DataInputPlus

Modifier and Type	Method	Description
static UnfilteredDeserializer	UnfilteredDeserializer.create(TableMetadata metadata, DataInputPlus in, SerializationHeader header, DeserializationHelper helper)
Clustering<byte[]>	Clustering.Serializer.deserialize(DataInputPlus in, int version, List<AbstractType<?>> types)
ClusteringBoundOrBoundary<byte[]>	ClusteringBoundOrBoundary.Serializer.deserialize(DataInputPlus in, int version, List<AbstractType<?>> types)
ClusteringPrefix<byte[]>	ClusteringPrefix.Serializer.deserialize(DataInputPlus in, int version, List<AbstractType<?>> types)
Columns	Columns.Serializer.deserialize(DataInputPlus in, TableMetadata metadata)
CounterMutation	CounterMutation.CounterMutationSerializer.deserialize(DataInputPlus in, int version)
DataRange	DataRange.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata)
DeletionTime	DeletionTime.LegacySerializer.deserialize(DataInputPlus in)
DeletionTime	DeletionTime.Serializer.deserialize(DataInputPlus in)
Mutation	Mutation.MutationSerializer.deserialize(DataInputPlus in, int version)
Mutation	Mutation.MutationSerializer.deserialize(DataInputPlus in, int version, DeserializationHelper.Flag flag)
abstract ReadCommand	ReadCommand.SelectionDeserializer.deserialize(DataInputPlus in, int version, boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, Index.QueryPlan indexQueryPlan)
ReadCommand	ReadCommand.Serializer.deserialize(DataInputPlus in, int version)
SerializationHeader.Component	SerializationHeader.Serializer.deserialize(Version version, DataInputPlus in)
Slice	Slice.Serializer.deserialize(DataInputPlus in, int version, List<AbstractType<?>> types)
Slices	Slices.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata)
TruncateResponse	TruncateResponse.TruncateResponseSerializer.deserialize(DataInputPlus in, int version)
SerializationHeader	SerializationHeader.Serializer.deserializeForMessaging(DataInputPlus in, TableMetadata metadata, ColumnFilter selection, boolean hasStatic)
Columns	Columns.Serializer.deserializeSubset(Columns superset, DataInputPlus in)
ClusteringBoundOrBoundary<byte[]>	ClusteringBoundOrBoundary.Serializer.deserializeValues(DataInputPlus in, ClusteringPrefix.Kind kind, int version, List<AbstractType<?>> types)
DeletionTime	SerializationHeader.readDeletionTime(DataInputPlus in)
long	SerializationHeader.readLocalDeletionTime(DataInputPlus in)
long	SerializationHeader.readTimestamp(DataInputPlus in)
int	SerializationHeader.readTTL(DataInputPlus in)
void	Clustering.Serializer.skip(DataInputPlus in, int version, List<AbstractType<?>> types)
void	ClusteringPrefix.Serializer.skip(DataInputPlus in, int version, List<AbstractType<?>> types)
void	DeletionTime.LegacySerializer.skip(DataInputPlus in)
void	DeletionTime.Serializer.skip(DataInputPlus in)
void	SerializationHeader.skipDeletionTime(DataInputPlus in)
void	SerializationHeader.skipLocalDeletionTime(DataInputPlus in)
void	SerializationHeader.skipTimestamp(DataInputPlus in)
void	SerializationHeader.skipTTL(DataInputPlus in)
void	ClusteringBoundOrBoundary.Serializer.skipValues(DataInputPlus in, ClusteringPrefix.Kind kind, int version, List<AbstractType<?>> types)

Constructors in org.apache.cassandra.db with parameters of type DataInputPlus

Modifier	Constructor	Description
	Deserializer(ClusteringComparator comparator, DataInputPlus in, SerializationHeader header)

Uses of DataInputPlus in org.apache.cassandra.db.aggregation

Methods in org.apache.cassandra.db.aggregation with parameters of type DataInputPlus

Modifier and Type	Method	Description
AggregationSpecification	AggregationSpecification.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata)
GroupingState	GroupingState.Serializer.deserialize(DataInputPlus in, int version, ClusteringComparator comparator)

Uses of DataInputPlus in org.apache.cassandra.db.commitlog

Classes in org.apache.cassandra.db.commitlog that implement DataInputPlus

Modifier and Type	Class	Description
class	EncryptedFileSegmentInputStream	Each segment of an encrypted file may contain many encrypted chunks, and each chunk needs to be individually decrypted to reconstruct the full segment.

Methods in org.apache.cassandra.db.commitlog with parameters of type DataInputPlus

Modifier and Type	Method	Description
CommitLogPosition	CommitLogPosition.CommitLogPositionSerializer.deserialize(DataInputPlus in)

Uses of DataInputPlus in org.apache.cassandra.db.filter

Methods in org.apache.cassandra.db.filter with parameters of type DataInputPlus

Modifier and Type	Method	Description
ClusteringIndexFilter	ClusteringIndexFilter.InternalDeserializer.deserialize(DataInputPlus in, int version, TableMetadata metadata, boolean reversed)
ClusteringIndexFilter	ClusteringIndexFilter.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata)
ColumnFilter	ColumnFilter.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata)
ColumnSubselection	ColumnSubselection.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata)
DataLimits	DataLimits.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata)
RowFilter	RowFilter.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata, boolean needsReconciliation)
protected abstract RowFilter.UserExpression	RowFilter.UserExpression.Deserializer.deserialize(DataInputPlus in, int version, TableMetadata metadata)

Uses of DataInputPlus in org.apache.cassandra.db.marshal

Methods in org.apache.cassandra.db.marshal with parameters of type DataInputPlus

Modifier and Type	Method	Description
<V> V	AbstractType.read(ValueAccessor<V> accessor, DataInputPlus in, int maxValueSize)
byte[]	ByteArrayAccessor.read(DataInputPlus in, int length)
ByteBuffer	ByteBufferAccessor.read(DataInputPlus in, int length)
V	ValueAccessor.read(DataInputPlus in, int length)	Reads a value of bytes from
byte[]	AbstractType.readArray(DataInputPlus in, int maxValueSize)
ByteBuffer	AbstractType.readBuffer(DataInputPlus in)
ByteBuffer	AbstractType.readBuffer(DataInputPlus in, int maxValueSize)
ByteBuffer	EmptyType.readBuffer(DataInputPlus in)
ByteBuffer	EmptyType.readBuffer(DataInputPlus in, int maxValueSize)
void	AbstractType.skipValue(DataInputPlus in)

Uses of DataInputPlus in org.apache.cassandra.db.partitions

Methods in org.apache.cassandra.db.partitions with parameters of type DataInputPlus

Modifier and Type	Method	Description
PartitionUpdate	PartitionUpdate.PartitionUpdateSerializer.deserialize(DataInputPlus in, int version, DeserializationHelper.Flag flag)
UnfilteredPartitionIterator	UnfilteredPartitionIterators.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata, ColumnFilter selection, DeserializationHelper.Flag flag)

Uses of DataInputPlus in org.apache.cassandra.db.rows

Methods in org.apache.cassandra.db.rows with parameters of type DataInputPlus

Modifier and Type	Method	Description
CellPath	CellPath.Serializer.deserialize(DataInputPlus in)
EncodingStats	EncodingStats.Serializer.deserialize(DataInputPlus in)
UnfilteredRowIterator	UnfilteredRowIteratorSerializer.deserialize(DataInputPlus in, int version, TableMetadata metadata, ColumnFilter selection, DeserializationHelper.Flag flag)
UnfilteredRowIterator	UnfilteredRowIteratorSerializer.deserialize(DataInputPlus in, int version, TableMetadata metadata, DeserializationHelper.Flag flag, UnfilteredRowIteratorSerializer.Header header)
Unfiltered	UnfilteredSerializer.deserialize(DataInputPlus in, SerializationHeader header, DeserializationHelper helper, Row.Builder builder)	Deserialize an Unfiltered from the provided input.
UnfilteredRowIteratorSerializer.Header	UnfilteredRowIteratorSerializer.deserializeHeader(TableMetadata metadata, ColumnFilter selection, DataInputPlus in, int version, DeserializationHelper.Flag flag)
RangeTombstoneMarker	UnfilteredSerializer.deserializeMarkerBody(DataInputPlus in, SerializationHeader header, ClusteringBoundOrBoundary<?> bound)
Row	UnfilteredSerializer.deserializeRowBody(DataInputPlus in, SerializationHeader header, DeserializationHelper helper, int flags, int extendedFlags, Row.Builder builder)
Row	UnfilteredSerializer.deserializeStaticRow(DataInputPlus in, SerializationHeader header, DeserializationHelper helper)
static int	UnfilteredSerializer.readExtendedFlags(DataInputPlus in, int flags)
void	CellPath.Serializer.skip(DataInputPlus in)
void	UnfilteredSerializer.skipMarkerBody(DataInputPlus in)
void	UnfilteredSerializer.skipRowBody(DataInputPlus in)
void	UnfilteredSerializer.skipStaticRow(DataInputPlus in, SerializationHeader header, DeserializationHelper helper)

Uses of DataInputPlus in org.apache.cassandra.db.streaming

Classes in org.apache.cassandra.db.streaming that implement DataInputPlus

Modifier and Type	Class	Description
class	CompressedInputStream	InputStream which reads compressed chunks from the underlying input stream and deals with decompression and position tracking.

Methods in org.apache.cassandra.db.streaming with parameters of type DataInputPlus

Modifier and Type	Method	Description
CassandraStreamHeader	CassandraStreamHeader.CassandraStreamHeaderSerializer.deserialize(DataInputPlus in, int version)
CassandraStreamHeader	CassandraStreamHeader.CassandraStreamHeaderSerializer.deserialize(DataInputPlus in, int version, Function<TableId,IPartitioner> partitionerMapper)
SSTableMultiWriter	CassandraCompressedStreamReader.read(DataInputPlus inputPlus)
SSTableMultiWriter	CassandraEntireSSTableStreamReader.read(DataInputPlus in)
void	CassandraIncomingFile.read(DataInputPlus in, int version)
SSTableMultiWriter	CassandraStreamReader.read(DataInputPlus inputPlus)
SSTableMultiWriter	IStreamReader.read(DataInputPlus inputPlus)

Constructors in org.apache.cassandra.db.streaming with parameters of type DataInputPlus

Modifier	Constructor	Description
	CompressedInputStream(DataInputPlus input, CompressionInfo compressionInfo, ChecksumType checksumType, DoubleSupplier validateChecksumChance)
	StreamDeserializer(TableMetadata metadata, DataInputPlus in, Version version, SerializationHeader header, StreamSession session, SSTableMultiWriter writer)

Uses of DataInputPlus in org.apache.cassandra.exceptions

Methods in org.apache.cassandra.exceptions with parameters of type DataInputPlus

Modifier and Type	Method	Description
RequestFailureReason	RequestFailureReason.Serializer.deserialize(DataInputPlus in, int version)

Uses of DataInputPlus in org.apache.cassandra.gms

Methods in org.apache.cassandra.gms with parameters of type DataInputPlus

Modifier and Type	Method	Description
Object	GossipShutdown.Serializer.deserialize(DataInputPlus in, int version)

Uses of DataInputPlus in org.apache.cassandra.hints

Classes in org.apache.cassandra.hints that implement DataInputPlus

Modifier and Type	Class	Description
class	ChecksummedDataInput	A RandomAccessReader wrapper that calculates the CRC in place.
final class	CompressedChecksummedDataInput
class	EncryptedChecksummedDataInput

Methods in org.apache.cassandra.hints with parameters of type DataInputPlus

Modifier and Type	Method	Description
HintMessage	HintMessage.Serializer.deserialize(DataInputPlus in, int version)

Uses of DataInputPlus in org.apache.cassandra.index.sai.disk.v1.vector

Classes in org.apache.cassandra.index.sai.disk.v1.vector that implement DataInputPlus

Modifier and Type	Class	Description
class	RandomAccessReaderAdapter

Uses of DataInputPlus in org.apache.cassandra.io

Methods in org.apache.cassandra.io with parameters of type DataInputPlus

Modifier and Type	Method	Description
T	ISerializer.deserialize(DataInputPlus in)	Deserialize from the specified DataInput instance.
Out	IVersionedAsymmetricSerializer.deserialize(DataInputPlus in, int version)	Deserialize into the specified DataInputStream instance.
default void	ISerializer.skip(DataInputPlus in)

Uses of DataInputPlus in org.apache.cassandra.io.sstable

Fields in org.apache.cassandra.io.sstable declared as DataInputPlus

Modifier and Type	Field	Description
protected final DataInputPlus	SSTableSimpleIterator.in

Methods in org.apache.cassandra.io.sstable with parameters of type DataInputPlus

Modifier and Type	Method	Description
static SSTableSimpleIterator	SSTableSimpleIterator.create(TableMetadata metadata, DataInputPlus in, SerializationHeader header, DeserializationHelper helper, DeletionTime partitionDeletion)
static SSTableSimpleIterator	SSTableSimpleIterator.createTombstoneOnly(TableMetadata metadata, DataInputPlus in, SerializationHeader header, DeserializationHelper helper, DeletionTime partitionDeletion)
IndexInfo	IndexInfo.Serializer.deserialize(DataInputPlus in)
void	IndexInfo.Serializer.skip(DataInputPlus in)
void	SSTableZeroCopyWriter.writeComponent(Component component, DataInputPlus in, long size)

Uses of DataInputPlus in org.apache.cassandra.io.sstable.format

Methods in org.apache.cassandra.io.sstable.format with parameters of type DataInputPlus

Modifier and Type	Method	Description
T	SSTableFormat.KeyCacheValueSerializer.deserialize(R reader, DataInputPlus input)
void	SSTableFormat.KeyCacheValueSerializer.skip(DataInputPlus input)

Uses of DataInputPlus in org.apache.cassandra.io.sstable.format.big

Methods in org.apache.cassandra.io.sstable.format.big with parameters of type DataInputPlus

Modifier and Type	Method	Description
RowIndexEntry	RowIndexEntry.IndexSerializer.deserialize(DataInputPlus in, long indexFilePosition)
RowIndexEntry	RowIndexEntry.Serializer.deserialize(DataInputPlus in, long indexFilePosition)
RowIndexEntry	RowIndexEntry.IndexSerializer.deserializeForCache(DataInputPlus in)
RowIndexEntry	RowIndexEntry.Serializer.deserializeForCache(DataInputPlus in)
RowIndexEntry	BigTableReader.deserializeKeyCacheValue(DataInputPlus input)
long	RowIndexEntry.IndexSerializer.deserializePositionAndSkip(DataInputPlus in)
long	RowIndexEntry.Serializer.deserializePositionAndSkip(DataInputPlus in)
static long	RowIndexEntry.Serializer.readPosition(DataInputPlus in)	Reads only the data 'position' of the index entry and returns it.
static void	RowIndexEntry.Serializer.skip(DataInputPlus in, Version version)
static void	RowIndexEntry.Serializer.skipForCache(DataInputPlus in, Version version)

Uses of DataInputPlus in org.apache.cassandra.io.sstable.indexsummary

Methods in org.apache.cassandra.io.sstable.indexsummary with type parameters of type DataInputPlus

Modifier and Type	Method	Description
<T extends InputStream & DataInputPlus> IndexSummary	IndexSummary.IndexSummarySerializer.deserialize(T in, IPartitioner partitioner, int expectedMinIndexInterval, int maxIndexInterval)

Uses of DataInputPlus in org.apache.cassandra.io.sstable.keycache

Methods in org.apache.cassandra.io.sstable.keycache with parameters of type DataInputPlus

Modifier and Type	Method	Description
AbstractRowIndexEntry	KeyCacheSupport.deserializeKeyCacheValue(DataInputPlus input)

Uses of DataInputPlus in org.apache.cassandra.io.sstable.metadata

Methods in org.apache.cassandra.io.sstable.metadata with parameters of type DataInputPlus

Modifier and Type	Method	Description
CompactionMetadata	CompactionMetadata.CompactionMetadataSerializer.deserialize(Version version, DataInputPlus in)
T	IMetadataComponentSerializer.deserialize(Version version, DataInputPlus in)	Deserialize metadata component from given input.
StatsMetadata	StatsMetadata.StatsMetadataSerializer.deserialize(Version version, DataInputPlus in)
ValidationMetadata	ValidationMetadata.ValidationMetadataSerializer.deserialize(Version version, DataInputPlus in)

Uses of DataInputPlus in org.apache.cassandra.io.util

Subinterfaces of DataInputPlus in org.apache.cassandra.io.util

Modifier and Type	Interface	Description
interface	FileDataInput
interface	RewindableDataInput

Classes in org.apache.cassandra.io.util that implement DataInputPlus

Modifier and Type	Class	Description
class	DataInputBuffer	Input stream around a single ByteBuffer.
static class	DataInputPlus.DataInputStreamPlus	Wrapper around an InputStream that provides no buffering but can decode varints
class	FileInputStreamPlus
class	FileSegmentInputStream	This is the same as DataInputBuffer, i.e.
class	MemoryInputStream
class	NIODataInputStream	Rough equivalent of BufferedInputStream and DataInputStream wrapping the input stream of a File or Socket Created to work around the fact that when BIS + DIS delegate to NIO for socket IO they will allocate large thread local direct byte buffers when a large array is used to read.
class	RandomAccessReader
class	RebufferingInputStream	Rough equivalent of BufferedInputStream and DataInputStream wrapping a ByteBuffer that can be refilled via rebuffer.
class	TeeDataInputPlus	DataInput that also stores the raw inputs into an output buffer This is useful for storing serialized buffers as they are deserialized.
class	TrackedDataInputPlus	This class is to track bytes read from given DataInput

Constructors in org.apache.cassandra.io.util with parameters of type DataInputPlus

Modifier	Constructor	Description
	TeeDataInputPlus(DataInputPlus source, DataOutputPlus teeBuffer)
	TeeDataInputPlus(DataInputPlus source, DataOutputPlus teeBuffer, long limit)

Uses of DataInputPlus in org.apache.cassandra.locator

Methods in org.apache.cassandra.locator with parameters of type DataInputPlus

Modifier and Type	Method	Description
InetAddressAndPort	InetAddressAndPort.FwdFrmSerializer.deserialize(DataInputPlus in, int version)
InetAddressAndPort	InetAddressAndPort.Serializer.deserialize(DataInputPlus in, int version)

Uses of DataInputPlus in org.apache.cassandra.net

Classes in org.apache.cassandra.net that implement DataInputPlus

Modifier and Type	Class	Description
class	AsyncStreamingInputPlus

Methods in org.apache.cassandra.net with parameters of type DataInputPlus

Modifier and Type	Method	Description
<T> Message<T>	Message.Serializer.deserialize(DataInputPlus in, InetAddressAndPort peer, int version)
<T> Message<T>	Message.Serializer.deserialize(DataInputPlus in, Message.Header header, int version)	A partial variant of deserialize, taking in a previously deserialized Message.Header as an argument.

Uses of DataInputPlus in org.apache.cassandra.repair

Methods in org.apache.cassandra.repair with parameters of type DataInputPlus

Modifier and Type	Method	Description
SyncNodePair	SyncNodePair.NodePairSerializer.deserialize(DataInputPlus in, int version)

Uses of DataInputPlus in org.apache.cassandra.schema

Methods in org.apache.cassandra.schema with parameters of type DataInputPlus

Modifier and Type	Method	Description
IndexMetadata	IndexMetadata.Serializer.deserialize(DataInputPlus in, int version, TableMetadata table)
Collection<Mutation>	SchemaMutationsSerializer.deserialize(DataInputPlus in, int version)

Uses of DataInputPlus in org.apache.cassandra.serializers

Methods in org.apache.cassandra.serializers with parameters of type DataInputPlus

Modifier and Type	Method	Description
AbstractType<?>	AbstractTypeSerializer.deserialize(DataInputPlus in)
List<AbstractType<?>>	AbstractTypeSerializer.deserializeList(DataInputPlus in)

Uses of DataInputPlus in org.apache.cassandra.service

Methods in org.apache.cassandra.service with parameters of type DataInputPlus

Modifier and Type	Method	Description
Future<Pair<CounterCacheKey,ClockAndCount>>	CacheService.CounterCacheSerializer.deserialize(DataInputPlus in)
Future<Pair<KeyCacheKey,AbstractRowIndexEntry>>	CacheService.KeyCacheSerializer.deserialize(DataInputPlus input)
Future<Pair<RowCacheKey,IRowCacheEntry>>	CacheService.RowCacheSerializer.deserialize(DataInputPlus in)
void	CacheService.KeyCacheSerializer.deserializeMetadata(DataInputPlus in)

Uses of DataInputPlus in org.apache.cassandra.service.paxos

Methods in org.apache.cassandra.service.paxos with parameters of type DataInputPlus

Modifier and Type	Method	Description
static Ballot	Ballot.deserialize(DataInputPlus in)
Ballot	Ballot.Serializer.deserialize(DataInputPlus in, int version)
T	Commit.CommitSerializer.deserialize(DataInputPlus in, int version)
org.apache.cassandra.service.paxos.PaxosCommitAndPrepare.Request	PaxosCommitAndPrepare.RequestSerializer.deserialize(DataInputPlus in, int version)
org.apache.cassandra.service.paxos.PaxosPrepare.Request	PaxosPrepare.RequestSerializer.deserialize(DataInputPlus in, int version)
org.apache.cassandra.service.paxos.PaxosPrepare.Response	PaxosPrepare.ResponseSerializer.deserialize(DataInputPlus in, int version)
org.apache.cassandra.service.paxos.PaxosPrepareRefresh.Request	PaxosPrepareRefresh.RequestSerializer.deserialize(DataInputPlus in, int version)
org.apache.cassandra.service.paxos.PaxosPrepareRefresh.Response	PaxosPrepareRefresh.ResponseSerializer.deserialize(DataInputPlus in, int version)
org.apache.cassandra.service.paxos.PaxosPropose.Request	PaxosPropose.RequestSerializer.deserialize(DataInputPlus in, int version)
org.apache.cassandra.service.paxos.PaxosPropose.Response	PaxosPropose.ResponseSerializer.deserialize(DataInputPlus in, int version)
org.apache.cassandra.service.paxos.PaxosRepair.Request	PaxosRepair.RequestSerializer.deserialize(DataInputPlus in, int version)
org.apache.cassandra.service.paxos.PaxosRepair.Response	PaxosRepair.ResponseSerializer.deserialize(DataInputPlus in, int version)
PrepareResponse	PrepareResponse.PrepareResponseSerializer.deserialize(DataInputPlus in, int version)

Uses of DataInputPlus in org.apache.cassandra.service.paxos.cleanup

Methods in org.apache.cassandra.service.paxos.cleanup with parameters of type DataInputPlus

Modifier and Type	Method	Description
PaxosStartPrepareCleanup.Request	PaxosStartPrepareCleanup.RequestSerializer.deserialize(DataInputPlus in, int version)

Uses of DataInputPlus in org.apache.cassandra.streaming

Subinterfaces of DataInputPlus in org.apache.cassandra.streaming

Modifier and Type	Interface	Description
interface	StreamingDataInputPlus

Methods in org.apache.cassandra.streaming with parameters of type DataInputPlus

Modifier and Type	Method	Description
StreamRequest	StreamRequest.StreamRequestSerializer.deserialize(DataInputPlus in, int version)
StreamSummary	StreamSummary.StreamSummarySerializer.deserialize(DataInputPlus in, int version)
void	IncomingStream.read(DataInputPlus inputPlus, int version)	Read in the stream data.

Uses of DataInputPlus in org.apache.cassandra.streaming.async

Methods in org.apache.cassandra.streaming.async with parameters of type DataInputPlus

Modifier and Type	Method	Description
io.netty.buffer.ByteBuf	StreamCompressionSerializer.deserialize(net.jpountz.lz4.LZ4SafeDecompressor decompressor, DataInputPlus in, int version)

Uses of DataInputPlus in org.apache.cassandra.streaming.compress

Classes in org.apache.cassandra.streaming.compress that implement DataInputPlus

Modifier and Type	Class	Description
class	StreamCompressionInputStream

Constructors in org.apache.cassandra.streaming.compress with parameters of type DataInputPlus

Modifier	Constructor	Description
	StreamCompressionInputStream(DataInputPlus dataInputPlus, int protocolVersion)

Uses of DataInputPlus in org.apache.cassandra.streaming.messages

Methods in org.apache.cassandra.streaming.messages with parameters of type DataInputPlus

Modifier and Type	Method	Description
static StreamMessage	StreamMessage.deserialize(DataInputPlus in, int version)
V	StreamMessage.Serializer.deserialize(DataInputPlus in, int version)
StreamMessageHeader	StreamMessageHeader.FileMessageHeaderSerializer.deserialize(DataInputPlus in, int version)

Uses of DataInputPlus in org.apache.cassandra.utils

Methods in org.apache.cassandra.utils with parameters of type DataInputPlus

Modifier and Type	Method	Description
Boolean	BooleanSerializer.deserialize(DataInputPlus in, int version)
EstimatedHistogram	EstimatedHistogram.EstimatedHistogramSerializer.deserialize(DataInputPlus in)
Integer	Int32Serializer.deserialize(DataInputPlus in, int version)
Long	Int64Serializer.deserialize(DataInputPlus in, int version)
static MerkleTree	MerkleTree.deserialize(DataInputPlus in, boolean offHeapRequested, int version)
static MerkleTree	MerkleTree.deserialize(DataInputPlus in, int version)
MerkleTrees	MerkleTrees.MerkleTreesSerializer.deserialize(DataInputPlus in, int version)
Collection<Range<Token>>	RangesSerializer.deserialize(DataInputPlus in, int version)
TimeUUID	TimeUUID.Serializer.deserialize(DataInputPlus in, int version)
UUID	UUIDSerializer.deserialize(DataInputPlus in, int version)
Void	VoidSerializer.deserialize(DataInputPlus in, int version)
static <V, C extends Collection<? super V>> C	CollectionSerializer.deserializeCollection(IVersionedSerializer<V> serializer, IntFunction<C> factory, DataInputPlus in, int version)
static <K, V, M extends Map<K, V>> M	CollectionSerializer.deserializeMap(IVersionedSerializer<K> keySerializer, IVersionedSerializer<V> valueSerializer, IntFunction<M> factory, DataInputPlus in, int version)
static <T> T	NullableSerializer.deserializeNullable(IVersionedSerializer<T> serializer, DataInputPlus in, int version)
static byte[]	ByteArrayUtil.readWithVIntLength(DataInputPlus in)
static ByteBuffer	ByteBufferUtil.readWithVIntLength(DataInputPlus in)
static void	ByteBufferUtil.skipShortLength(DataInputPlus in)
static void	ByteBufferUtil.skipWithVIntLength(DataInputPlus in)

Uses of DataInputPlus in org.apache.cassandra.utils.streamhist

Methods in org.apache.cassandra.utils.streamhist with parameters of type DataInputPlus

Modifier and Type	Method	Description
TombstoneHistogram	TombstoneHistogram.HistogramSerializer.deserialize(DataInputPlus in)
TombstoneHistogram	TombstoneHistogram.LegacyHistogramSerializer.deserialize(DataInputPlus in)

Uses of DataInputPlus in org.apache.cassandra.utils.vint

Methods in org.apache.cassandra.utils.vint with parameters of type DataInputPlus

Modifier and Type	Method	Description
static void	VIntCoding.skipUnsignedVInt(DataInputPlus input)