public class ThrottledIndexOutput extends IndexOutput
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_MIN_WRITTEN_BYTES |
Constructor and Description |
---|
ThrottledIndexOutput(int bytesPerSecond,
long delayInMillis,
IndexOutput delegate) |
ThrottledIndexOutput(int bytesPerSecond,
long delays,
int minBytesWritten,
IndexOutput delegate) |
ThrottledIndexOutput(int bytesPerSecond,
long flushDelayMillis,
long closeDelayMillis,
long seekDelayMillis,
long minBytesWritten,
IndexOutput delegate) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes this stream to further operations.
|
void |
copyBytes(DataInput input,
long numBytes)
Copy numBytes bytes from input to ourself.
|
long |
getChecksum()
Returns the current checksum of bytes written so far
|
protected long |
getDelay(boolean closing) |
long |
getFilePointer()
Returns the current position in this file, where the next write will
occur.
|
static int |
mBitsToBytes(int mbits) |
ThrottledIndexOutput |
newFromDelegate(IndexOutput output) |
void |
writeByte(byte b)
Writes a single byte.
|
void |
writeBytes(byte[] b,
int offset,
int length)
Writes an array of bytes.
|
getName, toString
writeBytes, writeInt, writeLong, writeMapOfStrings, writeSetOfStrings, writeShort, writeString, writeVInt, writeVLong, writeZInt, writeZLong
public static final int DEFAULT_MIN_WRITTEN_BYTES
public ThrottledIndexOutput(int bytesPerSecond, long delayInMillis, IndexOutput delegate)
public ThrottledIndexOutput(int bytesPerSecond, long delays, int minBytesWritten, IndexOutput delegate)
public ThrottledIndexOutput(int bytesPerSecond, long flushDelayMillis, long closeDelayMillis, long seekDelayMillis, long minBytesWritten, IndexOutput delegate)
public ThrottledIndexOutput newFromDelegate(IndexOutput output)
public static final int mBitsToBytes(int mbits)
public void close() throws java.io.IOException
IndexOutput
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in class IndexOutput
java.io.IOException
public long getFilePointer()
IndexOutput
getFilePointer
in class IndexOutput
public void writeByte(byte b) throws java.io.IOException
DataOutput
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.
writeByte
in class DataOutput
java.io.IOException
DataInput.readByte()
public void writeBytes(byte[] b, int offset, int length) throws java.io.IOException
DataOutput
writeBytes
in class DataOutput
b
- the bytes to writeoffset
- the offset in the byte arraylength
- the number of bytes to writejava.io.IOException
DataInput.readBytes(byte[],int,int)
protected long getDelay(boolean closing)
public void copyBytes(DataInput input, long numBytes) throws java.io.IOException
DataOutput
copyBytes
in class DataOutput
java.io.IOException
public long getChecksum() throws java.io.IOException
IndexOutput
getChecksum
in class IndexOutput
java.io.IOException
Copyright © 2000–2019 The Apache Software Foundation. All rights reserved.