org.apache.paimon.disk

Class ChannelWriterOutputView

java.lang.Object

org.apache.paimon.data.AbstractPagedOutputView

org.apache.paimon.disk.ChannelWriterOutputView

All Implemented Interfaces:

Closeable, DataOutput, AutoCloseable, DataOutputView, MemorySegmentWritable

public final class ChannelWriterOutputView
extends AbstractPagedOutputView
implements Closeable

A DataOutputView that is backed by a FileIOChannel, making it effectively a data output stream. The view will compress its data before writing it in blocks to the underlying channel.

Field Summary

Fields inherited from class org.apache.paimon.data.AbstractPagedOutputView

currentSegment, segmentSize

Constructor Summary

Constructors

Constructor and Description
ChannelWriterOutputView(BufferFileWriter writer, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize)

Method Summary

Modifier and Type	Method and Description
void	close()
void	closeAndDelete()
int	getBlockCount()
FileIOChannel	getChannel()
long	getNumBytes()
long	getNumCompressedBytes()
long	getWriteBytes()
protected MemorySegment	nextSegment(MemorySegment current, int positionInCurrent) This method must return a segment.

Methods inherited from class org.apache.paimon.data.AbstractPagedOutputView

advance, clear, getCurrentPositionInSegment, getCurrentSegment, getSegmentSize, seekOutput, skipBytesToWrite, write, write, write, write, write, writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeShort, writeUTF

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelWriterOutputView

public ChannelWriterOutputView(BufferFileWriter writer,
                               BlockCompressionFactory compressionCodecFactory,
                               int compressionBlockSize)

Method Detail

getChannel

public FileIOChannel getChannel()

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

closeAndDelete

public void closeAndDelete()
                    throws IOException

Throws:

IOException

nextSegment

protected MemorySegment nextSegment(MemorySegment current,
                                    int positionInCurrent)
                             throws IOException

Description copied from class: AbstractPagedOutputView

This method must return a segment. If no more segments are available, it must throw an EOFException.

Specified by:

nextSegment in class AbstractPagedOutputView

Parameters:

current - The current memory segment

positionInCurrent - The position in the segment, one after the last valid byte.

Returns:

The next memory segment.

Throws:

IOException

getNumBytes

public long getNumBytes()

getNumCompressedBytes

public long getNumCompressedBytes()

getWriteBytes

public long getWriteBytes()

getBlockCount

public int getBlockCount()