org.vertexium.accumulo.util

Class DataInputStreamUtils

java.lang.Object

org.vertexium.accumulo.util.DataInputStreamUtils

public class DataInputStreamUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
DataInputStreamUtils()

Method Summary

Modifier and Type	Method and Description
static byte[]	decodeByteArray(DataInputStream in)
static Edges	decodeEdges(DataInputStream in, NameSubstitutionStrategy nameSubstitutionStrategy)
static void	decodeHeader(DataInputStream in, byte expectedTypeId)
static Iterable<Property>	decodeProperties(AccumuloGraph graph, DataInputStream in, EnumSet<FetchHint> fetchHints)
static String	decodeString(DataInputStream in)
static com.google.common.collect.ImmutableSet<String>	decodeStringSet(DataInputStream in)
static org.apache.hadoop.io.Text	decodeText(DataInputStream in)
static List<org.apache.hadoop.io.Text>	decodeTextList(DataInputStream in)

Methods inherited from class java.lang.Object

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

Constructor Detail

DataInputStreamUtils

public DataInputStreamUtils()

Method Detail

decodeText

public static org.apache.hadoop.io.Text decodeText(DataInputStream in)
                                            throws IOException

Throws:

IOException

decodeString

public static String decodeString(DataInputStream in)
                           throws IOException

Throws:

IOException

decodeTextList

public static List<org.apache.hadoop.io.Text> decodeTextList(DataInputStream in)
                                                      throws IOException

Throws:

IOException

decodeStringSet

public static com.google.common.collect.ImmutableSet<String> decodeStringSet(DataInputStream in)
                                                                      throws IOException

Throws:

IOException

decodeProperties

public static Iterable<Property> decodeProperties(AccumuloGraph graph,
                                                  DataInputStream in,
                                                  EnumSet<FetchHint> fetchHints)
                                           throws IOException

Throws:

IOException

decodeEdges

public static Edges decodeEdges(DataInputStream in,
                                NameSubstitutionStrategy nameSubstitutionStrategy)
                         throws IOException

Throws:

IOException

decodeByteArray

public static byte[] decodeByteArray(DataInputStream in)
                              throws IOException

Throws:

IOException

decodeHeader

public static void decodeHeader(DataInputStream in,
                                byte expectedTypeId)
                         throws IOException

Throws:

IOException