io.pravega.common.io.serialization

Interface RevisionDataInput

All Superinterfaces:

java.io.DataInput

public interface RevisionDataInput
extends java.io.DataInput

Extension to DataInput that adds support for a few new constructs. An instance of RevisionDataInput is created for each Serialization Revision and closed when that Revision's serialization is fully consumed - it is not shared between multiple revisions.

This interface is designed to be used to consume data serialized using RevisionDataOutput.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	RevisionDataInput.ElementDeserializer<T> Defines a Function signature that can deserialize an element from a RevisionDataInput.

Method Summary

Modifier and Type	Method and Description
java.io.InputStream	getBaseStream() Gets a pointer to the InputStream that this RevisionDataInput reads from.
byte[]	readArray() Decodes a byte array that has been serialized using RevisionDataOutput.writeArray(byte[]).
<T> T[]	readArray(RevisionDataInput.ElementDeserializer<T> elementDeserializer, java.util.function.IntFunction<T[]> newArray) Decodes a specific array that has been serialized using RevisionDataOutput.writeArray(T[], ElementSerializer).
<T> java.util.Collection<T>	readCollection(RevisionDataInput.ElementDeserializer<T> elementDeserializer) Decodes a generic Collection that has been serialized using RevisionDataOutput.writeCollection().
<T,C extends java.util.Collection<T>> C	readCollection(RevisionDataInput.ElementDeserializer<T> elementDeserializer, java.util.function.Supplier<C> newCollection) Decodes a specific Collection that has been serialized using RevisionDataOutput.writeCollection().
int	readCompactInt() Decodes an Integer that has been serialized using RevisionDataOutput.writeCompactInt().
long	readCompactLong() Decodes a Long that has been serialized using RevisionDataOutput.writeCompactLong().
<K,V> java.util.Map<K,V>	readMap(RevisionDataInput.ElementDeserializer<K> keyDeserializer, RevisionDataInput.ElementDeserializer<V> valueDeserializer) Decodes a generic Map that has been serialized using RevisionDataOutput.writeMap().
<K,V,M extends java.util.Map<K,V>> M	readMap(RevisionDataInput.ElementDeserializer<K> keyDeserializer, RevisionDataInput.ElementDeserializer<V> valueDeserializer, java.util.function.Supplier<M> newMap) Decodes a specific Map that has been serialized using RevisionDataOutput.writeMap().
java.util.UUID	readUUID() Decodes a UUID that has been serialized using RevisionDataOutput.writeUUID().

Methods inherited from interface java.io.DataInput

readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, skipBytes

Method Detail

getBaseStream

java.io.InputStream getBaseStream()

Gets a pointer to the InputStream that this RevisionDataInput reads from.

Returns:

The InputStream.

readCompactLong

long readCompactLong()
              throws java.io.IOException

Decodes a Long that has been serialized using RevisionDataOutput.writeCompactLong(). After this method is complete, the underlying InputStream may have advanced by 1, 2, 4, or 8 bytes. This method has undefined behavior if the data starting at the current position was not encoded using RevisionDataOutput.writeCompactLong(). It may throw a SerializationException (after reading 1 byte) or it may produce a result that is not as expected.

Returns:

The decoded compact Long. This number should be between 0 and 2^62-1, inclusive.

Throws:

java.io.IOException - If an IO Exception occurred.

readCompactInt

int readCompactInt()
            throws java.io.IOException

Decodes an Integer that has been serialized using RevisionDataOutput.writeCompactInt(). After this method is complete, the underlying InputStream may have advanced by 1, 2, 3, or 4 bytes. This method has undefined behavior if the data starting at the current position was not encoded using RevisionDataOutput.writeCompactInt(). It may throw a SerializationException (after reading 1 byte) or it may produce a result that is not as expected.

Returns:

The decoded compact Long. This number should be between 0 and 2^30-1, inclusive.

Throws:

java.io.IOException - If an IO Exception occurred.

readUUID

java.util.UUID readUUID()
                 throws java.io.IOException

Decodes a UUID that has been serialized using RevisionDataOutput.writeUUID(). This method has undefined behavior if the data starting at the current position was not encoded using RevisionDataOutput.writeUUID().

Returns:

A new UUID.

Throws:

java.io.IOException - If an IO Exception occurred.

readCollection

<T> java.util.Collection<T> readCollection(RevisionDataInput.ElementDeserializer<T> elementDeserializer)
                                    throws java.io.IOException

Decodes a generic Collection that has been serialized using RevisionDataOutput.writeCollection(). The underlying type of the collection will be an ArrayList. Should a different type of Collection be desired, consider using the appropriate overload of this method. This method has undefined behavior if the data starting at the current position was not encoded using RevisionDataOutput.writeCollection().

