Package org.apache.lucene.util
Class ThrottledIndexOutput
- java.lang.Object
-
- org.apache.lucene.store.DataOutput
-
- org.apache.lucene.store.IndexOutput
-
- org.apache.lucene.util.ThrottledIndexOutput
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
public class ThrottledIndexOutput extends IndexOutput
Intentionally slow IndexOutput for testing.
-
-
Field Summary
Fields Modifier and Type Field Description static int
DEFAULT_MIN_WRITTEN_BYTES
-
Constructor Summary
Constructors Constructor Description ThrottledIndexOutput(int bytesPerSecond, long delays, int minBytesWritten, IndexOutput delegate)
ThrottledIndexOutput(int bytesPerSecond, long flushDelayMillis, long closeDelayMillis, long seekDelayMillis, long minBytesWritten, IndexOutput delegate)
ThrottledIndexOutput(int bytesPerSecond, long delayInMillis, IndexOutput delegate)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method 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)
-
Methods inherited from class org.apache.lucene.store.IndexOutput
getName, toString
-
Methods inherited from class org.apache.lucene.store.DataOutput
writeBytes, writeInt, writeLong, writeMapOfStrings, writeSetOfStrings, writeShort, writeString, writeVInt, writeVLong, writeZInt, writeZLong
-
-
-
-
Field Detail
-
DEFAULT_MIN_WRITTEN_BYTES
public static final int DEFAULT_MIN_WRITTEN_BYTES
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
ThrottledIndexOutput
public ThrottledIndexOutput(int bytesPerSecond, long delayInMillis, IndexOutput delegate)
-
ThrottledIndexOutput
public ThrottledIndexOutput(int bytesPerSecond, long delays, int minBytesWritten, IndexOutput delegate)
-
ThrottledIndexOutput
public ThrottledIndexOutput(int bytesPerSecond, long flushDelayMillis, long closeDelayMillis, long seekDelayMillis, long minBytesWritten, IndexOutput delegate)
-
-
Method Detail
-
newFromDelegate
public ThrottledIndexOutput newFromDelegate(IndexOutput output)
-
mBitsToBytes
public static final int mBitsToBytes(int mbits)
-
close
public void close() throws IOException
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in classIndexOutput
- Throws:
IOException
-
getFilePointer
public long getFilePointer()
- Specified by:
getFilePointer
in classIndexOutput
-
writeByte
public void writeByte(byte b) throws IOException
- Specified by:
writeByte
in classDataOutput
- Throws:
IOException
-
writeBytes
public void writeBytes(byte[] b, int offset, int length) throws IOException
- Specified by:
writeBytes
in classDataOutput
- Throws:
IOException
-
getDelay
protected long getDelay(boolean closing)
-
copyBytes
public void copyBytes(DataInput input, long numBytes) throws IOException
- Overrides:
copyBytes
in classDataOutput
- Throws:
IOException
-
getChecksum
public long getChecksum() throws IOException
- Specified by:
getChecksum
in classIndexOutput
- Throws:
IOException
-
-