org.vertexium.accumulo

Class AccumuloGraph

java.lang.Object

org.vertexium.GraphBase

org.vertexium.GraphBaseWithSearchIndex

org.vertexium.accumulo.AccumuloGraph

All Implemented Interfaces:

Graph, GraphWithSearchIndex, Traceable

public class AccumuloGraph
extends GraphBaseWithSearchIndex
implements Traceable

Field Summary

Fields

Modifier and Type	Field and Description
static Integer	ALL_VERSIONS
protected ElementMutationBuilder	elementMutationBuilder
static int	SINGLE_VERSION

Fields inherited from class org.vertexium.GraphBaseWithSearchIndex

METADATA_ID_GENERATOR_CLASSNAME

Fields inherited from class org.vertexium.GraphBase

METADATA_DEFINE_PROPERTY_PREFIX, QUERY_LOGGER

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AccumuloGraph(AccumuloGraphConfiguration config, org.apache.accumulo.core.client.Connector connector)

Method Summary

Modifier and Type	Method and Description
protected void	_addMutations(org.apache.accumulo.core.client.BatchWriter writer, org.apache.accumulo.core.data.Mutation... mutations)
static Visibility	accumuloVisibilityToVisibility(org.apache.accumulo.core.security.ColumnVisibility columnVisibility)
static Visibility	accumuloVisibilityToVisibility(String columnVisibilityString)
static Visibility	accumuloVisibilityToVisibility(org.apache.hadoop.io.Text columnVisibility)
protected void	addMutations(Element element, org.apache.accumulo.core.data.Mutation... mutations)
protected void	addMutations(VertexiumObjectType objectType, org.apache.accumulo.core.data.Mutation... mutations)
void	alterEdgeLabel(AccumuloEdge edge, String newEdgeLabel)
static AccumuloGraph	create(AccumuloGraphConfiguration config)
static AccumuloGraph	create(Map config)
Authorizations	createAuthorizations(String... auths)
org.apache.accumulo.core.client.ScannerBase	createBatchScanner(String tableName, Collection<org.apache.accumulo.core.data.Range> ranges, Authorizations authorizations)
org.apache.accumulo.core.client.ScannerBase	createBatchScanner(String tableName, Collection<org.apache.accumulo.core.data.Range> ranges, org.apache.accumulo.core.security.Authorizations accumuloAuthorizations)
protected org.apache.accumulo.core.client.ScannerBase	createEdgeScanner(FetchHints fetchHints, Integer maxVersions, Long startTime, Long endTime, Collection<org.apache.accumulo.core.data.Range> ranges, Authorizations authorizations)
protected org.apache.accumulo.core.client.ScannerBase	createEdgeScanner(FetchHints fetchHints, Integer maxVersions, Long startTime, Long endTime, org.apache.accumulo.core.data.Range range, Authorizations authorizations)
protected org.apache.accumulo.core.client.ScannerBase	createVertexScanner(FetchHints fetchHints, Integer maxVersions, Long startTime, Long endTime, Collection<org.apache.accumulo.core.data.Range> ranges, Authorizations authorizations)
protected org.apache.accumulo.core.client.ScannerBase	createVertexScanner(FetchHints fetchHints, Integer maxVersions, Long startTime, Long endTime, org.apache.accumulo.core.data.Range range, Authorizations authorizations)
void	deleteEdge(Edge edge, Authorizations authorizations)
void	deleteExtendedDataRow(ExtendedDataRowId rowId, Authorizations authorizations)
void	deleteVertex(Vertex vertex, Authorizations authorizations)
void	drop()
protected static void	ensureRowDeletingIteratorIsAttached(org.apache.accumulo.core.client.Connector connector, String tableName)
protected static void	ensureTableExists(org.apache.accumulo.core.client.Connector connector, String tableName, Integer maxVersions, String hdfsContextClasspath, boolean createTable)
Iterable<String>	filterEdgeIdsByAuthorization(Iterable<String> edgeIds, String authorizationToMatch, EnumSet<ElementFilter> filters, Authorizations authorizations)
Iterable<String>	filterVertexIdsByAuthorization(Iterable<String> vertexIds, String authorizationToMatch, EnumSet<ElementFilter> filters, Authorizations authorizations)
Iterable<Path>	findPaths(FindPathOptions options, Authorizations authorizations)
Iterable<String>	findRelatedEdgeIds(Iterable<String> vertexIds, Long endTime, Authorizations authorizations)
Iterable<RelatedEdge>	findRelatedEdgeSummary(Iterable<String> vertexIds, Long endTime, Authorizations authorizations)
void	flush()
void	flushGraph()
static Iterable<org.apache.hadoop.io.Text>	getColumnFamiliesToFetch(ElementType elementType, FetchHints fetchHints)
AccumuloGraphConfiguration	getConfiguration()
org.apache.accumulo.core.client.Connector	getConnector()
String	getDataTableName()
static String	getDataTableName(String tableNamePrefix)
org.apache.accumulo.core.client.BatchWriter	getDataWriter()
Edge	getEdge(String edgeId, FetchHints fetchHints, Long endTime, Authorizations authorizations)
long	getEdgeCount(Authorizations authorizations)
CloseableIterable<Edge>	getEdges(FetchHints fetchHints, Long endTime, Authorizations authorizations)
CloseableIterable<Edge>	getEdges(Iterable<String> ids, FetchHints fetchHints, Long endTime, Authorizations authorizations)
Iterable<Edge>	getEdgesInRange(Range idRange, FetchHints fetchHints, Long endTime, Authorizations authorizations)
protected CloseableIterable<Edge>	getEdgesInRange(org.apache.accumulo.core.trace.Span trace, org.apache.accumulo.core.data.Range range, FetchHints fetchHints, Long endTime, Authorizations authorizations)
protected CloseableIterable<Edge>	getEdgesInRange(org.apache.accumulo.core.trace.Span trace, String startId, String endId, FetchHints fetchHints, Long timestamp, Authorizations authorizations)
String	getEdgesTableName()
static String	getEdgesTableName(String tableNamePrefix)
org.apache.accumulo.core.client.BatchWriter	getEdgesWriter()
Iterable<ExtendedDataRow>	getExtendedData(ElementType elementType, String elementId, String tableName, Authorizations authorizations)
Iterable<ExtendedDataRow>	getExtendedData(Iterable<ExtendedDataRowId> ids, Authorizations authorizations)
Iterable<ExtendedDataRow>	getExtendedDataInRange(ElementType elementType, Range elementIdRange, Authorizations authorizations)
Iterable<ExtendedDataRow>	getExtendedDataInRange(Range extendedDataRowKeyRange, Authorizations authorizations)
String	getExtendedDataTableName()
static String	getExtendedDataTableName(String tableNamePrefix)
org.apache.accumulo.core.client.BatchWriter	getExtendedDataWriter()
AccumuloGraphLogger	getGraphLogger()
protected GraphMetadataStore	getGraphMetadataStore()
Iterable<HistoricalPropertyValue>	getHistoricalPropertyValues(Element element, String key, String name, Visibility visibility, Long startTime, Long endTime, Authorizations authorizations)
String	getHistoryEdgesTableName()
static String	getHistoryEdgesTableName(String tableNamePrefix)
org.apache.accumulo.core.client.BatchWriter	getHistoryEdgesWriter()
String	getHistoryTableNameFromElementType(ElementType elementType)
String	getHistoryVerticesTableName()
static String	getHistoryVerticesTableName(String tableNamePrefix)
org.apache.accumulo.core.client.BatchWriter	getHistoryVerticesWriter()
org.apache.accumulo.core.client.BatchWriter	getHistoryWriterFromElementType(VertexiumObjectType objectType)
Iterable<GraphMetadataEntry>	getMetadataInRange(org.apache.accumulo.core.data.Range range)
String	getMetadataTableName()
static String	getMetadataTableName(String tableNamePrefix)
protected org.apache.accumulo.core.client.BatchWriter	getMetadataWriter()
AccumuloNameSubstitutionStrategy	getNameSubstitutionStrategy()
List<InputStream>	getStreamingPropertyValueInputStreams(List<StreamingPropertyValue> streamingPropertyValues)
StreamingPropertyValueStorageStrategy	getStreamingPropertyValueStorageStrategy()
String	getTableNameFromElementType(ElementType elementType)
protected Class<?>	getValueType(Object value)
Vertex	getVertex(String vertexId, FetchHints fetchHints, Long endTime, Authorizations authorizations)
long	getVertexCount(Authorizations authorizations)
VertexiumSerializer	getVertexiumSerializer()
Iterable<Vertex>	getVertices(FetchHints fetchHints, Long endTime, Authorizations authorizations)
CloseableIterable<Vertex>	getVertices(Iterable<String> ids, FetchHints fetchHints, Long endTime, Authorizations authorizations)
Iterable<Vertex>	getVerticesInRange(Range idRange, FetchHints fetchHints, Long endTime, Authorizations authorizations)
protected CloseableIterable<Vertex>	getVerticesInRange(org.apache.accumulo.core.trace.Span trace, org.apache.accumulo.core.data.Range range, FetchHints fetchHints, Long endTime, Authorizations authorizations)
String	getVerticesTableName()
static String	getVerticesTableName(String tableNamePrefix)
Iterable<Vertex>	getVerticesWithPrefix(String vertexIdPrefix, FetchHints fetchHints, Long endTime, Authorizations authorizations)
org.apache.accumulo.core.client.BatchWriter	getVerticesWriter()
org.apache.accumulo.core.client.BatchWriter	getWriterFromElementType(VertexiumObjectType objectType)
boolean	isVisibilityValid(Visibility visibility, Authorizations authorizations)
Iterable<Range>	listDataTableSplits()
Iterable<Range>	listEdgesTableSplits()
Iterable<Range>	listExtendedDataTableSplits()
Iterable<Range>	listHistoryEdgesTableSplits()
Iterable<Range>	listHistoryVerticesTableSplits()
Iterable<Range>	listVerticesTableSplits()
void	markEdgeHidden(Edge edge, Visibility visibility, Authorizations authorizations)
void	markEdgeVisible(Edge edge, Visibility visibility, Authorizations authorizations)
void	markPropertyHidden(AccumuloElement element, Property property, Long timestamp, Visibility visibility, Authorizations authorizations)
void	markPropertyVisible(AccumuloElement element, Property property, Long timestamp, Visibility visibility, Authorizations authorizations)
void	markVertexHidden(Vertex vertex, Visibility visibility, Authorizations authorizations)
void	markVertexVisible(Vertex vertex, Visibility visibility, Authorizations authorizations)
AccumuloEdgeBuilderByVertexId	prepareEdge(String edgeId, String outVertexId, String inVertexId, String label, Long timestamp, Visibility visibility)
EdgeBuilder	prepareEdge(String edgeId, Vertex outVertex, Vertex inVertex, String label, Long timestamp, Visibility visibility)
AccumuloVertexBuilder	prepareVertex(String vertexId, Long timestamp, Visibility visibility)
protected void	setup()
protected void	setupGraphMetadata()
protected void	setupGraphMetadata(GraphMetadataEntry graphMetadataEntry)
void	shutdown()
void	softDeleteEdge(Edge edge, Long timestamp, Authorizations authorizations)
void	softDeleteVertex(Vertex vertex, Long timestamp, Authorizations authorizations)
org.apache.accumulo.core.security.Authorizations	toAccumuloAuthorizations(Authorizations authorizations)
IteratorFetchHints	toIteratorFetchHints(FetchHints fetchHints)
void	traceOff()
void	traceOn(String description)
void	traceOn(String description, Map<String,String> data)
void	truncate()
static org.apache.accumulo.core.security.ColumnVisibility	visibilityToAccumuloVisibility(String visibilityString)
static org.apache.accumulo.core.security.ColumnVisibility	visibilityToAccumuloVisibility(Visibility visibility)

