Home

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.1.0
Older JavaDocs (2.x): 2.0.0
Older JavaDocs (1.x): 1.0 – 0.9 – 0.8 – 0.7 – 0.6 – 0.5 – 0.4 – 0.3 – 0.2 – 0.1
For previous wikidocs, use the following URL schema: http://tinkerpop.com/docs/wikidocs/pipes/${version}/Home.html

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

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

Pipe<String,String> pipe1 = new RemoveCharacterPipe("o");
Pipe<String,Integer> pipe2 = new CountCharactersPipe();
Pipe<String,Integer> pipeline = new Pipeline<String,Integer>(pipe1, pipe2);
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)

---

• Basic Concepts
  • Basic Pipes
  • Pipe Types
    • Transform Pipes
    • Filter Pipes
    • SideEffect Pipes
  • Pipe SubTypes
    • MetaPipes
    • Branch Pipes
• Advanced Concepts
  • Creating a Pipe
  • Transformation Paths
• Conclusion
  • Acknowledgments
  • Release Notes

---

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