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() |
void |
copyBytes(DataInput input,
long numBytes) |
long |
getChecksum() |
protected long |
getDelay(boolean closing) |
long |
getFilePointer() |
static int |
mBitsToBytes(int mbits) |
ThrottledIndexOutput |
newFromDelegate(IndexOutput output) |
void |
writeByte(byte b) |
void |
writeBytes(byte[] b,
int offset,
int length) |
toString
writeBytes, writeInt, writeLong, writeMapOfStrings, writeSetOfStrings, writeShort, writeString, writeStringSet, writeStringStringMap, 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 IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class IndexOutput
IOException
public long getFilePointer()
getFilePointer
in class IndexOutput
public void writeByte(byte b) throws IOException
writeByte
in class DataOutput
IOException
public void writeBytes(byte[] b, int offset, int length) throws IOException
writeBytes
in class DataOutput
IOException
protected long getDelay(boolean closing)
public void copyBytes(DataInput input, long numBytes) throws IOException
copyBytes
in class DataOutput
IOException
public long getChecksum() throws IOException
getChecksum
in class IndexOutput
IOException
Copyright © 2000-2015 Apache Software Foundation. All Rights Reserved.