org.vertexium.accumulo.util

Interface StreamingPropertyValueStorageStrategy

All Known Implementing Classes:

DataInDataTableStreamingPropertyValueStorageStrategy, OverflowIntoHdfsStreamingPropertyValueStorageStrategy

public interface StreamingPropertyValueStorageStrategy

Method Summary

Modifier and Type	Method and Description
void	close()
List<InputStream>	getInputStreams(List<StreamingPropertyValue> streamingPropertyValues)
StreamingPropertyValueRef	saveStreamingPropertyValue(ElementMutationBuilder elementMutationBuilder, String rowKey, Property property, StreamingPropertyValue streamingPropertyValue)

Method Detail

saveStreamingPropertyValue

StreamingPropertyValueRef saveStreamingPropertyValue(ElementMutationBuilder elementMutationBuilder,
                                                     String rowKey,
                                                     Property property,
                                                     StreamingPropertyValue streamingPropertyValue)

close

void close()

getInputStreams

List<InputStream> getInputStreams(List<StreamingPropertyValue> streamingPropertyValues)