org.vertexium.accumulo

Class StreamingPropertyValueTableData

java.lang.Object

org.vertexium.property.PropertyValue

org.vertexium.property.StreamingPropertyValue

org.vertexium.accumulo.StreamingPropertyValueTableData

All Implemented Interfaces:

Serializable

public class StreamingPropertyValueTableData
extends StreamingPropertyValue

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.hadoop.io.Text	DATA_COLUMN_FAMILY
static org.apache.hadoop.io.Text	METADATA_COLUMN_FAMILY
static org.apache.hadoop.io.Text	METADATA_LENGTH_COLUMN_QUALIFIER

Constructor Summary

Constructors

Constructor and Description
StreamingPropertyValueTableData(AccumuloGraph graph, String dataRowKey, Class valueType, Long length, long timestamp)

Method Summary

Modifier and Type	Method and Description
InputStream	getInputStream()
Long	getLength()

Methods inherited from class org.vertexium.property.StreamingPropertyValue

create, create, create, getValueType, readToString, readToString, toString

Methods inherited from class org.vertexium.property.PropertyValue

isSearchIndex, isStore, searchIndex, store

Methods inherited from class java.lang.Object

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

Field Detail

METADATA_COLUMN_FAMILY

public static final org.apache.hadoop.io.Text METADATA_COLUMN_FAMILY

DATA_COLUMN_FAMILY

public static final org.apache.hadoop.io.Text DATA_COLUMN_FAMILY

METADATA_LENGTH_COLUMN_QUALIFIER

public static final org.apache.hadoop.io.Text METADATA_LENGTH_COLUMN_QUALIFIER

Constructor Detail

StreamingPropertyValueTableData

public StreamingPropertyValueTableData(AccumuloGraph graph,
                                       String dataRowKey,
                                       Class valueType,
                                       Long length,
                                       long timestamp)

Method Detail

getLength

public Long getLength()

Specified by:

getLength in class StreamingPropertyValue

getInputStream

public InputStream getInputStream()

Specified by:

getInputStream in class StreamingPropertyValue