Methods inherited from class org.vertexium.GraphBaseWithSearchIndex

getDefaultFetchHints, getIdGenerator, getSearchIndex, getSearchIndexSecurityGranularity, getVertexPropertyCountByValue, isFieldBoostSupported, isQuerySimilarToTextSupported, query, query, query, query, querySimilarTo, reindex, reindexVertices, saveElementMutations

Methods inherited from class org.vertexium.GraphBase

addEdge, addEdge, addEdge, addEdge, addGraphEventListener, addToPropertyDefinitionCache, addVertex, addVertex, addVertices, createAuthorizations, createAuthorizations, createAuthorizations, defineProperty, deleteAllExtendedDataForElement, deleteEdge, deleteVertex, doEdgesExist, doEdgesExist, doesEdgeExist, doesVertexExist, doVerticesExist, ensurePropertyDefined, findPaths, findPaths, findPaths, findPaths, findPathsRecursive, findPathsSetIntersection, findRelatedEdgeIds, findRelatedEdgeIdsForVertices, findRelatedEdges, findRelatedEdges, findRelatedEdgeSummary, findRelatedEdgeSummaryForVertices, fireGraphEvent, getAllExtendedData, getEdge, getEdge, getEdges, getEdges, getEdges, getEdges, getEdgesInRange, getEdgesInRange, getExtendedData, getMetadata, getMetadata, getMetadataWithPrefix, getPropertyDefinition, getPropertyDefinitions, getVertex, getVertex, getVertices, getVertices, getVertices, getVertices, getVerticesInOrder, getVerticesInOrder, getVerticesInRange, getVerticesInRange, getVerticesWithPrefix, getVerticesWithPrefix, hasEventListeners, isPropertyDefined, prepareEdge, prepareEdge, prepareEdge, prepareEdge, prepareVertex, prepareVertex, prepareVertex, savePropertyDefinition, setMetadata, softDeleteEdge, softDeleteEdge, softDeleteEdge, softDeleteVertex, softDeleteVertex, softDeleteVertex, visit, visitEdges, visitElements, visitVertices

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.vertexium.Graph

