Uses of Class
org.apache.cassandra.io.util.ChannelProxy
Packages that use ChannelProxy
Package
Description
File transfer
Hints subsystem consists of several components.
-
Uses of ChannelProxy in org.apache.cassandra.db.streaming
Methods in org.apache.cassandra.db.streaming with parameters of type ChannelProxyModifier and TypeMethodDescriptionprotected longCassandraStreamWriter.write(ChannelProxy proxy, DataIntegrityMetadata.ChecksumValidator validator, StreamingDataOutputPlus output, long start, int transferOffset, int toTransfer, int bufferSize) Sequentially read bytes from the file and write them to the output stream -
Uses of ChannelProxy in org.apache.cassandra.hints
Fields in org.apache.cassandra.hints declared as ChannelProxyMethods in org.apache.cassandra.hints that return ChannelProxyConstructors in org.apache.cassandra.hints with parameters of type ChannelProxyModifierConstructorDescriptionCompressedChecksummedDataInput(ChannelProxy channel, ICompressor compressor, long filePosition) protectedEncryptedChecksummedDataInput(ChannelProxy channel, Cipher cipher, ICompressor compressor, long filePosition) -
Uses of ChannelProxy in org.apache.cassandra.index.sasi.utils
Constructors in org.apache.cassandra.index.sasi.utils with parameters of type ChannelProxyModifierConstructorDescriptionMappedBuffer(ChannelProxy file) protectedMappedBuffer(ChannelProxy file, int numPageBits) -
Uses of ChannelProxy in org.apache.cassandra.io.sstable.format
Methods in org.apache.cassandra.io.sstable.format that return ChannelProxy -
Uses of ChannelProxy in org.apache.cassandra.io.util
Fields in org.apache.cassandra.io.util declared as ChannelProxyModifier and TypeFieldDescriptionprotected final ChannelProxyAbstractReaderFileProxy.channelfinal ChannelProxyFileHandle.channelMethods in org.apache.cassandra.io.util that return ChannelProxyModifier and TypeMethodDescriptionAbstractReaderFileProxy.channel()BufferManagingRebufferer.channel()EmptyRebufferer.channel()ReaderFileProxy.channel()WrappingRebufferer.channel()RandomAccessReader.getChannel()final ChannelProxyChannelProxy.newChannel()sharedCopy()can not be used if thread will be interruped, as the backing channel will be closed.ChannelProxy.sharedCopy()Methods in org.apache.cassandra.io.util with parameters of type ChannelProxyModifier and TypeMethodDescriptionstatic MmappedRegionsMmappedRegions.empty(ChannelProxy channel) MmappedRegionsCache.getOrCreate(ChannelProxy channel, long length, int bufferSize) Looks for mmapped regions in cache.MmappedRegionsCache.getOrCreate(ChannelProxy channel, CompressionMetadata metadata, int bufferSize) Looks for mmapped regions in cache.booleanMmappedRegions.isValid(ChannelProxy channel) static MmappedRegionsMmappedRegions.map(ChannelProxy channel, long length, int chunkSize) static MmappedRegionsMmappedRegions.map(ChannelProxy channel, CompressionMetadata metadata) Method parameters in org.apache.cassandra.io.util with type arguments of type ChannelProxyModifier and TypeMethodDescriptionFileHandle.Builder.complete(Function<File, ChannelProxy> channelProxyFactory) Constructors in org.apache.cassandra.io.util with parameters of type ChannelProxyModifierConstructorDescriptionprotectedAbstractReaderFileProxy(ChannelProxy channel, long fileLength) ChannelProxy(ChannelProxy copy) protectedCompressedChunkReader(ChannelProxy channel, CompressionMetadata metadata, Supplier<Double> crcCheckChanceSupplier) EmptyRebufferer(ChannelProxy channel) Mmap(ChannelProxy channel, CompressionMetadata metadata, MmappedRegions regions, Supplier<Double> crcCheckChanceSupplier) Standard(ChannelProxy channel, CompressionMetadata metadata, Supplier<Double> crcCheckChanceSupplier) ThreadLocalReadAheadBuffer(ChannelProxy channel, int bufferSize, BufferType bufferType) -
Uses of ChannelProxy in org.apache.cassandra.security
Constructors in org.apache.cassandra.security with parameters of type ChannelProxyModifierConstructorDescriptionChannelProxyReadChannel(ChannelProxy channelProxy, long currentPosition)