cascading.pipe.assembly
Class Retain

java.lang.Object
  extended by cascading.pipe.Pipe
      extended by cascading.pipe.SubAssembly
          extended by cascading.pipe.assembly.Retain
All Implemented Interfaces:
FlowElement, Traceable, 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, name, parent, stepConfigDef
 
Constructor Summary
Retain(Pipe previous, Fields retainFields)
           
 
Method Summary
 
Methods inherited from class cascading.pipe.SubAssembly
getName, getPrevious, getTailNames, getTails, setPrevious, setTails, unwind
 
Methods inherited from class cascading.pipe.Pipe
equals, getConfigDef, getHeads, getParent, getStepConfigDef, getTrace, hasConfigDef, hashCode, hasStepConfigDef, id, isEquivalentTo, named, names, outgoingScopeFor, pipes, print, printInternal, resolveIncomingOperationArgumentFields, resolveIncomingOperationPassThroughFields, setParent, toString
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

Retain

@ConstructorProperties(value={"previous","retainFields"})
public Retain(Pipe previous,
                                         Fields retainFields)


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