addEdge, addEdge, addEdge, addEdge, addGraphEventListener, addVertex, addVertex, addVertices, createAuthorizations, createAuthorizations, createAuthorizations, defineProperty, deleteEdge, deleteVertex, doEdgesExist, doEdgesExist, doesEdgeExist, doesVertexExist, doVerticesExist, findPaths, findPaths, findPaths, findPaths, findRelatedEdgeIds, findRelatedEdgeIdsForVertices, findRelatedEdges, findRelatedEdges, findRelatedEdgeSummary, findRelatedEdgeSummaryForVertices, getEdge, getEdge, getEdges, getEdges, getEdges, getEdges, getEdgesInRange, getEdgesInRange, getExtendedData, getMetadata, getMetadata, getMetadataWithPrefix, getPropertyDefinition, getPropertyDefinitions, getVertex, getVertex, getVertices, getVertices, getVertices, getVertices, getVerticesInOrder, getVerticesInOrder, getVerticesInRange, getVerticesInRange, getVerticesWithPrefix, getVerticesWithPrefix, isPropertyDefined, prepareEdge, prepareEdge, prepareEdge, prepareEdge, prepareVertex, prepareVertex, prepareVertex, savePropertyDefinition, setMetadata, softDeleteEdge, softDeleteEdge, softDeleteEdge, softDeleteVertex, softDeleteVertex, softDeleteVertex, visit, visitEdges, visitElements, visitVertices

