Class Retain

  extended by cascading.pipe.Pipe
      extended by cascading.pipe.SubAssembly
          extended by cascading.pipe.assembly.Retain
All Implemented Interfaces:
FlowElement, Serializable

public class Retain
extends SubAssembly

Class Retain is a SubAssembly that will discard all incoming fields except those given on the constructor.

Use this pipe to narrow a stream of tuples, removing unused data.

See Also:
Discard, Serialized Form

Field Summary
Fields inherited from class cascading.pipe.Pipe
configDef, previous, stepConfigDef
Constructor Summary
Retain(Pipe previous, Fields retainFields)
Method Summary
Methods inherited from class cascading.pipe.SubAssembly
getConfigDef, getName, getPrevious, getStepConfigDef, getTailNames, getTails, setTails, unwind
Methods inherited from class cascading.pipe.Pipe
equals, getHeads, getTrace, hasConfigDef, hashCode, hasStepConfigDef, isEquivalentTo, named, names, outgoingScopeFor, pipes, print, printInternal, resolveIncomingOperationArgumentFields, resolveIncomingOperationPassThroughFields, toString
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail


public Retain(Pipe previous,
                                         Fields retainFields)

Copyright © 2007-2012 Concurrent, Inc. All Rights Reserved.