| Modifier and Type | Field and Description |
|---|---|
| private static final Log | LOG
Log instance. |
| private static final RandomAccessStreamCache. | |
| private static final Optional |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public static IOException | Returns: the IOException is there was any but only if initialException is nullto be closed closeable, Log the logger to be used so that logging appears under that log instance logger, String the name to appear in the log output resourceName, IOException if set, this exception will be returned even where there is another
exception while closing the IO resource initialException)Try to close an IO resource and log and return if there was an exception. |
| public static void | closeQuietly(Closeable
to be closed closeable)Null safe close of the given |
| public static long | Returns: the number of bytes that have been copiedthe input stream input, OutputStream the output stream output)Copies all the contents from the given input stream to the given output stream. |
| public static RandomAccessStreamCache. | Returns: a function to create an instance of a memory only StreamCache using unrestricted main memoryProvides a function to create an instance of a memory only StreamCache using unrestricted main memory. |
| public static RandomAccessStreamCache. | Returns: a function to create an instance of a temp file only StreamCache using unrestricted sizeProvides a function to create an instance of a temp file only StreamCache using unrestricted size. |
| private static Consumer | |
| public static long | Returns: the number of bytes written to the bufferthe input stream to read from in, byte[] the buffer to fill buffer)Populates the given buffer with data read from the input stream. |
| public static byte[] | Returns: the byte arraythe input stream to read from. in)Reads the input stream and returns its contents as a byte array. |
| public static void | |
| private static Consumer |
| LOG | back to summary |
|---|---|
| private static final Log LOG Log instance. | |
| streamCache | back to summary |
|---|---|
| private static final RandomAccessStreamCache. | |
| UNMAPPER | back to summary |
|---|---|
| private static final Optional<Consumer<ByteBuffer>> UNMAPPER | |
| IOUtils | back to summary |
|---|---|
| private IOUtils() | |
| closeAndLogException | back to summary |
|---|---|
| public static IOException closeAndLogException(Closeable closeable, Log logger, String resourceName, IOException initialException) Try to close an IO resource and log and return if there was an exception. An exception is only returned if the IOException passed in is null.
| |
| closeQuietly | back to summary |
|---|---|
| public static void closeQuietly(Closeable closeable) Null safe close of the given
| |
| copy | back to summary |
|---|---|
| public static long copy(InputStream input, OutputStream output) throws IOException Copies all the contents from the given input stream to the given output stream.
| |
| createMemoryOnlyStreamCache | back to summary |
|---|---|
| public static RandomAccessStreamCache. Provides a function to create an instance of a memory only StreamCache using unrestricted main memory. RandomAccessReadWriteBuffer is used as current default implementation.
| |
| createTempFileOnlyStreamCache | back to summary |
|---|---|
| public static RandomAccessStreamCache. Provides a function to create an instance of a temp file only StreamCache using unrestricted size. ScratchFile is used as current default implementation.
| |
| newBufferCleaner | back to summary |
|---|---|
| private static Consumer | |
| populateBuffer | back to summary |
|---|---|
| public static long populateBuffer(InputStream in, byte[] buffer) throws IOException Populates the given buffer with data read from the input stream. If the data doesn't fit the buffer, only the data that fits in the buffer is read. If the data is less than fits in the buffer, the buffer is not completely filled.
| |
| toByteArray | back to summary |
|---|---|
| public static byte[] toByteArray(InputStream in) throws IOException Reads the input stream and returns its contents as a byte array.
| |
| unmap | back to summary |
|---|---|
| public static void unmap(ByteBuffer buf) Unmap memory mapped byte buffers. This is a hack waiting for a proper JVM provided solution expected in java 10 https://bugs.openjdk.java.net/browse/JDK-4724038 The issue here is that even when closed, memory mapped byte buffers hold a lock on the underlying file until GC is executes and this in turns result in an error if the user tries to move or delete the file.
| |
| unmapper | back to summary |
|---|---|
| private static Consumer This is adapted from org.apache.lucene.store.MMapDirectory | |