Package org.apache.lucene.store
Class ByteBuffersDataOutput
- java.lang.Object
-
- org.apache.lucene.store.DataOutput
-
- org.apache.lucene.store.ByteBuffersDataOutput
-
- All Implemented Interfaces:
Accountable
public final class ByteBuffersDataOutput extends DataOutput implements Accountable
ADataOutputstoring data in a list ofByteBuffers.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classByteBuffersDataOutput.ByteBufferRecyclerAn implementation of aByteBufferallocation and recycling policy.
-
Field Summary
Fields Modifier and Type Field Description static IntFunction<ByteBuffer>ALLOCATE_BB_ON_HEAPstatic intDEFAULT_MAX_BITS_PER_BLOCKstatic intDEFAULT_MIN_BITS_PER_BLOCKstatic Consumer<ByteBuffer>NO_REUSEA singleton instance of "no-reuse" buffer strategy.
-
Constructor Summary
Constructors Constructor Description ByteBuffersDataOutput()ByteBuffersDataOutput(int minBitsPerBlock, int maxBitsPerBlock, IntFunction<ByteBuffer> blockAllocate, Consumer<ByteBuffer> blockReuse)ByteBuffersDataOutput(long expectedSize)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcopyTo(DataOutput output)Copy the current content of this object into anotherDataOutput.static ByteBuffersDataOutputnewResettableInstance()longramBytesUsed()Return the memory usage of this object in bytes.voidreset()This method resets this object to a clean (zero-size) state and publishes any currently allocated buffers for reuse to the reuse strategy provided in the constructor.longsize()byte[]toArrayCopy()Return a contiguous array with the current content written to the output.ArrayList<ByteBuffer>toBufferList()Return a list of read-only view ofByteBufferblocks over the current content written to the output.ByteBuffersDataInputtoDataInput()Return aByteBuffersDataInputfor the set of current buffers (toBufferList()).StringtoString()ArrayList<ByteBuffer>toWriteableBufferList()Returns a list of writeable blocks over the (source) content buffers.voidwriteByte(byte b)Writes a single byte.voidwriteBytes(byte[] b)voidwriteBytes(byte[] b, int length)Writes an array of bytes.voidwriteBytes(byte[] src, int offset, int length)Writes an array of bytes.voidwriteBytes(ByteBuffer buffer)voidwriteInt(int v)Writes an int as four bytes.voidwriteLong(long v)Writes a long as eight bytes.voidwriteMapOfStrings(Map<String,String> map)Writes a String map.voidwriteSetOfStrings(Set<String> set)Writes a String set.voidwriteShort(short v)Writes a short as two bytes.voidwriteString(String v)Writes a string.-
Methods inherited from class org.apache.lucene.store.DataOutput
copyBytes, writeVInt, writeVLong, writeZInt, writeZLong
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.lucene.util.Accountable
getChildResources
-
-
-
-
Field Detail
-
ALLOCATE_BB_ON_HEAP
public static final IntFunction<ByteBuffer> ALLOCATE_BB_ON_HEAP
-
NO_REUSE
public static final Consumer<ByteBuffer> NO_REUSE
A singleton instance of "no-reuse" buffer strategy.
-
DEFAULT_MIN_BITS_PER_BLOCK
public static final int DEFAULT_MIN_BITS_PER_BLOCK
- See Also:
- Constant Field Values
-
DEFAULT_MAX_BITS_PER_BLOCK
public static final int DEFAULT_MAX_BITS_PER_BLOCK
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
ByteBuffersDataOutput
public ByteBuffersDataOutput(long expectedSize)
-
ByteBuffersDataOutput
public ByteBuffersDataOutput()
-
ByteBuffersDataOutput
public ByteBuffersDataOutput(int minBitsPerBlock, int maxBitsPerBlock, IntFunction<ByteBuffer> blockAllocate, Consumer<ByteBuffer> blockReuse)
-
-
Method Detail
-
writeByte
public void writeByte(byte b)
Description copied from class:DataOutputWrites a single byte.The most primitive data type is an eight-bit byte. Files are accessed as sequences of bytes. All other data types are defined as sequences of bytes, so file formats are byte-order independent.
- Specified by:
writeBytein classDataOutput- See Also:
DataInput.readByte()
-
writeBytes
public void writeBytes(byte[] src, int offset, int length)Description copied from class:DataOutputWrites an array of bytes.- Specified by:
writeBytesin classDataOutput- Parameters:
src- the bytes to writeoffset- the offset in the byte arraylength- the number of bytes to write- See Also:
DataInput.readBytes(byte[],int,int)
-
writeBytes
public void writeBytes(byte[] b, int length)Description copied from class:DataOutputWrites an array of bytes.- Overrides:
writeBytesin classDataOutput- Parameters:
b- the bytes to writelength- the number of bytes to write- See Also:
DataInput.readBytes(byte[],int,int)
-
writeBytes
public void writeBytes(byte[] b)
-
writeBytes
public void writeBytes(ByteBuffer buffer)
-
toBufferList
public ArrayList<ByteBuffer> toBufferList()
Return a list of read-only view ofByteBufferblocks over the current content written to the output.
-
toWriteableBufferList
public ArrayList<ByteBuffer> toWriteableBufferList()
Returns a list of writeable blocks over the (source) content buffers. This method returns the raw content of source buffers that may change over the lifetime of this object (blocks can be recycled or discarded, for example). Most applications should favor callingtoBufferList()which returns a read-only view over the content of the source buffers. The difference betweentoBufferList()andtoWriteableBufferList()is that read-only view of source buffers will always returnfalsefromByteBuffer.hasArray()(which sometimes may be required to avoid double copying).
-
toDataInput
public ByteBuffersDataInput toDataInput()
Return aByteBuffersDataInputfor the set of current buffers (toBufferList()).
-
toArrayCopy
public byte[] toArrayCopy()
Return a contiguous array with the current content written to the output. The returned array is always a copy (can be mutated). If thesize()of the underlying buffers exceeds maximum size of Java array, anRuntimeExceptionwill be thrown.
-
copyTo
public void copyTo(DataOutput output) throws IOException
Copy the current content of this object into anotherDataOutput.- Throws:
IOException
-
size
public long size()
- Returns:
- The number of bytes written to this output so far.
-
writeShort
public void writeShort(short v)
Description copied from class:DataOutputWrites a short as two bytes.- Overrides:
writeShortin classDataOutput- See Also:
DataInput.readShort()
-
writeInt
public void writeInt(int v)
Description copied from class:DataOutputWrites an int as four bytes.32-bit unsigned integer written as four bytes, high-order bytes first.
- Overrides:
writeIntin classDataOutput- See Also:
DataInput.readInt()
-
writeLong
public void writeLong(long v)
Description copied from class:DataOutputWrites a long as eight bytes.64-bit unsigned integer written as eight bytes, high-order bytes first.
- Overrides:
writeLongin classDataOutput- See Also:
DataInput.readLong()
-
writeString
public void writeString(String v)
Description copied from class:DataOutputWrites a string.Writes strings as UTF-8 encoded bytes. First the length, in bytes, is written as a
VInt, followed by the bytes.- Overrides:
writeStringin classDataOutput- See Also:
DataInput.readString()
-
writeMapOfStrings
public void writeMapOfStrings(Map<String,String> map)
Description copied from class:DataOutputWrites a String map.First the size is written as an
vInt, followed by each key-value pair written as two consecutiveStrings.- Overrides:
writeMapOfStringsin classDataOutput- Parameters:
map- Input map.
-
writeSetOfStrings
public void writeSetOfStrings(Set<String> set)
Description copied from class:DataOutputWrites a String set.First the size is written as an
vInt, followed by each value written as aString.- Overrides:
writeSetOfStringsin classDataOutput- Parameters:
set- Input set.
-
ramBytesUsed
public long ramBytesUsed()
Description copied from interface:AccountableReturn the memory usage of this object in bytes. Negative values are illegal.- Specified by:
ramBytesUsedin interfaceAccountable
-
reset
public void reset()
This method resets this object to a clean (zero-size) state and publishes any currently allocated buffers for reuse to the reuse strategy provided in the constructor. Sharing byte buffers for reads and writes is dangerous and will very likely lead to hard-to-debug issues, use with great care.
-
newResettableInstance
public static ByteBuffersDataOutput newResettableInstance()
- Returns:
- Returns a new
ByteBuffersDataOutputwith thereset()capability.
-
-