Sha256: 9a1d22b520179760607d1689b426315d81d061680c8839a7e23b08f8de13fec0
Contents?: true
Size: 683 Bytes
Versions: 11
Compression:
Stored size: 683 Bytes
Contents
package com.xnlogic.pacer.pipes;
import java.util.Iterator;
import com.tinkerpop.blueprints.Graph;
import com.tinkerpop.blueprints.Vertex;
import com.tinkerpop.pipes.AbstractPipe;
public class VerticesPipe extends AbstractPipe<Graph, Vertex> {
private Iterator<Vertex> iter;
private Graph starts;
public void setStarts(Iterator<Graph> starts) {
// TODO: Error checking?
this.starts = (Graph)starts.next();
this.iter = this.starts.getVertices().iterator();
}
protected Vertex processNextStart() {
return this.iter.next();
}
public void reset() {
this.iter = this.starts.getVertices().iterator();
}
}
Version data entries
11 entries across 11 versions & 1 rubygems