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