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 Edges	decodeEdges(DataInputStream in, NameSubstitutionStrategy nameSubstitutionStrategy)
static void	decodeHeader(DataInputStream in, byte expectedTypeId)
static List<MetadataEntry>	decodeMetadataEntries(DataInputStream in)
static Iterable<Property>	decodeProperties(AccumuloGraph graph, DataInputStream in, List<MetadataEntry> metadataEntries, FetchHints 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)

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

decodeStringSet

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

Throws:

IOException

decodeMetadataEntries

public static List<MetadataEntry> decodeMetadataEntries(DataInputStream in)
                                                 throws IOException

Throws:

IOException

decodeProperties

public static Iterable<Property> decodeProperties(AccumuloGraph graph,
                                                  DataInputStream in,
                                                  List<MetadataEntry> metadataEntries,
                                                  FetchHints fetchHints)
                                           throws IOException

Throws:

IOException

decodeEdges

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

Throws:

IOException

decodeHeader

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

Throws:

IOException