Field Detail

SINGLE_VERSION

public static final int SINGLE_VERSION

See Also:

Constant Field Values

ALL_VERSIONS

public static final Integer ALL_VERSIONS

elementMutationBuilder

protected final ElementMutationBuilder elementMutationBuilder

Constructor Detail

AccumuloGraph

protected AccumuloGraph(AccumuloGraphConfiguration config,
                        org.apache.accumulo.core.client.Connector connector)

Method Detail

create

public static AccumuloGraph create(AccumuloGraphConfiguration config)

setup

protected void setup()

Overrides:

setup in class GraphBaseWithSearchIndex

setupGraphMetadata

protected void setupGraphMetadata()

Overrides:

setupGraphMetadata in class GraphBaseWithSearchIndex

setupGraphMetadata

protected void setupGraphMetadata(GraphMetadataEntry graphMetadataEntry)

Overrides:

setupGraphMetadata in class GraphBaseWithSearchIndex

ensureTableExists

protected static void ensureTableExists(org.apache.accumulo.core.client.Connector connector,
                                        String tableName,
                                        Integer maxVersions,
                                        String hdfsContextClasspath,
                                        boolean createTable)

ensureRowDeletingIteratorIsAttached

protected static void ensureRowDeletingIteratorIsAttached(org.apache.accumulo.core.client.Connector connector,
                                                          String tableName)

create

public static AccumuloGraph create(Map config)

prepareVertex

public AccumuloVertexBuilder prepareVertex(String vertexId,
                                           Long timestamp,
                                           Visibility visibility)

Specified by:

prepareVertex in interface Graph

Specified by:

prepareVertex in class GraphBaseWithSearchIndex

addMutations

protected void addMutations(Element element,
                            org.apache.accumulo.core.data.Mutation... mutations)

addMutations

protected void addMutations(VertexiumObjectType objectType,
                            org.apache.accumulo.core.data.Mutation... mutations)

_addMutations

protected void _addMutations(org.apache.accumulo.core.client.BatchWriter writer,
                             org.apache.accumulo.core.data.Mutation... mutations)

getVerticesWriter

public org.apache.accumulo.core.client.BatchWriter getVerticesWriter()

getHistoryVerticesWriter

public org.apache.accumulo.core.client.BatchWriter getHistoryVerticesWriter()

getEdgesWriter

public org.apache.accumulo.core.client.BatchWriter getEdgesWriter()

getHistoryEdgesWriter

public org.apache.accumulo.core.client.BatchWriter getHistoryEdgesWriter()

getExtendedDataWriter

public org.apache.accumulo.core.client.BatchWriter getExtendedDataWriter()

getDataWriter

public org.apache.accumulo.core.client.BatchWriter getDataWriter()

getWriterFromElementType

public org.apache.accumulo.core.client.BatchWriter getWriterFromElementType(VertexiumObjectType objectType)

getHistoryWriterFromElementType

