org.apache.spark.storage

Class ReadableChannelFileRegion

Object

io.netty.util.AbstractReferenceCounted

org.apache.spark.network.util.AbstractFileRegion

org.apache.spark.storage.ReadableChannelFileRegion

All Implemented Interfaces:

io.netty.channel.FileRegion, io.netty.util.ReferenceCounted

public class ReadableChannelFileRegion
extends org.apache.spark.network.util.AbstractFileRegion

Constructor Summary

Constructors

Constructor and Description
ReadableChannelFileRegion(java.nio.channels.ReadableByteChannel source, long blockSize)

Method Summary

Modifier and Type	Method and Description
long	count()
void	deallocate()
long	position()
long	transferred()
long	transferTo(java.nio.channels.WritableByteChannel target, long pos)

Methods inherited from class org.apache.spark.network.util.AbstractFileRegion

retain, retain, touch, touch, transfered

Methods inherited from class io.netty.util.AbstractReferenceCounted

refCnt, release, release

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.netty.util.ReferenceCounted

refCnt, release, release

Constructor Detail

ReadableChannelFileRegion

public ReadableChannelFileRegion(java.nio.channels.ReadableByteChannel source,
                                 long blockSize)

Method Detail

count

public long count()

deallocate

public void deallocate()

Specified by:

deallocate in class io.netty.util.AbstractReferenceCounted

position

public long position()

transferTo

public long transferTo(java.nio.channels.WritableByteChannel target,
                       long pos)

transferred

public long transferred()