Type Parameters:

T - Type of the elements in the Collection.

Parameters:

elementDeserializer - A Function that will decode a single element of the Collection from the given RevisionDataInput.

Returns:

A new Collection. If the original collection passed to RevisionDataOutput.writeCollection() was null, this will return an empty collection.

Throws:

java.io.IOException - If an IO Exception occurred.

readCollection

<T,C extends java.util.Collection<T>> C readCollection(RevisionDataInput.ElementDeserializer<T> elementDeserializer,
                                                       java.util.function.Supplier<C> newCollection)
                                                throws java.io.IOException

Decodes a specific Collection that has been serialized using RevisionDataOutput.writeCollection(). This method has undefined behavior if the data starting at the current position was not encoded using RevisionDataOutput.writeCollection().

Type Parameters:

T - Type of the elements in the Collection.

C - Type of the Collection desired to be instantiated and returned.

Parameters:

elementDeserializer - A Function that will decode a single element of the Collection from the given RevisionDataInput.

newCollection - A Supplier that will create a new instance of the Collection type desired.

Returns:

A new Collection. If the original Collection passed to RevisionDataOutput.writeCollection() was null, this will return an empty collection.

Throws:

java.io.IOException - If an IO Exception occurred.

readArray

<T> T[] readArray(RevisionDataInput.ElementDeserializer<T> elementDeserializer,
                  java.util.function.IntFunction<T[]> newArray)
           throws java.io.IOException

Decodes a specific array that has been serialized using RevisionDataOutput.writeArray(T[], ElementSerializer). This method has undefined behavior if the data starting at the current position was not encoded using RevisionDataOutput.writeArray(T[], ElementSerializer).

Type Parameters:

T - Type of the elements in the array.

Parameters:

elementDeserializer - A Function that will decode a single element of the Collection from the given RevisionDataInput.

newArray - A Function that will create a new instance of the array type desired, with the specified length.

Returns:

A new array. If the original array passed to RevisionDataOutput.writeArray() was null, this will return an empty array.

Throws:

java.io.IOException - If an IO Exception occurred.

readArray

byte[] readArray()
          throws java.io.IOException

Decodes a byte array that has been serialized using RevisionDataOutput.writeArray(byte[]). This method has undefined behavior if the data starting at the current position was not encoded using RevisionDataOutput.writeArray(byte[]).

Returns:

A new byte array. If the original array passed to RevisionDataOutput.writeArray(byte[]) was null, this will return an empty array.

Throws:

java.io.IOException - If an IO Exception occurred.

readMap

<K,V> java.util.Map<K,V> readMap(RevisionDataInput.ElementDeserializer<K> keyDeserializer,
                                 RevisionDataInput.ElementDeserializer<V> valueDeserializer)
                          throws java.io.IOException

Decodes a generic Map that has been serialized using RevisionDataOutput.writeMap(). The underlying type of the map will be a HashMap. Should a different type of Map be desired, consider using the appropriate overload of this method. This method has undefined behavior if the data starting at the current position was not encoded using RevisionDataOutput.writeMap().

Type Parameters:

K - Type of the Keys in the Map.

V - Type of the Values in the Map.

Parameters:

keyDeserializer - A Function that will decode a single Key of the Map from the given RevisionDataInput.

valueDeserializer - A Function that will decode a single Value of the Map from the given RevisionDataInput.

Returns:

A new Map. If the original Map passed to RevisionDataOutput.writeMap() was null, this will return an empty map.

Throws:

java.io.IOException - If an IOException occurred.

readMap

<K,V,M extends java.util.Map<K,V>> M readMap(RevisionDataInput.ElementDeserializer<K> keyDeserializer,
                                             RevisionDataInput.ElementDeserializer<V> valueDeserializer,
                                             java.util.function.Supplier<M> newMap)
                                      throws java.io.IOException

Decodes a specific Map that has been serialized using RevisionDataOutput.writeMap(). This method has undefined behavior if the data starting at the current position was not encoded using RevisionDataOutput.writeMap().

Type Parameters:

K - Type of the Keys in the Map.

V - Type of the Values in the Map.

M - Type of the Map desired to be instantiated and returned.

Parameters:

keyDeserializer - A Function that will decode a single Key of the Map from the given RevisionDataInput.

valueDeserializer - A Function that will decode a single Value of the Map from the given RevisionDataInput.

newMap - A Supplier that will create a new instance of the Map type desired.

Returns:

A new Map. If the original Map passed to RevisionDataOutput.writeMap() was null, this will return an empty map.

Throws:

java.io.IOException - If an IOException occurred.