org.vertexium.accumulo

Class ElementMutationBuilder

java.lang.Object

org.vertexium.accumulo.ElementMutationBuilder

public abstract class ElementMutationBuilder
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.hadoop.io.Text	EMPTY_TEXT
static org.apache.accumulo.core.data.Value	EMPTY_VALUE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ElementMutationBuilder(org.apache.hadoop.fs.FileSystem fileSystem, VertexiumSerializer vertexiumSerializer, long maxStreamingPropertyValueTableDataSize, String dataDir)

Method Summary

Modifier and Type	Method and Description
void	addPropertyDeleteMetadataToMutation(org.apache.accumulo.core.data.Mutation m, PropertyDeleteMutation propertyDeleteMutation)
void	addPropertyDeleteToMutation(org.apache.accumulo.core.data.Mutation m, Property property)
void	addPropertyDeleteToMutation(org.apache.accumulo.core.data.Mutation m, PropertyDeleteMutation propertyDelete)
void	addPropertyMetadataToMutation(org.apache.accumulo.core.data.Mutation m, Property property)
void	addPropertySoftDeleteToMutation(org.apache.accumulo.core.data.Mutation m, Property property)
void	addPropertySoftDeleteToMutation(org.apache.accumulo.core.data.Mutation m, PropertySoftDeleteMutation propertySoftDelete)
void	addPropertyToMutation(AccumuloGraph graph, org.apache.accumulo.core.data.Mutation m, String rowKey, Property property)
void	alterEdgeLabel(Edge edge, String newEdgeLabel)
boolean	alterEdgeVertexInVertex(org.apache.accumulo.core.data.Mutation vertexInMutation, Edge edge, Visibility newVisibility)
boolean	alterEdgeVertexOutVertex(org.apache.accumulo.core.data.Mutation vertexOutMutation, Edge edge, Visibility newVisibility)
boolean	alterElementVisibility(org.apache.accumulo.core.data.Mutation m, AccumuloElement element, Visibility newVisibility)
Iterable<KeyValuePair>	getEdgeTableKeyValuePairsEdge(AccumuloEdge edge)
Iterable<KeyValuePair>	getKeyValuePairsForVertex(AccumuloVertex vertex)
protected abstract NameSubstitutionStrategy	getNameSubstitutionStrategy()
Iterable<KeyValuePair>	getVertexTableKeyValuePairsEdge(AccumuloEdge edge)
protected abstract void	saveDataMutation(org.apache.accumulo.core.data.Mutation dataMutation)
void	saveEdgeBuilder(AccumuloGraph graph, EdgeBuilderBase edgeBuilder, long timestamp)
protected abstract void	saveEdgeMutation(org.apache.accumulo.core.data.Mutation m)
void	saveExtendedDataMarkers(String elementId, ElementType elementType, Iterable<ExtendedDataMutation> extendedData)
protected abstract void	saveExtendedDataMutation(ElementType elementType, org.apache.accumulo.core.data.Mutation m)
protected StreamingPropertyValueRef	saveStreamingPropertyValue(String rowKey, Property property, StreamingPropertyValue propertyValue)
void	saveVertexBuilder(AccumuloGraph graph, VertexBuilder vertexBuilder, long timestamp)
protected abstract void	saveVertexMutation(org.apache.accumulo.core.data.Mutation m)

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY_TEXT

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

EMPTY_VALUE

public static final org.apache.accumulo.core.data.Value EMPTY_VALUE

Constructor Detail

ElementMutationBuilder

protected ElementMutationBuilder(org.apache.hadoop.fs.FileSystem fileSystem,
                                 VertexiumSerializer vertexiumSerializer,
                                 long maxStreamingPropertyValueTableDataSize,
                                 String dataDir)

Method Detail

saveVertexBuilder

public void saveVertexBuilder(AccumuloGraph graph,
                              VertexBuilder vertexBuilder,
                              long timestamp)

saveExtendedDataMutation

protected abstract void saveExtendedDataMutation(ElementType elementType,
                                                 org.apache.accumulo.core.data.Mutation m)

saveVertexMutation

protected abstract void saveVertexMutation(org.apache.accumulo.core.data.Mutation m)

saveExtendedDataMarkers

public void saveExtendedDataMarkers(String elementId,
                                    ElementType elementType,
                                    Iterable<ExtendedDataMutation> extendedData)

getKeyValuePairsForVertex

public Iterable<KeyValuePair> getKeyValuePairsForVertex(AccumuloVertex vertex)

getEdgeTableKeyValuePairsEdge

public Iterable<KeyValuePair> getEdgeTableKeyValuePairsEdge(AccumuloEdge edge)

getVertexTableKeyValuePairsEdge

public Iterable<KeyValuePair> getVertexTableKeyValuePairsEdge(AccumuloEdge edge)

saveEdgeBuilder

public void saveEdgeBuilder(AccumuloGraph graph,
                            EdgeBuilderBase edgeBuilder,
                            long timestamp)

alterEdgeLabel

public void alterEdgeLabel(Edge edge,
                           String newEdgeLabel)

saveEdgeMutation

protected abstract void saveEdgeMutation(org.apache.accumulo.core.data.Mutation m)

alterElementVisibility

public boolean alterElementVisibility(org.apache.accumulo.core.data.Mutation m,
                                      AccumuloElement element,
                                      Visibility newVisibility)

alterEdgeVertexOutVertex

public boolean alterEdgeVertexOutVertex(org.apache.accumulo.core.data.Mutation vertexOutMutation,
                                        Edge edge,
                                        Visibility newVisibility)

alterEdgeVertexInVertex

public boolean alterEdgeVertexInVertex(org.apache.accumulo.core.data.Mutation vertexInMutation,
                                       Edge edge,
                                       Visibility newVisibility)

addPropertyToMutation

public void addPropertyToMutation(AccumuloGraph graph,
                                  org.apache.accumulo.core.data.Mutation m,
                                  String rowKey,
                                  Property property)

getNameSubstitutionStrategy

protected abstract NameSubstitutionStrategy getNameSubstitutionStrategy()

addPropertyDeleteToMutation

public void addPropertyDeleteToMutation(org.apache.accumulo.core.data.Mutation m,
                                        PropertyDeleteMutation propertyDelete)

addPropertyMetadataToMutation

public void addPropertyMetadataToMutation(org.apache.accumulo.core.data.Mutation m,
                                          Property property)

addPropertyDeleteMetadataToMutation

public void addPropertyDeleteMetadataToMutation(org.apache.accumulo.core.data.Mutation m,
                                                PropertyDeleteMutation propertyDeleteMutation)

saveStreamingPropertyValue

protected StreamingPropertyValueRef saveStreamingPropertyValue(String rowKey,
                                                               Property property,
                                                               StreamingPropertyValue propertyValue)

addPropertyDeleteToMutation

public void addPropertyDeleteToMutation(org.apache.accumulo.core.data.Mutation m,
                                        Property property)

addPropertySoftDeleteToMutation

public void addPropertySoftDeleteToMutation(org.apache.accumulo.core.data.Mutation m,
                                            Property property)

addPropertySoftDeleteToMutation

public void addPropertySoftDeleteToMutation(org.apache.accumulo.core.data.Mutation m,
                                            PropertySoftDeleteMutation propertySoftDelete)

saveDataMutation

protected abstract void saveDataMutation(org.apache.accumulo.core.data.Mutation dataMutation)