public org.apache.accumulo.core.client.BatchWriter getHistoryWriterFromElementType(VertexiumObjectType objectType)

getMetadataWriter

protected org.apache.accumulo.core.client.BatchWriter getMetadataWriter()

getVertices

public Iterable<Vertex> getVertices(FetchHints fetchHints,
                                    Long endTime,
                                    Authorizations authorizations)
                             throws VertexiumException

Specified by:

getVertices in interface Graph

Specified by:

getVertices in class GraphBaseWithSearchIndex

Throws:

VertexiumException

deleteVertex

public void deleteVertex(Vertex vertex,
                         Authorizations authorizations)

Specified by:

deleteVertex in interface Graph

Specified by:

deleteVertex in class GraphBaseWithSearchIndex

softDeleteVertex

public void softDeleteVertex(Vertex vertex,
                             Long timestamp,
                             Authorizations authorizations)

Specified by:

softDeleteVertex in interface Graph

Specified by:

softDeleteVertex in class GraphBaseWithSearchIndex

markVertexHidden

public void markVertexHidden(Vertex vertex,
                             Visibility visibility,
                             Authorizations authorizations)

Specified by:

markVertexHidden in interface Graph

Specified by:

markVertexHidden in class GraphBaseWithSearchIndex

markVertexVisible

public void markVertexVisible(Vertex vertex,
                              Visibility visibility,
                              Authorizations authorizations)

Specified by:

markVertexVisible in interface Graph

Specified by:

markVertexVisible in class GraphBaseWithSearchIndex

prepareEdge

public AccumuloEdgeBuilderByVertexId prepareEdge(String edgeId,
                                                 String outVertexId,
                                                 String inVertexId,
                                                 String label,
                                                 Long timestamp,
                                                 Visibility visibility)

Specified by:

prepareEdge in interface Graph

Specified by:

prepareEdge in class GraphBaseWithSearchIndex

prepareEdge

public EdgeBuilder prepareEdge(String edgeId,
                               Vertex outVertex,
                               Vertex inVertex,
                               String label,
                               Long timestamp,
                               Visibility visibility)

Specified by:

prepareEdge in interface Graph

Specified by:

prepareEdge in class GraphBaseWithSearchIndex

getNameSubstitutionStrategy

public AccumuloNameSubstitutionStrategy getNameSubstitutionStrategy()

getHistoricalPropertyValues

public Iterable<HistoricalPropertyValue> getHistoricalPropertyValues(Element element,
                                                                     String key,
                                                                     String name,
                                                                     Visibility visibility,
                                                                     Long startTime,
                                                                     Long endTime,
                                                                     Authorizations authorizations)

getStreamingPropertyValueInputStreams

public List<InputStream> getStreamingPropertyValueInputStreams(List<StreamingPropertyValue> streamingPropertyValues)

Specified by:

getStreamingPropertyValueInputStreams in interface Graph

Overrides:

getStreamingPropertyValueInputStreams in class GraphBase

getExtendedData

public Iterable<ExtendedDataRow> getExtendedData(Iterable<ExtendedDataRowId> ids,
                                                 Authorizations authorizations)

Specified by:

getExtendedData in interface Graph

Overrides:

getExtendedData in class GraphBase

getExtendedData

public Iterable<ExtendedDataRow> getExtendedData(ElementType elementType,
                                                 String elementId,
                                                 String tableName,
                                                 Authorizations authorizations)

Specified by:

getExtendedData in interface Graph

Overrides:

getExtendedData in class GraphBase

getExtendedDataInRange

public Iterable<ExtendedDataRow> getExtendedDataInRange(ElementType elementType,
                                                        Range elementIdRange,
                                                        Authorizations authorizations)

Specified by:

getExtendedDataInRange in interface Graph

Overrides:

getExtendedDataInRange in class GraphBase

getExtendedDataInRange

public Iterable<ExtendedDataRow> getExtendedDataInRange(Range extendedDataRowKeyRange,
                                                        Authorizations authorizations)

getEdges

public CloseableIterable<Edge> getEdges(FetchHints fetchHints,
                                        Long endTime,
                                        Authorizations authorizations)

Specified by:

getEdges in interface Graph

Specified by:

getEdges in class GraphBaseWithSearchIndex

deleteEdge

public void deleteEdge(Edge edge,
                       Authorizations authorizations)

Specified by:

deleteEdge in interface Graph

Specified by:

deleteEdge in class GraphBaseWithSearchIndex

deleteExtendedDataRow

public void deleteExtendedDataRow(ExtendedDataRowId rowId,
                                  Authorizations authorizations)

Specified by:

deleteExtendedDataRow in interface Graph

