| Package | Description |
|---|---|
| org.vertexium.accumulo | |
| org.vertexium.accumulo.mapreduce | |
| org.vertexium.accumulo.tools | |
| org.vertexium.accumulo.util |
| Modifier and Type | Method and Description |
|---|---|
static AccumuloGraph |
AccumuloGraph.create(AccumuloGraphConfiguration config) |
static AccumuloGraph |
AccumuloGraph.create(Map config) |
AccumuloGraph |
AccumuloElement.getGraph() |
| Modifier and Type | Method and Description |
|---|---|
void |
ElementMutationBuilder.addPropertyToMutation(AccumuloGraph graph,
org.apache.accumulo.core.data.Mutation m,
String rowKey,
Property property) |
static Vertex |
AccumuloVertex.createFromIteratorValue(AccumuloGraph graph,
org.apache.accumulo.core.data.Key key,
org.apache.accumulo.core.data.Value value,
EnumSet<FetchHint> fetchHints,
Authorizations authorizations) |
static Edge |
AccumuloEdge.createFromIteratorValue(AccumuloGraph graph,
org.apache.accumulo.core.data.Key key,
org.apache.accumulo.core.data.Value value,
EnumSet<FetchHint> fetchHints,
Authorizations authorizations) |
void |
ElementMutationBuilder.saveEdgeBuilder(AccumuloGraph graph,
EdgeBuilderBase edgeBuilder,
long timestamp) |
void |
ElementMutationBuilder.saveVertexBuilder(AccumuloGraph graph,
VertexBuilder vertexBuilder,
long timestamp) |
StreamingPropertyValue |
StreamingPropertyValueHdfsRef.toStreamingPropertyValue(AccumuloGraph graph,
long timestamp) |
StreamingPropertyValue |
StreamingPropertyValueTableRef.toStreamingPropertyValue(AccumuloGraph graph,
long timestamp) |
| Constructor and Description |
|---|
AccumuloFindPathStrategy(AccumuloGraph graph,
FindPathOptions options,
ProgressCallback progressCallback,
Authorizations authorizations) |
AccumuloVertex(AccumuloGraph graph,
String vertexId,
Visibility vertexVisibility,
Iterable<Property> properties,
Iterable<PropertyDeleteMutation> propertyDeleteMutations,
Iterable<PropertySoftDeleteMutation> propertySoftDeleteMutations,
Iterable<Visibility> hiddenVisibilities,
com.google.common.collect.ImmutableSet<String> extendedDataTableNames,
Edges inEdges,
Edges outEdges,
long timestamp,
EnumSet<FetchHint> fetchHints,
Authorizations authorizations) |
AccumuloVertex(AccumuloGraph graph,
String vertexId,
Visibility vertexVisibility,
Iterable<Property> properties,
Iterable<PropertyDeleteMutation> propertyDeleteMutations,
Iterable<PropertySoftDeleteMutation> propertySoftDeleteMutations,
Iterable<Visibility> hiddenVisibilities,
com.google.common.collect.ImmutableSet<String> extendedDataTableNames,
long timestamp,
EnumSet<FetchHint> fetchHints,
Authorizations authorizations) |
LazyMutableProperty(AccumuloGraph graph,
VertexiumSerializer vertexiumSerializer,
String propertyKey,
String propertyName,
byte[] propertyValue,
LazyPropertyMetadata metadata,
Set<Visibility> hiddenVisibilities,
Visibility visibility,
long timestamp,
EnumSet<FetchHint> fetchHints) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract TValue |
AccumuloElementInputFormatBase.createElementFromRow(AccumuloGraph graph,
org.apache.accumulo.core.util.PeekingIterator<Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>> row,
Authorizations authorizations) |
protected Edge |
AccumuloEdgeInputFormat.createElementFromRow(AccumuloGraph graph,
org.apache.accumulo.core.util.PeekingIterator<Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>> row,
Authorizations authorizations) |
protected Vertex |
AccumuloVertexInputFormat.createElementFromRow(AccumuloGraph graph,
org.apache.accumulo.core.util.PeekingIterator<Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>> row,
Authorizations authorizations) |
static Vertex |
AccumuloVertexInputFormat.createVertex(AccumuloGraph graph,
Iterator<Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>> row,
Authorizations authorizations) |
protected static Iterable<Property> |
AccumuloElementInputFormatBase.makePropertiesFromElementData(AccumuloGraph graph,
ElementData elementData,
EnumSet<IteratorFetchHint> fetchHints) |
static void |
AccumuloEdgeInputFormat.setInputInfo(org.apache.hadoop.mapreduce.Job job,
AccumuloGraph graph,
String instanceName,
String zooKeepers,
String principal,
org.apache.accumulo.core.client.security.tokens.AuthenticationToken token,
String[] authorizations) |
static void |
AccumuloVertexInputFormat.setInputInfo(org.apache.hadoop.mapreduce.Job job,
AccumuloGraph graph,
String instanceName,
String zooKeepers,
String principal,
org.apache.accumulo.core.client.security.tokens.AuthenticationToken token,
String[] authorizations) |
| Constructor and Description |
|---|
DeleteHistoricalLegacyStreamingPropertyValueData(AccumuloGraph graph) |
| Modifier and Type | Method and Description |
|---|---|
static Iterable<Property> |
DataInputStreamUtils.decodeProperties(AccumuloGraph graph,
DataInputStream in,
EnumSet<FetchHint> fetchHints) |
Copyright © 2014–2017. All rights reserved.