org.apache.spark.storage

Class ReadableChannelFileRegion

Object

io.netty.util.AbstractReferenceCounted

org.apache.spark.storage.ReadableChannelFileRegion

All Implemented Interfaces:

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

public class ReadableChannelFileRegion
extends io.netty.util.AbstractReferenceCounted
implements io.netty.channel.FileRegion

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	transfered()
long	transferTo(java.nio.channels.WritableByteChannel target, long pos)

Methods inherited from class io.netty.util.AbstractReferenceCounted

refCnt, release, release, retain, retain

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, retain, retain

Constructor Detail

ReadableChannelFileRegion

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

Method Detail

count

public long count()

Specified by:

count in interface io.netty.channel.FileRegion

position

public long position()

Specified by:

position in interface io.netty.channel.FileRegion

transfered

public long transfered()

Specified by:

transfered in interface io.netty.channel.FileRegion

transferTo

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

Specified by:

transferTo in interface io.netty.channel.FileRegion

deallocate

public void deallocate()

Specified by:

deallocate in class io.netty.util.AbstractReferenceCounted