JHUAPL/AccumuloGraph
1
0
Fork 0
mirror of https://github.com/JHUAPL/AccumuloGraph.git synced 2026-01-09 12:47:56 -05:00
Code Issues Packages Projects Releases 4 Wiki Activity

Use index parser in AccumuloIndex

Browse Source
This commit is contained in:
Michael Lieberman
2015-01-21 12:01:37 -05:00
parent a9d8ff7570
commit 3897998fca
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/main/java/edu/jhuapl/tinkerpop/AccumuloIndex.java
View File

@@ -14,6 +14,7 @@
*/
package edu.jhuapl.tinkerpop;
import java.util.Arrays;
import java.util.Iterator;
import java.util.Map.Entry;
@@ -32,7 +33,11 @@ import com.tinkerpop.blueprints.CloseableIterable;
import com.tinkerpop.blueprints.Edge;
import com.tinkerpop.blueprints.Element;
import com.tinkerpop.blueprints.Index;
import com.tinkerpop.blueprints.Vertex;
import edu.jhuapl.tinkerpop.parser.EdgeIndexParser;
import edu.jhuapl.tinkerpop.parser.ElementIndexParser;
import edu.jhuapl.tinkerpop.parser.VertexIndexParser;
import edu.jhuapl.tinkerpop.tables.NamedIndexTableWrapper;
/**
@@ -151,22 +156,17 @@ public class AccumuloIndex<T extends Element> implements Index<T> {
@Override
public Iterator<T> iterator() {
final ElementIndexParser<? extends AccumuloElement> parser =
Vertex.class.equals(indexedType) ? new VertexIndexParser(globals) :
new EdgeIndexParser(globals);
if (scan != null) {
return new ScannerIterable<T>(scan) {
@SuppressWarnings("unchecked")
@Override
public T next(PeekingIterator<Entry<Key, Value>> iterator) {
String id = iterator.next()
.getKey().getColumnQualifier().toString();
// TODO better use of information readily
// available...
if (indexedType.equals(Edge.class)) {
return (T) new AccumuloEdge(globals, id);
}
else {
return (T) new AccumuloVertex(globals, id);
}
return (T) parser.parse(Arrays.asList(iterator.next()));
}
}.iterator();
}