This commit is contained in:
Michael Lieberman
2015-01-21 13:47:44 -05:00
parent 128b40346a
commit 7fb9cce693
2 changed files with 11 additions and 82 deletions

View File

@@ -55,12 +55,7 @@ import com.tinkerpop.blueprints.util.ExceptionFactory;
import edu.jhuapl.tinkerpop.cache.ElementCaches;
import edu.jhuapl.tinkerpop.mutator.Mutators;
import edu.jhuapl.tinkerpop.tables.EdgeIndexTableWrapper;
import edu.jhuapl.tinkerpop.tables.EdgeTableWrapper;
import edu.jhuapl.tinkerpop.tables.IndexNameTableWrapper;
import edu.jhuapl.tinkerpop.tables.IndexedKeysTableWrapper;
import edu.jhuapl.tinkerpop.tables.VertexIndexTableWrapper;
import edu.jhuapl.tinkerpop.tables.VertexTableWrapper;
/**
*
@@ -166,13 +161,6 @@ public class AccumuloGraph implements Graph, KeyIndexableGraph, IndexableGraph {
throw new AccumuloGraphException(e);
}
globals.setVertexWrapper(new VertexTableWrapper(globals));
globals.setEdgeWrapper(new EdgeTableWrapper(globals));
globals.setVertexIndexWrapper(new VertexIndexTableWrapper(globals));
globals.setEdgeIndexWrapper(new EdgeIndexTableWrapper(globals));
globals.setKeyMetadataWrapper(new IndexedKeysTableWrapper(globals));
globals.setIndexMetadataWrapper(new IndexNameTableWrapper(globals));
try {
setupWriters();
} catch (Exception e) {
@@ -215,6 +203,7 @@ public class AccumuloGraph implements Graph, KeyIndexableGraph, IndexableGraph {
* {@link VertexIndexTableWrapper}.
* @return
*/
@Deprecated
public Scanner getVertexIndexScanner() {
return getScanner(globals.getConfig().getVertexKeyIndexTableName());
}

View File

@@ -46,12 +46,6 @@ public class GlobalInstances {
private final AccumuloGraphConfiguration config;
private final MultiTableBatchWriter mtbw;
private VertexTableWrapper vertexWrapper;
private EdgeTableWrapper edgeWrapper;
private VertexIndexTableWrapper vertexIndexWrapper;
private EdgeIndexTableWrapper edgeIndexWrapper;
private IndexedKeysTableWrapper keyMetadataWrapper;
private IndexNameTableWrapper indexMetadataWrapper;
private final ElementCaches caches;
public GlobalInstances(AccumuloGraph graph,
@@ -77,34 +71,34 @@ public class GlobalInstances {
}
public VertexTableWrapper getVertexWrapper() {
return vertexWrapper;
return new VertexTableWrapper(this);
}
public EdgeTableWrapper getEdgeWrapper() {
return edgeWrapper;
return new EdgeTableWrapper(this);
}
public VertexIndexTableWrapper getVertexIndexWrapper() {
return vertexIndexWrapper;
return new VertexIndexTableWrapper(this);
}
public EdgeIndexTableWrapper getEdgeIndexWrapper() {
return edgeIndexWrapper;
return new EdgeIndexTableWrapper(this);
}
public IndexedKeysTableWrapper getKeyMetadataWrapper() {
return keyMetadataWrapper;
return new IndexedKeysTableWrapper(this);
}
public IndexNameTableWrapper getIndexMetadataWrapper() {
return indexMetadataWrapper;
return new IndexNameTableWrapper(this);
}
public <T extends Element> ElementTableWrapper getElementWrapper(Class<T> clazz) {
if (Vertex.class.equals(clazz)) {
return vertexWrapper;
return getVertexWrapper();
} else if (Edge.class.equals(clazz)) {
return edgeWrapper;
return getEdgeWrapper();
} else {
throw new AccumuloGraphException("Unrecognized class: "+clazz);
}
@@ -112,9 +106,9 @@ public class GlobalInstances {
public <T extends Element> IndexTableWrapper getKeyIndexWrapper(Class<T> clazz) {
if (Vertex.class.equals(clazz)) {
return vertexIndexWrapper;
return getVertexIndexWrapper();
} else if (Edge.class.equals(clazz)) {
return edgeIndexWrapper;
return getEdgeIndexWrapper();
} else {
throw new AccumuloGraphException("Unrecognized class: "+clazz);
}
@@ -136,58 +130,4 @@ public class GlobalInstances {
}
}
}
/**
* TODO: Refactor these away when the {@link #graph} member is gone.
* @param wrapper
*/
@Deprecated
public void setVertexWrapper(VertexTableWrapper wrapper) {
this.vertexWrapper = wrapper;
}
/**
* TODO: Refactor these away when the {@link #graph} member is gone.
* @param wrapper
*/
@Deprecated
public void setEdgeWrapper(EdgeTableWrapper wrapper) {
this.edgeWrapper = wrapper;
}
/**
* TODO: Refactor these away when the {@link #graph} member is gone.
* @param wrapper
*/
@Deprecated
public void setVertexIndexWrapper(VertexIndexTableWrapper wrapper) {
this.vertexIndexWrapper = wrapper;
}
/**
* TODO: Refactor these away when the {@link #graph} member is gone.
* @param wrapper
*/
@Deprecated
public void setEdgeIndexWrapper(EdgeIndexTableWrapper wrapper) {
this.edgeIndexWrapper = wrapper;
}
/**
* TODO: Refactor these away when the {@link #graph} member is gone.
* @param wrapper
*/
@Deprecated
public void setKeyMetadataWrapper(IndexedKeysTableWrapper wrapper) {
this.keyMetadataWrapper = wrapper;
}
/**
* TODO: Refactor these away when the {@link #graph} member is gone.
* @param wrapper
*/
@Deprecated
public void setIndexMetadataWrapper(IndexNameTableWrapper indexMetadataWrapper) {
this.indexMetadataWrapper = indexMetadataWrapper;
}
}