Skip to content

Home

Jump to bottom
okram edited this page Mar 20, 2013 · 109 revisions

Pipes is a dataflow framework using process graphs. A process graph is composed of Pipe vertices connected by communication edges. A Pipe implements a simple computational step that can be composed with other Pipe objects to create a larger computation. Such data flow graphs allow for the splitting, merging, looping, and in general, the transformation of data from input to output.

There are numerous Pipe classes that come with the main Pipes distribution. Once a good understanding of each Pipe accomplished, then using the framework is straightforward. In general, the best way to learn about all the Pipes provided is through the project JavaDoc.

Please join the Gremlin users group at http://groups.google.com/group/gremlin-users for all TinkerPop related discussions.

Pipes JavaDoc: 2.3.0 – 2.2.0 – 2.1.0 – 2.0.0 – 1.0 – 0.9 – 0.8 – 0.7 – 0.6 – 0.5 – 0.4 – 0.3 – 0.2 – 0.1
Pipes WikiDocs: 2.3.0 – 2.2.0 – 2.1.0 – 2.0.0

<dependency>
  <groupId>com.tinkerpop</groupId>
  <artifactId>pipes</artifactId>
  <version>2.3.0</version>
</dependency>

Non-Maven users can get the raw jars from Apache’s Central Repository.

Pipe<String,Integer> pipeline = new Pipeline<String,Integer>(
  new RemoveCharacterPipe("o"), 
  new CountCharactersPipe());
pipeline.setStarts(Arrays.asList("marko","josh","peter"));
for(Integer number : pipeline) {
  System.out.println(number);
}

4
3
5

On the Nature of Pipes (Graphical Presentation of the Pipe Mechanics)

1 Pipes documentation is up to date with the current Pipes codebase, not with the latest Pipes release.

Clone this wiki locally