Skip to content
This repository

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.5.02.4.02.3.02.2.02.1.02.0.01.00.90.80.70.60.50.40.30.20.1
Pipes WikiDocs: 2.5.02.4.02.3.02.2.02.1.02.0.0

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

Non-Maven users can get the raw release jars from Apache’s Central Repository. Snapshots can be obtained from Sonatype (see Maven Repositories for more information).

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.

Something went wrong with that request. Please try again.