Package io.deephaven.extensions.barrage.chunk

Class BaseChunkWriter.BulkIntWriter

java.lang.Object

io.deephaven.extensions.barrage.chunk.BaseChunkWriter.BulkIntWriter

All Implemented Interfaces:

SafeCloseable, AutoCloseable

Enclosing class:

BaseChunkWriter<SOURCE_CHUNK_TYPE extends Chunk<Values>>

protected static final class BaseChunkWriter.BulkIntWriter
extends Object
implements SafeCloseable

Buffers little-endian int values — an Arrow offset or lengths buffer — and flushes them in windows of BaseChunkWriter.BULK_WRITE_BUFFER_BYTES, rather than making one DataOutput call, i.e. four individual byte writes, per value.

Constructor Summary

Constructors

Constructor	Description
BulkIntWriter(@NotNull OutputStream outputStream)

Method Summary

Modifier and Type	Method	Description
void	close()
void	write(int value)

Methods inherited from class java.lang.Object

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

Constructor Details

BulkIntWriter

public BulkIntWriter(@NotNull
 @NotNull OutputStream outputStream)

Method Details

write

public void write(int value)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable