alluxio.master.journal

Class PatchedInputChunked

java.lang.Object

java.io.InputStream

com.esotericsoftware.kryo.io.Input

com.esotericsoftware.kryo.io.InputChunked

alluxio.master.journal.PatchedInputChunked

All Implemented Interfaces:

Closeable, AutoCloseable

public class PatchedInputChunked
extends com.esotericsoftware.kryo.io.InputChunked

A replacement for Kryo's InputChunked which properly handles eof. See https://github.com/EsotericSoftware/kryo/issues/651. Once kryo releases 4.0.3, we can upgrade and remove this class.

Field Summary

Fields inherited from class com.esotericsoftware.kryo.io.Input

buffer, capacity, chars, inputStream, limit, position, total

Constructor Summary

Constructors

Constructor and Description
PatchedInputChunked(InputStream input)

Method Summary

Modifier and Type	Method and Description
protected int	fill(byte[] buffer, int offset, int count)

Methods inherited from class com.esotericsoftware.kryo.io.InputChunked

nextChunks, rewind, setBuffer, setInputStream

Methods inherited from class com.esotericsoftware.kryo.io.Input

available, canReadInt, canReadLong, close, eof, getBuffer, getInputStream, limit, position, read, read, read, readBoolean, readByte, readBytes, readBytes, readBytes, readByteUnsigned, readChar, readChars, readDouble, readDouble, readDoubles, readFloat, readFloat, readFloats, readInt, readInt, readInts, readInts, readLong, readLong, readLongs, readLongs, readShort, readShorts, readShortUnsigned, readString, readStringBuilder, readVarInt, readVarLong, require, setBuffer, setLimit, setPosition, setTotal, skip, skip, total

Methods inherited from class java.io.InputStream

mark, markSupported, reset

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PatchedInputChunked

public PatchedInputChunked(InputStream input)

Parameters:

input - the input stream

Method Detail

fill

protected int fill(byte[] buffer,
                   int offset,
                   int count)
            throws com.esotericsoftware.kryo.KryoException

Overrides:

fill in class com.esotericsoftware.kryo.io.InputChunked

Throws:

com.esotericsoftware.kryo.KryoException