cascading.pipe
Class EndPipe

java.lang.Object
  cascading.pipe.Pipe
      cascading.pipe.EndPipe

All Implemented Interfaces:

FlowElement, Serializable

public class EndPipe
extends Pipe

*** Experimental - May be removed in a future iteration ***

Class EndPipe marks the end of a branch in a pipe assembly. Strictly this is not necessary, but it may allow for tagging meta-data to a Tap instance that comes immediately after it. It will also allow for branching after the Group to be handled in the reducer so that a reducer can write out to multiple output files.

Currently this tagging is used to mark a tap to by pass the default OutputCollector and to write 'directly' via a Tap TapCollector.

See Also:

Serialized Form

Field Summary

Fields inherited from class cascading.pipe.Pipe

previous

Constructor Summary

EndPipe(Pipe previous)

EndPipe(String name, Pipe previous)

Method Summary

Methods inherited from class cascading.pipe.Pipe

equals, getHeads, getName, getPrevious, hashCode, outgoingScopeFor, pipes, print, printInternal, resolveFields, resolveIncomingOperationFields, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

EndPipe

public EndPipe(String name,
               Pipe previous)

EndPipe

public EndPipe(Pipe previous)