Specified by:

deleteExtendedDataRow in class GraphBase

softDeleteEdge

public void softDeleteEdge(Edge edge,
                           Long timestamp,
                           Authorizations authorizations)

Specified by:

softDeleteEdge in interface Graph

Specified by:

softDeleteEdge in class GraphBaseWithSearchIndex

markEdgeHidden

public void markEdgeHidden(Edge edge,
                           Visibility visibility,
                           Authorizations authorizations)

Specified by:

markEdgeHidden in interface Graph

Specified by:

markEdgeHidden in class GraphBaseWithSearchIndex

markEdgeVisible

public void markEdgeVisible(Edge edge,
                            Visibility visibility,
                            Authorizations authorizations)

Specified by:

markEdgeVisible in interface Graph

Specified by:

markEdgeVisible in class GraphBaseWithSearchIndex

createAuthorizations

public Authorizations createAuthorizations(String... auths)

Specified by:

createAuthorizations in interface Graph

Specified by:

createAuthorizations in class GraphBaseWithSearchIndex

markPropertyHidden

public void markPropertyHidden(AccumuloElement element,
                               Property property,
                               Long timestamp,
                               Visibility visibility,
                               Authorizations authorizations)

markPropertyVisible

public void markPropertyVisible(AccumuloElement element,
                                Property property,
                                Long timestamp,
                                Visibility visibility,
                                Authorizations authorizations)

flushGraph

public void flushGraph()

Specified by:

flushGraph in interface GraphWithSearchIndex

flush

public void flush()

Specified by:

flush in interface Graph

Overrides:

flush in class GraphBaseWithSearchIndex

shutdown

public void shutdown()

Specified by:

shutdown in interface Graph

Overrides:

shutdown in class GraphBaseWithSearchIndex

getVertexiumSerializer

public VertexiumSerializer getVertexiumSerializer()

getConfiguration

public AccumuloGraphConfiguration getConfiguration()

Overrides:

getConfiguration in class GraphBaseWithSearchIndex

getVertex

public Vertex getVertex(String vertexId,
                        FetchHints fetchHints,
                        Long endTime,
                        Authorizations authorizations)
                 throws VertexiumException

Specified by:

getVertex in interface Graph

Overrides:

getVertex in class GraphBase

Throws:

VertexiumException

getVerticesWithPrefix

public Iterable<Vertex> getVerticesWithPrefix(String vertexIdPrefix,
                                              FetchHints fetchHints,
                                              Long endTime,
                                              Authorizations authorizations)

Specified by:

getVerticesWithPrefix in interface Graph

Overrides:

getVerticesWithPrefix in class GraphBase

getVerticesInRange

public Iterable<Vertex> getVerticesInRange(Range idRange,
                                           FetchHints fetchHints,
                                           Long endTime,
                                           Authorizations authorizations)

Specified by:

getVerticesInRange in interface Graph

Overrides:

getVerticesInRange in class GraphBase

createVertexScanner

protected org.apache.accumulo.core.client.ScannerBase createVertexScanner(FetchHints fetchHints,
                                                                          Integer maxVersions,
                                                                          Long startTime,
                                                                          Long endTime,
                                                                          org.apache.accumulo.core.data.Range range,
                                                                          Authorizations authorizations)
                                                                   throws VertexiumException

Throws:

VertexiumException

createEdgeScanner

protected org.apache.accumulo.core.client.ScannerBase createEdgeScanner(FetchHints fetchHints,
                                                                        Integer maxVersions,
                                                                        Long startTime,
                                                                        Long endTime,
                                                                        org.apache.accumulo.core.data.Range range,
                                                                        Authorizations authorizations)
                                                                 throws VertexiumException

Throws:

VertexiumException

toIteratorFetchHints

public IteratorFetchHints toIteratorFetchHints(FetchHints fetchHints)

createVertexScanner

protected org.apache.accumulo.core.client.ScannerBase createVertexScanner(FetchHints fetchHints,
                                                                          Integer maxVersions,
                                                                          Long startTime,
                                                                          Long endTime,
                                                                          Collection<org.apache.accumulo.core.data.Range> ranges,
                                                                          Authorizations authorizations)
                                                                   throws VertexiumException

Throws:

VertexiumException

createEdgeScanner

protected org.apache.accumulo.core.client.ScannerBase createEdgeScanner(FetchHints fetchHints,
                                                                        Integer maxVersions,
                                                                        Long startTime,
                                                                        Long endTime,
                                                                        Collection<org.apache.accumulo.core.data.Range> ranges,
                                                                        Authorizations authorizations)
                                                                 throws VertexiumException

Throws:

