Uses of Interface
org.apache.cassandra.io.util.DataOutputPlus
-
-
Uses of DataOutputPlus in org.apache.cassandra.batchlog
Methods in org.apache.cassandra.batchlog with parameters of type DataOutputPlus Modifier and Type Method Description void
Batch.Serializer. serialize(Batch batch, DataOutputPlus out, int version)
-
Uses of DataOutputPlus in org.apache.cassandra.cache
Methods in org.apache.cassandra.cache with parameters of type DataOutputPlus Modifier and Type Method Description void
AutoSavingCache.CacheSerializer. serialize(K key, DataOutputPlus out, ColumnFamilyStore cfs)
void
SerializingCacheProvider.RowCacheSerializer. serialize(IRowCacheEntry entry, DataOutputPlus out)
void
CounterCacheKey. write(DataOutputPlus out)
-
Uses of DataOutputPlus in org.apache.cassandra.db
Methods in org.apache.cassandra.db with parameters of type DataOutputPlus Modifier and Type Method Description void
Clustering.Serializer. serialize(Clustering<?> clustering, DataOutputPlus out, int version, java.util.List<AbstractType<?>> types)
<T> void
ClusteringBoundOrBoundary.Serializer. serialize(ClusteringBoundOrBoundary<T> bound, DataOutputPlus out, int version, java.util.List<AbstractType<?>> types)
void
ClusteringPrefix.Serializer. serialize(ClusteringPrefix<?> clustering, DataOutputPlus out, int version, java.util.List<AbstractType<?>> types)
void
Columns.Serializer. serialize(Columns columns, DataOutputPlus out)
void
CounterMutation.CounterMutationSerializer. serialize(CounterMutation cm, DataOutputPlus out, int version)
void
DataRange.Serializer. serialize(DataRange range, DataOutputPlus out, int version, TableMetadata metadata)
void
DeletionTime.Serializer. serialize(DeletionTime delTime, DataOutputPlus out)
void
Mutation.MutationSerializer. serialize(Mutation mutation, DataOutputPlus out, int version)
void
PartitionPosition.RowPositionSerializer. serialize(PartitionPosition pos, DataOutputPlus out, int version)
void
ReadCommand.Serializer. serialize(ReadCommand command, DataOutputPlus out, int version)
void
RowIndexEntry.IndexSerializer. serialize(RowIndexEntry<T> rie, DataOutputPlus out, java.nio.ByteBuffer indexInfo)
void
RowIndexEntry. serialize(DataOutputPlus out, java.nio.ByteBuffer indexInfo)
void
RowIndexEntry.Serializer. serialize(RowIndexEntry<IndexInfo> rie, DataOutputPlus out, java.nio.ByteBuffer indexInfo)
void
SerializationHeader.Serializer. serialize(Version version, SerializationHeader.Component header, DataOutputPlus out)
void
Slice.Serializer. serialize(Slice slice, DataOutputPlus out, int version, java.util.List<AbstractType<?>> types)
void
Slices.Serializer. serialize(Slices slices, DataOutputPlus out, int version)
void
TruncateResponse.TruncateResponseSerializer. serialize(TruncateResponse tr, DataOutputPlus out, int version)
void
RowIndexEntry.IndexSerializer. serializeForCache(RowIndexEntry<T> rie, DataOutputPlus out)
void
RowIndexEntry. serializeForCache(DataOutputPlus out)
void
RowIndexEntry.Serializer. serializeForCache(RowIndexEntry<IndexInfo> rie, DataOutputPlus out)
void
SerializationHeader.Serializer. serializeForMessaging(SerializationHeader header, ColumnFilter selection, DataOutputPlus out, boolean hasStatic)
protected void
PartitionRangeReadCommand. serializeSelection(DataOutputPlus out, int version)
protected abstract void
ReadCommand. serializeSelection(DataOutputPlus out, int version)
protected void
SinglePartitionReadCommand. serializeSelection(DataOutputPlus out, int version)
void
Columns.Serializer. serializeSubset(java.util.Collection<ColumnMetadata> columns, Columns superset, DataOutputPlus out)
If both ends have a pre-shared superset of the columns we are serializing, we can send them much more efficiently.void
SerializationHeader. writeDeletionTime(DeletionTime dt, DataOutputPlus out)
void
SerializationHeader. writeLocalDeletionTime(int localDeletionTime, DataOutputPlus out)
void
SerializationHeader. writeTimestamp(long timestamp, DataOutputPlus out)
void
SerializationHeader. writeTTL(int ttl, DataOutputPlus out)
-
Uses of DataOutputPlus in org.apache.cassandra.db.aggregation
Methods in org.apache.cassandra.db.aggregation with parameters of type DataOutputPlus Modifier and Type Method Description void
AggregationSpecification.Serializer. serialize(AggregationSpecification aggregationSpec, DataOutputPlus out, int version)
void
GroupingState.Serializer. serialize(GroupingState state, DataOutputPlus out, int version, ClusteringComparator comparator)
-
Uses of DataOutputPlus in org.apache.cassandra.db.commitlog
Methods in org.apache.cassandra.db.commitlog with parameters of type DataOutputPlus Modifier and Type Method Description void
CommitLogPosition.CommitLogPositionSerializer. serialize(CommitLogPosition clsp, DataOutputPlus out)
-
Uses of DataOutputPlus in org.apache.cassandra.db.filter
Methods in org.apache.cassandra.db.filter with parameters of type DataOutputPlus Modifier and Type Method Description void
ClusteringIndexFilter.Serializer. serialize(ClusteringIndexFilter filter, DataOutputPlus out, int version)
void
ColumnFilter.Serializer. serialize(ColumnFilter selection, DataOutputPlus out, int version)
void
ColumnSubselection.Serializer. serialize(ColumnSubselection subSel, DataOutputPlus out, int version)
void
DataLimits.Serializer. serialize(DataLimits limits, DataOutputPlus out, int version, ClusteringComparator comparator)
void
RowFilter.Serializer. serialize(RowFilter filter, DataOutputPlus out, int version)
protected abstract void
RowFilter.UserExpression. serialize(DataOutputPlus out, int version)
protected abstract void
AbstractClusteringIndexFilter. serializeInternal(DataOutputPlus out, int version)
protected void
ClusteringIndexNamesFilter. serializeInternal(DataOutputPlus out, int version)
protected void
ClusteringIndexSliceFilter. serializeInternal(DataOutputPlus out, int version)
-
Uses of DataOutputPlus in org.apache.cassandra.db.marshal
Methods in org.apache.cassandra.db.marshal with parameters of type DataOutputPlus Modifier and Type Method Description void
ByteArrayAccessor. write(byte[] value, DataOutputPlus out)
void
ByteBufferAccessor. write(java.nio.ByteBuffer value, DataOutputPlus out)
void
ValueAccessor. write(V value, DataOutputPlus out)
Write the contents of the given value into the a DataOutputPlusvoid
AbstractType. writeValue(java.nio.ByteBuffer value, DataOutputPlus out)
<V> void
AbstractType. writeValue(V value, ValueAccessor<V> accessor, DataOutputPlus out)
void
EmptyType. writeValue(java.nio.ByteBuffer value, DataOutputPlus out)
default void
ValueAccessor. writeWithVIntLength(V value, DataOutputPlus out)
-
Uses of DataOutputPlus in org.apache.cassandra.db.partitions
Methods in org.apache.cassandra.db.partitions with parameters of type DataOutputPlus Modifier and Type Method Description void
PartitionUpdate.PartitionUpdateSerializer. serialize(PartitionUpdate update, DataOutputPlus out, int version)
void
UnfilteredPartitionIterators.Serializer. serialize(UnfilteredPartitionIterator iter, ColumnFilter selection, DataOutputPlus out, int version)
-
Uses of DataOutputPlus in org.apache.cassandra.db.rows
Methods in org.apache.cassandra.db.rows with parameters of type DataOutputPlus Modifier and Type Method Description void
CellPath.Serializer. serialize(CellPath path, DataOutputPlus out)
void
EncodingStats.Serializer. serialize(EncodingStats stats, DataOutputPlus out)
void
UnfilteredRowIteratorSerializer. serialize(UnfilteredRowIterator iterator, ColumnFilter selection, DataOutputPlus out, int version)
void
UnfilteredRowIteratorSerializer. serialize(UnfilteredRowIterator iterator, ColumnFilter selection, DataOutputPlus out, int version, int rowEstimate)
void
UnfilteredSerializer. serialize(Unfiltered unfiltered, SerializationHelper helper, DataOutputPlus out, int version)
void
UnfilteredSerializer. serialize(Unfiltered unfiltered, SerializationHelper helper, DataOutputPlus out, long previousUnfilteredSize, int version)
void
UnfilteredSerializer. serializeStaticRow(Row row, SerializationHelper helper, DataOutputPlus out, int version)
void
UnfilteredSerializer. writeEndOfPartition(DataOutputPlus out)
-
Uses of DataOutputPlus in org.apache.cassandra.db.streaming
Methods in org.apache.cassandra.db.streaming with parameters of type DataOutputPlus Modifier and Type Method Description void
CassandraStreamHeader.CassandraStreamHeaderSerializer. serialize(CassandraStreamHeader header, DataOutputPlus out, int version)
-
Uses of DataOutputPlus in org.apache.cassandra.dht
Methods in org.apache.cassandra.dht with parameters of type DataOutputPlus Modifier and Type Method Description void
AbstractBounds.AbstractBoundsSerializer. serialize(AbstractBounds<T> range, DataOutputPlus out, int version)
void
IPartitionerDependentSerializer. serialize(T t, DataOutputPlus out, int version)
Serialize the specified type into the specified DataOutputStream instance.void
Token.TokenFactory. serialize(Token token, DataOutputPlus out)
void
Token.TokenSerializer. serialize(Token token, DataOutputPlus out, int version)
-
Uses of DataOutputPlus in org.apache.cassandra.exceptions
Methods in org.apache.cassandra.exceptions with parameters of type DataOutputPlus Modifier and Type Method Description void
RequestFailureReason.Serializer. serialize(RequestFailureReason reason, DataOutputPlus out, int version)
-
Uses of DataOutputPlus in org.apache.cassandra.hints
Methods in org.apache.cassandra.hints with parameters of type DataOutputPlus Modifier and Type Method Description void
HintMessage.Serializer. serialize(SerializableHintMessage obj, DataOutputPlus out, int version)
-
Uses of DataOutputPlus in org.apache.cassandra.index.sasi.disk
Methods in org.apache.cassandra.index.sasi.disk with parameters of type DataOutputPlus Modifier and Type Method Description protected void
AbstractTokenTreeBuilder. flushBuffer(java.nio.ByteBuffer buffer, DataOutputPlus o, boolean align)
void
AbstractTokenTreeBuilder. write(DataOutputPlus out)
void
StaticTokenTreeBuilder. write(DataOutputPlus out)
void
TokenTreeBuilder. write(DataOutputPlus out)
-
Uses of DataOutputPlus in org.apache.cassandra.io
Methods in org.apache.cassandra.io with parameters of type DataOutputPlus Modifier and Type Method Description void
ISerializer. serialize(T t, DataOutputPlus out)
Serialize the specified type into the specified DataOutput instance.void
IVersionedAsymmetricSerializer. serialize(In t, DataOutputPlus out, int version)
Serialize the specified type into the specified DataOutputStream instance. -
Uses of DataOutputPlus in org.apache.cassandra.io.compress
Classes in org.apache.cassandra.io.compress that implement DataOutputPlus Modifier and Type Class Description class
CompressedSequentialWriter
-
Uses of DataOutputPlus in org.apache.cassandra.io.sstable
Methods in org.apache.cassandra.io.sstable with parameters of type DataOutputPlus Modifier and Type Method Description void
IndexInfo.Serializer. serialize(IndexInfo info, DataOutputPlus out)
void
IndexSummary.IndexSummarySerializer. serialize(IndexSummary t, DataOutputPlus out)
-
Uses of DataOutputPlus in org.apache.cassandra.io.sstable.metadata
Methods in org.apache.cassandra.io.sstable.metadata with parameters of type DataOutputPlus Modifier and Type Method Description void
CompactionMetadata.CompactionMetadataSerializer. serialize(Version version, CompactionMetadata component, DataOutputPlus out)
void
IMetadataComponentSerializer. serialize(Version version, T component, DataOutputPlus out)
Serialize metadata component to given output.void
IMetadataSerializer. serialize(java.util.Map<MetadataType,MetadataComponent> components, DataOutputPlus out, Version version)
Serialize given metadata componentsvoid
MetadataSerializer. serialize(java.util.Map<MetadataType,MetadataComponent> components, DataOutputPlus out, Version version)
void
StatsMetadata.StatsMetadataSerializer. serialize(Version version, StatsMetadata component, DataOutputPlus out)
void
ValidationMetadata.ValidationMetadataSerializer. serialize(Version version, ValidationMetadata component, DataOutputPlus out)
-
Uses of DataOutputPlus in org.apache.cassandra.io.util
Classes in org.apache.cassandra.io.util that implement DataOutputPlus Modifier and Type Class Description class
BufferedDataOutputStreamPlus
An implementation of the DataOutputStreamPlus interface using a ByteBuffer to stage writes before flushing them to an underlying channel.class
ChecksummedSequentialWriter
class
DataOutputBuffer
An implementation of the DataOutputStream interface using a FastByteArrayOutputStream and exposing its buffer so copies can be avoided.class
DataOutputBufferFixed
An implementation of the DataOutputStream interface using a FastByteArrayOutputStream and exposing its buffer so copies can be avoided.class
DataOutputStreamPlus
Abstract base class for DataOutputStreams that accept writes from ByteBuffer or Memory and also provide access to the underlying WritableByteChannel associated with their output stream.class
SafeMemoryWriter
class
SequentialWriter
Adds buffering, mark, and fsyncing to OutputStream.class
UnbufferedDataOutputStreamPlus
Base class for DataOutput implementations that does not have an optimized implementations of Plus methods and does no buffering.class
WrappedDataOutputStreamPlus
When possible useWrappedDataOutputStreamPlus
instead of this class, as it will be more efficient when using Plus methods. -
Uses of DataOutputPlus in org.apache.cassandra.locator
Methods in org.apache.cassandra.locator with parameters of type DataOutputPlus Modifier and Type Method Description void
InetAddressAndPort.FwdFrmSerializer. serialize(InetAddressAndPort endpoint, DataOutputPlus out, int version)
void
InetAddressAndPort.Serializer. serialize(InetAddressAndPort endpoint, DataOutputPlus out, int version)
-
Uses of DataOutputPlus in org.apache.cassandra.net
Classes in org.apache.cassandra.net that implement DataOutputPlus Modifier and Type Class Description class
AsyncChannelOutputPlus
ADataOutputStreamPlus
that writes ASYNCHRONOUSLY to a Netty Channel.class
AsyncMessageOutputPlus
ADataOutputStreamPlus
that writes ASYNCHRONOUSLY to a Netty Channel.class
AsyncStreamingOutputPlus
ADataOutputStreamPlus
that writes ASYNCHRONOUSLY to a Netty Channel.Methods in org.apache.cassandra.net with parameters of type DataOutputPlus Modifier and Type Method Description <T> void
Message.Serializer. serialize(Message<T> message, DataOutputPlus out, int version)
-
Uses of DataOutputPlus in org.apache.cassandra.repair
Methods in org.apache.cassandra.repair with parameters of type DataOutputPlus Modifier and Type Method Description void
SyncNodePair.NodePairSerializer. serialize(SyncNodePair nodePair, DataOutputPlus out, int version)
-
Uses of DataOutputPlus in org.apache.cassandra.schema
Methods in org.apache.cassandra.schema with parameters of type DataOutputPlus Modifier and Type Method Description void
IndexMetadata.Serializer. serialize(IndexMetadata metadata, DataOutputPlus out, int version)
void
MigrationManager.MigrationsSerializer. serialize(java.util.Collection<Mutation> schema, DataOutputPlus out, int version)
-
Uses of DataOutputPlus in org.apache.cassandra.service
Methods in org.apache.cassandra.service with parameters of type DataOutputPlus Modifier and Type Method Description void
CacheService.CounterCacheSerializer. serialize(CounterCacheKey key, DataOutputPlus out, ColumnFamilyStore cfs)
void
CacheService.KeyCacheSerializer. serialize(KeyCacheKey key, DataOutputPlus out, ColumnFamilyStore cfs)
void
CacheService.RowCacheSerializer. serialize(RowCacheKey key, DataOutputPlus out, ColumnFamilyStore cfs)
-
Uses of DataOutputPlus in org.apache.cassandra.service.paxos
Methods in org.apache.cassandra.service.paxos with parameters of type DataOutputPlus Modifier and Type Method Description void
Commit.CommitSerializer. serialize(Commit commit, DataOutputPlus out, int version)
void
PrepareResponse.PrepareResponseSerializer. serialize(PrepareResponse response, DataOutputPlus out, int version)
-
Uses of DataOutputPlus in org.apache.cassandra.streaming
Methods in org.apache.cassandra.streaming with parameters of type DataOutputPlus Modifier and Type Method Description void
StreamRequest.StreamRequestSerializer. serialize(StreamRequest request, DataOutputPlus out, int version)
void
StreamSummary.StreamSummarySerializer. serialize(StreamSummary summary, DataOutputPlus out, int version)
-
Uses of DataOutputPlus in org.apache.cassandra.streaming.messages
Methods in org.apache.cassandra.streaming.messages with parameters of type DataOutputPlus Modifier and Type Method Description void
StreamMessageHeader.FileMessageHeaderSerializer. serialize(StreamMessageHeader header, DataOutputPlus out, int version)
-
Uses of DataOutputPlus in org.apache.cassandra.utils
Methods in org.apache.cassandra.utils with parameters of type DataOutputPlus Modifier and Type Method Description static void
BloomFilterSerializer. serialize(BloomFilter bf, DataOutputPlus out)
void
BooleanSerializer. serialize(java.lang.Boolean b, DataOutputPlus out, int version)
void
EstimatedHistogram.EstimatedHistogramSerializer. serialize(EstimatedHistogram eh, DataOutputPlus out)
void
IntervalTree.Serializer. serialize(IntervalTree<C,D,I> it, DataOutputPlus out, int version)
void
MerkleTree. serialize(DataOutputPlus out, int version)
void
MerkleTrees.MerkleTreesSerializer. serialize(MerkleTrees trees, DataOutputPlus out, int version)
void
UUIDSerializer. serialize(java.util.UUID uuid, DataOutputPlus out, int version)
static void
ByteBufferUtil. writeWithLength(java.nio.ByteBuffer bytes, DataOutputPlus out)
static void
ByteBufferUtil. writeWithShortLength(java.nio.ByteBuffer buffer, DataOutputPlus out)
static void
ByteBufferUtil. writeWithVIntLength(java.nio.ByteBuffer bytes, DataOutputPlus out)
-
Uses of DataOutputPlus in org.apache.cassandra.utils.obs
Methods in org.apache.cassandra.utils.obs with parameters of type DataOutputPlus Modifier and Type Method Description void
IBitSet. serialize(DataOutputPlus out)
void
OffHeapBitSet. serialize(DataOutputPlus out)
void
OffHeapBitSet. serializeOldBfFormat(DataOutputPlus out)
-
Uses of DataOutputPlus in org.apache.cassandra.utils.streamhist
Methods in org.apache.cassandra.utils.streamhist with parameters of type DataOutputPlus Modifier and Type Method Description void
TombstoneHistogram.HistogramSerializer. serialize(TombstoneHistogram histogram, DataOutputPlus out)
-