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 voidBatch.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 voidAutoSavingCache.CacheSerializer. serialize(K key, DataOutputPlus out, ColumnFamilyStore cfs)voidSerializingCacheProvider.RowCacheSerializer. serialize(IRowCacheEntry entry, DataOutputPlus out)voidCounterCacheKey. write(DataOutputPlus out) -
Uses of DataOutputPlus in org.apache.cassandra.cql3.selection
Methods in org.apache.cassandra.cql3.selection with parameters of type DataOutputPlus Modifier and Type Method Description protected abstract voidSelector. serialize(DataOutputPlus out, int version)voidSelector.Serializer. serialize(Selector selector, DataOutputPlus out, int version)protected voidSimpleSelector. serialize(DataOutputPlus out, int version)protected voidTermSelector. serialize(DataOutputPlus out, int version)protected static voidSelector. writeType(DataOutputPlus out, AbstractType<?> type) -
Uses of DataOutputPlus in org.apache.cassandra.db
Methods in org.apache.cassandra.db with parameters of type DataOutputPlus Modifier and Type Method Description voidClustering.Serializer. serialize(Clustering<?> clustering, DataOutputPlus out, int version, java.util.List<AbstractType<?>> types)<T> voidClusteringBoundOrBoundary.Serializer. serialize(ClusteringBoundOrBoundary<T> bound, DataOutputPlus out, int version, java.util.List<AbstractType<?>> types)voidClusteringPrefix.Serializer. serialize(ClusteringPrefix<?> clustering, DataOutputPlus out, int version, java.util.List<AbstractType<?>> types)voidColumns.Serializer. serialize(Columns columns, DataOutputPlus out)voidCounterMutation.CounterMutationSerializer. serialize(CounterMutation cm, DataOutputPlus out, int version)voidDataRange.Serializer. serialize(DataRange range, DataOutputPlus out, int version, TableMetadata metadata)voidDeletionTime.Serializer. serialize(DeletionTime delTime, DataOutputPlus out)voidMutation.MutationSerializer. serialize(Mutation mutation, DataOutputPlus out, int version)voidPartitionPosition.RowPositionSerializer. serialize(PartitionPosition pos, DataOutputPlus out, int version)voidReadCommand.Serializer. serialize(ReadCommand command, DataOutputPlus out, int version)voidRowIndexEntry.IndexSerializer. serialize(RowIndexEntry<T> rie, DataOutputPlus out, java.nio.ByteBuffer indexInfo)voidRowIndexEntry. serialize(DataOutputPlus out, java.nio.ByteBuffer indexInfo)voidRowIndexEntry.Serializer. serialize(RowIndexEntry<IndexInfo> rie, DataOutputPlus out, java.nio.ByteBuffer indexInfo)voidSerializationHeader.Serializer. serialize(Version version, SerializationHeader.Component header, DataOutputPlus out)voidSlice.Serializer. serialize(Slice slice, DataOutputPlus out, int version, java.util.List<AbstractType<?>> types)voidSlices.Serializer. serialize(Slices slices, DataOutputPlus out, int version)voidTruncateResponse.TruncateResponseSerializer. serialize(TruncateResponse tr, DataOutputPlus out, int version)voidRowIndexEntry.IndexSerializer. serializeForCache(RowIndexEntry<T> rie, DataOutputPlus out)voidRowIndexEntry. serializeForCache(DataOutputPlus out)voidRowIndexEntry.Serializer. serializeForCache(RowIndexEntry<IndexInfo> rie, DataOutputPlus out)voidSerializationHeader.Serializer. serializeForMessaging(SerializationHeader header, ColumnFilter selection, DataOutputPlus out, boolean hasStatic)protected voidPartitionRangeReadCommand. serializeSelection(DataOutputPlus out, int version)protected abstract voidReadCommand. serializeSelection(DataOutputPlus out, int version)protected voidSinglePartitionReadCommand. serializeSelection(DataOutputPlus out, int version)voidColumns.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.voidSerializationHeader. writeDeletionTime(DeletionTime dt, DataOutputPlus out)voidSerializationHeader. writeLocalDeletionTime(int localDeletionTime, DataOutputPlus out)voidSerializationHeader. writeTimestamp(long timestamp, DataOutputPlus out)voidSerializationHeader. 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 voidAggregationSpecification.Serializer. serialize(AggregationSpecification aggregationSpec, DataOutputPlus out, int version)voidGroupingState.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 voidCommitLogPosition.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 voidClusteringIndexFilter.Serializer. serialize(ClusteringIndexFilter filter, DataOutputPlus out, int version)voidColumnFilter.Serializer. serialize(ColumnFilter selection, DataOutputPlus out, int version)voidColumnSubselection.Serializer. serialize(ColumnSubselection subSel, DataOutputPlus out, int version)voidDataLimits.Serializer. serialize(DataLimits limits, DataOutputPlus out, int version, ClusteringComparator comparator)voidRowFilter.Serializer. serialize(RowFilter filter, DataOutputPlus out, int version)protected abstract voidRowFilter.UserExpression. serialize(DataOutputPlus out, int version)protected abstract voidAbstractClusteringIndexFilter. serializeInternal(DataOutputPlus out, int version)protected voidClusteringIndexNamesFilter. serializeInternal(DataOutputPlus out, int version)protected voidClusteringIndexSliceFilter. 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 voidByteArrayAccessor. write(byte[] value, DataOutputPlus out)voidByteBufferAccessor. write(java.nio.ByteBuffer value, DataOutputPlus out)voidValueAccessor. write(V value, DataOutputPlus out)Write the contents of the given value into the a DataOutputPlusvoidAbstractType. writeValue(java.nio.ByteBuffer value, DataOutputPlus out)<V> voidAbstractType. writeValue(V value, ValueAccessor<V> accessor, DataOutputPlus out)voidEmptyType. writeValue(java.nio.ByteBuffer value, DataOutputPlus out)default voidValueAccessor. 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 voidPartitionUpdate.PartitionUpdateSerializer. serialize(PartitionUpdate update, DataOutputPlus out, int version)voidUnfilteredPartitionIterators.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 voidCellPath.Serializer. serialize(CellPath path, DataOutputPlus out)voidEncodingStats.Serializer. serialize(EncodingStats stats, DataOutputPlus out)voidUnfilteredRowIteratorSerializer. serialize(UnfilteredRowIterator iterator, ColumnFilter selection, DataOutputPlus out, int version)voidUnfilteredRowIteratorSerializer. serialize(UnfilteredRowIterator iterator, ColumnFilter selection, DataOutputPlus out, int version, int rowEstimate)voidUnfilteredSerializer. serialize(Unfiltered unfiltered, SerializationHelper helper, DataOutputPlus out, int version)voidUnfilteredSerializer. serialize(Unfiltered unfiltered, SerializationHelper helper, DataOutputPlus out, long previousUnfilteredSize, int version)voidUnfilteredSerializer. serializeStaticRow(Row row, SerializationHelper helper, DataOutputPlus out, int version)voidUnfilteredSerializer. 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 voidCassandraStreamHeader.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 voidAbstractBounds.AbstractBoundsSerializer. serialize(AbstractBounds<T> range, DataOutputPlus out, int version)voidIPartitionerDependentSerializer. serialize(T t, DataOutputPlus out, int version)Serialize the specified type into the specified DataOutputStream instance.voidToken.TokenFactory. serialize(Token token, DataOutputPlus out)voidToken.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 voidRequestFailureReason.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 voidHintMessage.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 voidAbstractTokenTreeBuilder. flushBuffer(java.nio.ByteBuffer buffer, DataOutputPlus o, boolean align)voidAbstractTokenTreeBuilder. write(DataOutputPlus out)voidStaticTokenTreeBuilder. write(DataOutputPlus out)voidTokenTreeBuilder. 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 voidISerializer. serialize(T t, DataOutputPlus out)Serialize the specified type into the specified DataOutput instance.voidIVersionedAsymmetricSerializer. 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 classCompressedSequentialWriter -
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 voidIndexInfo.Serializer. serialize(IndexInfo info, DataOutputPlus out)voidIndexSummary.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 voidCompactionMetadata.CompactionMetadataSerializer. serialize(Version version, CompactionMetadata component, DataOutputPlus out)voidIMetadataComponentSerializer. serialize(Version version, T component, DataOutputPlus out)Serialize metadata component to given output.voidIMetadataSerializer. serialize(java.util.Map<MetadataType,MetadataComponent> components, DataOutputPlus out, Version version)Serialize given metadata componentsvoidMetadataSerializer. serialize(java.util.Map<MetadataType,MetadataComponent> components, DataOutputPlus out, Version version)voidStatsMetadata.StatsMetadataSerializer. serialize(Version version, StatsMetadata component, DataOutputPlus out)voidValidationMetadata.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 classBufferedDataOutputStreamPlusAn implementation of the DataOutputStreamPlus interface using a ByteBuffer to stage writes before flushing them to an underlying channel.classChecksummedSequentialWriterclassDataOutputBufferAn implementation of the DataOutputStream interface using a FastByteArrayOutputStream and exposing its buffer so copies can be avoided.classDataOutputBufferFixedAn implementation of the DataOutputStream interface using a FastByteArrayOutputStream and exposing its buffer so copies can be avoided.classDataOutputStreamPlusAbstract base class for DataOutputStreams that accept writes from ByteBuffer or Memory and also provide access to the underlying WritableByteChannel associated with their output stream.classFileOutputStreamPlusclassSafeMemoryWriterclassSequentialWriterAdds buffering, mark, and fsyncing to OutputStream.classUnbufferedDataOutputStreamPlusBase class for DataOutput implementations that does not have an optimized implementations of Plus methods and does no buffering.classWrappedDataOutputStreamPlusWhen possible useWrappedDataOutputStreamPlusinstead 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 voidInetAddressAndPort.FwdFrmSerializer. serialize(InetAddressAndPort endpoint, DataOutputPlus out, int version)voidInetAddressAndPort.Serializer. serialize(java.net.InetSocketAddress endpoint, DataOutputPlus out, int version)voidInetAddressAndPort.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 classAsyncChannelOutputPlusADataOutputStreamPlusthat writes ASYNCHRONOUSLY to a Netty Channel.classAsyncMessageOutputPlusADataOutputStreamPlusthat writes ASYNCHRONOUSLY to a Netty Channel.classAsyncStreamingOutputPlusADataOutputStreamPlusthat writes ASYNCHRONOUSLY to a Netty Channel.Methods in org.apache.cassandra.net with parameters of type DataOutputPlus Modifier and Type Method Description <T> voidMessage.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 voidSyncNodePair.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 voidIndexMetadata.Serializer. serialize(IndexMetadata metadata, DataOutputPlus out, int version)voidSchemaMutationsSerializer. 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 voidCacheService.CounterCacheSerializer. serialize(CounterCacheKey key, DataOutputPlus out, ColumnFamilyStore cfs)voidCacheService.KeyCacheSerializer. serialize(KeyCacheKey key, DataOutputPlus out, ColumnFamilyStore cfs)voidCacheService.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 voidBallot.Serializer. serialize(Ballot t, DataOutputPlus out, int version)voidCommit.CommitSerializer. serialize(T commit, DataOutputPlus out, int version)voidPaxosCommitAndPrepare.RequestSerializer. serialize(org.apache.cassandra.service.paxos.PaxosCommitAndPrepare.Request request, DataOutputPlus out, int version)voidPaxosPrepare.ResponseSerializer. serialize(org.apache.cassandra.service.paxos.PaxosPrepare.Response response, DataOutputPlus out, int version)voidPaxosPrepareRefresh.RequestSerializer. serialize(org.apache.cassandra.service.paxos.PaxosPrepareRefresh.Request request, DataOutputPlus out, int version)voidPaxosPrepareRefresh.ResponseSerializer. serialize(org.apache.cassandra.service.paxos.PaxosPrepareRefresh.Response response, DataOutputPlus out, int version)voidPaxosPropose.RequestSerializer. serialize(org.apache.cassandra.service.paxos.PaxosPropose.Request request, DataOutputPlus out, int version)voidPaxosPropose.ResponseSerializer. serialize(org.apache.cassandra.service.paxos.PaxosPropose.Response response, DataOutputPlus out, int version)voidPaxosRepair.RequestSerializer. serialize(org.apache.cassandra.service.paxos.PaxosRepair.Request request, DataOutputPlus out, int version)voidPaxosRepair.ResponseSerializer. serialize(org.apache.cassandra.service.paxos.PaxosRepair.Response response, DataOutputPlus out, int version)voidPrepareResponse.PrepareResponseSerializer. serialize(PrepareResponse response, DataOutputPlus out, int version) -
Uses of DataOutputPlus in org.apache.cassandra.service.paxos.cleanup
Methods in org.apache.cassandra.service.paxos.cleanup with parameters of type DataOutputPlus Modifier and Type Method Description voidPaxosStartPrepareCleanup.RequestSerializer. serialize(PaxosStartPrepareCleanup.Request request, DataOutputPlus out, int version) -
Uses of DataOutputPlus in org.apache.cassandra.streaming
Subinterfaces of DataOutputPlus in org.apache.cassandra.streaming Modifier and Type Interface Description interfaceStreamingDataOutputPlusClasses in org.apache.cassandra.streaming that implement DataOutputPlus Modifier and Type Class Description classStreamingDataOutputPlusFixedMethods in org.apache.cassandra.streaming with parameters of type DataOutputPlus Modifier and Type Method Description voidStreamRequest.StreamRequestSerializer. serialize(StreamRequest request, DataOutputPlus out, int version)voidStreamSummary.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 voidStreamMessageHeader.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 voidBloomFilterSerializer. serialize(BloomFilter bf, DataOutputPlus out)voidBooleanSerializer. serialize(java.lang.Boolean b, DataOutputPlus out, int version)voidEstimatedHistogram.EstimatedHistogramSerializer. serialize(EstimatedHistogram eh, DataOutputPlus out)voidInt32Serializer. serialize(java.lang.Integer t, DataOutputPlus out, int version)voidInt64Serializer. serialize(java.lang.Long t, DataOutputPlus out, int version)voidIntervalTree.Serializer. serialize(IntervalTree<C,D,I> it, DataOutputPlus out, int version)voidMerkleTree. serialize(DataOutputPlus out, int version)voidMerkleTrees.MerkleTreesSerializer. serialize(MerkleTrees trees, DataOutputPlus out, int version)voidTimeUUID.Serializer. serialize(TimeUUID t, DataOutputPlus out, int version)voidUUIDSerializer. serialize(java.util.UUID uuid, DataOutputPlus out, int version)voidVoidSerializer. serialize(java.lang.Void v, DataOutputPlus out, int version)static <V> voidCollectionSerializer. serializeCollection(IVersionedSerializer<V> valueSerializer, java.util.Collection<V> values, DataOutputPlus out, int version)static <V,L extends java.util.List<V> & java.util.RandomAccess>
voidCollectionSerializer. serializeList(IVersionedSerializer<V> valueSerializer, L values, DataOutputPlus out, int version)static <K,V>
voidCollectionSerializer. serializeMap(IVersionedSerializer<K> keySerializer, IVersionedSerializer<V> valueSerializer, java.util.Map<K,V> map, DataOutputPlus out, int version)static <T> voidNullableSerializer. serializeNullable(IVersionedSerializer<T> serializer, T value, DataOutputPlus out, int version)static voidByteBufferUtil. writeWithLength(java.nio.ByteBuffer bytes, DataOutputPlus out)static voidByteBufferUtil. writeWithShortLength(java.nio.ByteBuffer buffer, DataOutputPlus out)static voidByteArrayUtil. writeWithVIntLength(byte[] bytes, DataOutputPlus out)static voidByteBufferUtil. 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 voidIBitSet. serialize(DataOutputPlus out)voidOffHeapBitSet. serialize(DataOutputPlus out)voidOffHeapBitSet. 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 voidTombstoneHistogram.HistogramSerializer. serialize(TombstoneHistogram histogram, DataOutputPlus out) -
Uses of DataOutputPlus in org.apache.cassandra.utils.vint
Methods in org.apache.cassandra.utils.vint with parameters of type DataOutputPlus Modifier and Type Method Description static voidVIntCoding. writeUnsignedVInt(long value, DataOutputPlus output)static voidVIntCoding. writeVInt(long value, DataOutputPlus output)
-