VertexiumException

createBatchScanner

public org.apache.accumulo.core.client.ScannerBase createBatchScanner(String tableName,
                                                                      Collection<org.apache.accumulo.core.data.Range> ranges,
                                                                      Authorizations authorizations)
                                                               throws org.apache.accumulo.core.client.TableNotFoundException

Throws:

org.apache.accumulo.core.client.TableNotFoundException

createBatchScanner

public org.apache.accumulo.core.client.ScannerBase createBatchScanner(String tableName,
                                                                      Collection<org.apache.accumulo.core.data.Range> ranges,
                                                                      org.apache.accumulo.core.security.Authorizations accumuloAuthorizations)
                                                               throws org.apache.accumulo.core.client.TableNotFoundException

Throws:

org.apache.accumulo.core.client.TableNotFoundException

getColumnFamiliesToFetch

public static Iterable<org.apache.hadoop.io.Text> getColumnFamiliesToFetch(ElementType elementType,
                                                                           FetchHints fetchHints)

getTableNameFromElementType

public String getTableNameFromElementType(ElementType elementType)

getHistoryTableNameFromElementType

public String getHistoryTableNameFromElementType(ElementType elementType)

toAccumuloAuthorizations

public org.apache.accumulo.core.security.Authorizations toAccumuloAuthorizations(Authorizations authorizations)

getEdge

public Edge getEdge(String edgeId,
                    FetchHints fetchHints,
                    Long endTime,
                    Authorizations authorizations)

Specified by:

getEdge in interface Graph

Overrides:

getEdge in class GraphBase

visibilityToAccumuloVisibility

public static org.apache.accumulo.core.security.ColumnVisibility visibilityToAccumuloVisibility(Visibility visibility)

visibilityToAccumuloVisibility

public static org.apache.accumulo.core.security.ColumnVisibility visibilityToAccumuloVisibility(String visibilityString)

accumuloVisibilityToVisibility

public static Visibility accumuloVisibilityToVisibility(org.apache.accumulo.core.security.ColumnVisibility columnVisibility)

accumuloVisibilityToVisibility

public static Visibility accumuloVisibilityToVisibility(org.apache.hadoop.io.Text columnVisibility)

accumuloVisibilityToVisibility

public static Visibility accumuloVisibilityToVisibility(String columnVisibilityString)

getVerticesTableName

public static String getVerticesTableName(String tableNamePrefix)

getHistoryVerticesTableName

public static String getHistoryVerticesTableName(String tableNamePrefix)

getEdgesTableName

public static String getEdgesTableName(String tableNamePrefix)

getHistoryEdgesTableName

public static String getHistoryEdgesTableName(String tableNamePrefix)

getExtendedDataTableName

public static String getExtendedDataTableName(String tableNamePrefix)

getDataTableName

public static String getDataTableName(String tableNamePrefix)

getMetadataTableName

public static String getMetadataTableName(String tableNamePrefix)

getVerticesTableName

public String getVerticesTableName()

getHistoryVerticesTableName

public String getHistoryVerticesTableName()

getEdgesTableName

public String getEdgesTableName()

getHistoryEdgesTableName

public String getHistoryEdgesTableName()

getExtendedDataTableName

public String getExtendedDataTableName()

getDataTableName

public String getDataTableName()

getMetadataTableName

public String getMetadataTableName()

getStreamingPropertyValueStorageStrategy

public StreamingPropertyValueStorageStrategy getStreamingPropertyValueStorageStrategy()

getGraphLogger

public AccumuloGraphLogger getGraphLogger()

getConnector

public org.apache.accumulo.core.client.Connector getConnector()

listVerticesTableSplits

public Iterable<Range> listVerticesTableSplits()

listHistoryVerticesTableSplits

public Iterable<Range> listHistoryVerticesTableSplits()

listEdgesTableSplits

public Iterable<Range> listEdgesTableSplits()

listHistoryEdgesTableSplits

public Iterable<Range> listHistoryEdgesTableSplits()

listDataTableSplits

public Iterable<Range> listDataTableSplits()

listExtendedDataTableSplits

public Iterable<Range> listExtendedDataTableSplits()

alterEdgeLabel

public void alterEdgeLabel(AccumuloEdge edge,
                           String newEdgeLabel)

isVisibilityValid

public boolean isVisibilityValid(Visibility visibility,
                                 Authorizations authorizations)

Specified by:

isVisibilityValid in interface Graph

Specified by:

isVisibilityValid in class GraphBaseWithSearchIndex

truncate

public void truncate()

Specified by:

truncate in interface Graph

Specified by:

truncate in class GraphBaseWithSearchIndex

drop

public void drop()

Specified by:

drop in interface Graph

Specified by:

drop in class GraphBaseWithSearchIndex

findRelatedEdgeIds

public Iterable<String> findRelatedEdgeIds(Iterable<String> vertexIds,
                                           Long endTime,
                                           Authorizations authorizations)

Specified by:

findRelatedEdgeIds in interface Graph

Overrides:

findRelatedEdgeIds in class GraphBase

findRelatedEdgeSummary

public Iterable<RelatedEdge> findRelatedEdgeSummary(Iterable<String> vertexIds,
                                                    Long endTime,
                                                    Authorizations authorizations)

Specified by:

findRelatedEdgeSummary in interface Graph

Overrides:

findRelatedEdgeSummary in class GraphBase

findPaths

public Iterable<Path> findPaths(FindPathOptions options,
                                Authorizations authorizations)

Specified by:

findPaths in interface Graph

Overrides:

findPaths in class GraphBase

filterEdgeIdsByAuthorization

public Iterable<String> filterEdgeIdsByAuthorization(Iterable<String> edgeIds,
                                                     String authorizationToMatch,
                                                     EnumSet<ElementFilter> filters,
                                                     Authorizations authorizations)

Specified by:

filterEdgeIdsByAuthorization in interface Graph

Overrides:

filterEdgeIdsByAuthorization in class GraphBase

filterVertexIdsByAuthorization

public Iterable<String> filterVertexIdsByAuthorization(Iterable<String> vertexIds,
                                                       String authorizationToMatch,
                                                       EnumSet<ElementFilter> filters,
                                                       Authorizations authorizations)

Specified by:

filterVertexIdsByAuthorization in interface Graph

Overrides:

filterVertexIdsByAuthorization in class GraphBase

getMetadataInRange

public Iterable<GraphMetadataEntry> getMetadataInRange(org.apache.accumulo.core.data.Range range)

getGraphMetadataStore

protected GraphMetadataStore getGraphMetadataStore()

Specified by:

getGraphMetadataStore in class GraphBaseWithSearchIndex

getVerticesInRange

protected CloseableIterable<Vertex> getVerticesInRange(org.apache.accumulo.core.trace.Span trace,
                                                       org.apache.accumulo.core.data.Range range,
                                                       FetchHints fetchHints,
                                                       Long endTime,
                                                       Authorizations authorizations)

getVertices

public CloseableIterable<Vertex> getVertices(Iterable<String> ids,
                                             FetchHints fetchHints,
                                             Long endTime,
                                             Authorizations authorizations)

Specified by:

getVertices in interface Graph

Overrides:

getVertices in class GraphBase

getEdges

public CloseableIterable<Edge> getEdges(Iterable<String> ids,
                                        FetchHints fetchHints,
                                        Long endTime,
                                        Authorizations authorizations)

Specified by:

getEdges in interface Graph

Overrides:

getEdges in class GraphBase

getEdgesInRange

public Iterable<Edge> getEdgesInRange(Range idRange,
                                      FetchHints fetchHints,
                                      Long endTime,
                                      Authorizations authorizations)

Specified by:

getEdgesInRange in interface Graph

Overrides:

getEdgesInRange in class GraphBase

getEdgesInRange

protected CloseableIterable<Edge> getEdgesInRange(org.apache.accumulo.core.trace.Span trace,
                                                  String startId,
                                                  String endId,
                                                  FetchHints fetchHints,
                                                  Long timestamp,
                                                  Authorizations authorizations)
                                           throws VertexiumException

Throws:

VertexiumException

getEdgesInRange

protected CloseableIterable<Edge> getEdgesInRange(org.apache.accumulo.core.trace.Span trace,
                                                  org.apache.accumulo.core.data.Range range,
                                                  FetchHints fetchHints,
                                                  Long endTime,
                                                  Authorizations authorizations)
                                           throws VertexiumException

Throws:

VertexiumException

getVertexCount

public long getVertexCount(Authorizations authorizations)

Specified by:

getVertexCount in interface Graph

Overrides:

getVertexCount in class GraphBase

getEdgeCount

public long getEdgeCount(Authorizations authorizations)

Specified by:

getEdgeCount in interface Graph

Overrides:

getEdgeCount in class GraphBase

traceOn

public void traceOn(String description)

Specified by:

traceOn in interface Traceable

traceOn

public void traceOn(String description,
                    Map<String,String> data)

Specified by:

traceOn in interface Traceable

traceOff

public void traceOff()

Specified by:

traceOff in interface Traceable

getValueType

protected Class<?> getValueType(Object value)

Overrides:

getValueType in class GraphBase