Search Java Classes and Packages
# Classes and Interfaces in #Cascading - 503 results found.
| Name | Description | Type | Package | Framework |
| AggregateBy | The first role is as a base class for composable aggregate operations that have a MapReduce Map side optimization for the Reduce side aggregation. | Class | cascading.pipe.assembly | Cascading |
| AggregateByProps | Class | cascading.pipe.assembly | Cascading | |
| Aggregator | An Aggregator takes the set of all values associated with a unique grouping and returns zero or more values. | Interface | cascading.operation | Cascading |
| AggregatorCall | This interface is generic, allowing the user to set a custom 'context' object when Aggregator. | Interface | cascading.operation | Cascading |
| AggregatorEveryStage | Class | cascading.flow.stream.element | Cascading | |
| And | Logically, if Filter. | Class | cascading.operation.filter | Cascading |
| AndElementExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
| AnnotatedDecoratedElementGraph | Class | cascading.flow.planner.graph | Cascading | |
| AnnotatedGraph | Interface | cascading.flow.planner.graph | Cascading | |
| AnnotateGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
| AnnotationExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
| ApplyAssertionLevelTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
| ApplyDebugLevelTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
| AppProps | Flow may or may not be required to have set. | Class | cascading.property | Cascading |
| AssemblyPlanner | This allows for new languages or frameworks that may require additional meta-data from the underlying platform or environment. | Interface | cascading.flow | Cascading |
| Asserted | Class | cascading.flow.planner.iso.assertion | Cascading | |
| AssertEquals | to the number of argument values Tuple and each constructor value is . | Class | cascading.operation.assertion | Cascading |
| AssertEqualsAll | provided on the constructor. | Class | cascading.operation.assertion | Cascading |
| AssertExpression | returns true for the given expression pass the assertion. | Class | cascading.operation.assertion | Cascading |
| AssertGroupBase | Class | cascading.operation.assertion | Cascading | |
| AssertGroupSizeEquals | is equal the given size. | Class | cascading.operation.assertion | Cascading |
| AssertGroupSizeLessThan | Class AssertGroupSizeEquals is an GroupAssertion that asserts the number of items in the current group is less than the given size. | Class | cascading.operation.assertion | Cascading |
| AssertGroupSizeMoreThan | Class AssertGroupSizeEquals is an GroupAssertion that asserts the number of items in the current group is more than the given size. | Class | cascading.operation.assertion | Cascading |
| Assertion | Interface | cascading.operation | Cascading | |
| AssertionException | Class | cascading.operation | Cascading | |
| AssertionLevel | Enum AssertionLevel designates the level of a given Assertion instance. | Class | cascading.operation | Cascading |
| AssertMatches | Tuple by joining each individual element of the Tuple with a tab character (\t) unless otherwise specified. | Class | cascading.operation.assertion | Cascading |
| AssertMatchesAll | Tuple element individually. | Class | cascading.operation.assertion | Cascading |
| AssertNotEquals | to the number of argument values Tuple and each constructor value is not . | Class | cascading.operation.assertion | Cascading |
| AssertNotNull | Class | cascading.operation.assertion | Cascading | |
| AssertNull | Class | cascading.operation.assertion | Cascading | |
| AssertSizeEquals | On evaluation, Tuple. | Class | cascading.operation.assertion | Cascading |
| AssertSizeLessThan | On evaluation, Tuple. | Class | cascading.operation.assertion | Cascading |
| AssertSizeMoreThan | On evaluation, Tuple. | Class | cascading.operation.assertion | Cascading |
| Average | Class | cascading.operation.aggregator | Cascading | |
| AverageBy | Typically finding the average value in a tuple stream relies on a GroupBy and a Average Aggregator operation. | Class | cascading.pipe.assembly | Cascading |
| BaseAnnotatedElementGraph | Class | cascading.flow.planner.graph | Cascading | |
| BaseAssertion | this class is not required, but does provide some convenience functions for signaling assertion failures. | Class | cascading.operation.assertion | Cascading |
| BaseCacheFactory | Base class for all CacheFactories for creating CascadingCache instances. | Class | cascading.util.cache | Cascading |
| BaseCascade | Class | cascading.cascade | Cascading | |
| BaseElementGraph | Class | cascading.flow.planner.graph | Cascading | |
| BaseFlow | Class | cascading.flow | Cascading | |
| BaseFlowNode | Class | cascading.flow.planner | Cascading | |
| BaseFlowStep | Class FlowStep is an internal representation of a given Job to be executed on a remote cluster. | Class | cascading.flow.planner | Cascading |
| BaseJoiner | Class | cascading.pipe.joiner | Cascading | |
| BaseOperation | the Each or Every Pipe. | Class | cascading.operation | Cascading |
| BasePartitionTap | Class | cascading.tap.partition | Cascading | |
| BaseProcessGraph | Class | cascading.flow.planner.process | Cascading | |
| BaseState | Class | cascading.management.state | Cascading | |
| BigDecimalCoerce | Class | cascading.tuple.coerce | Cascading | |
| BlockingHashJoinAnnotator | Class | cascading.flow.planner.rule.annotator | Cascading | |
| BlockingMode | Class | cascading.flow.stream.annotations | Cascading | |
| BooleanCoerce | Class | cascading.tuple.coerce | Cascading | |
| BooleanObjectCoerce | Class | cascading.tuple.coerce | Cascading | |
| BoundariesElementExpression | Class | cascading.flow.planner.rule.elementexpression | Cascading | |
| Boundary | The Boundary class is only used internally by the planner to mark the boundaries between partitions within In MapReduce, Taps are used. | Class | cascading.pipe | Cascading |
| BoundaryElementFactory | Class | cascading.flow.planner.rule.transformer | Cascading | |
| BoundaryStage | Class | cascading.flow.stream.element | Cascading | |
| BoundedElementMultiGraph | Class | cascading.flow.planner.graph | Cascading | |
| Buffer | A Buffer is similar to an Aggregator by the fact that it operates on unique groups of values. | Interface | cascading.operation | Cascading |
| BufferAfterEveryAssert | Class | cascading.flow.planner.rule.assertion | Cascading | |
| BufferAfterEveryExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
| BufferCall | Interface | cascading.operation | Cascading | |
| BufferEveryWindow | Class | cascading.flow.stream.element | Cascading | |
| BufferJoin | will implement a custom join strategy. | Class | cascading.pipe.joiner | Cascading |
| CacheEvictionCallback | CacheEvictionCallBack is an interface to be used in conjunction with CascadingCache instances. | Interface | cascading.util.cache | Cascading |
| Cascade | A Cascade is an assembly of Flow instances that share or depend on equivalent Tap instances and are executed as a single group. | Interface | cascading.cascade | Cascading |
| CascadeConnector | Note order is not significant when adding passing Flow instances to the connect method. | Class | cascading.cascade | Cascading |
| CascadeDef | This allows for ad-hoc building of Cascade data and meta-data like tags. | Class | cascading.cascade | Cascading |
| CascadeException | Class | cascading.cascade | Cascading | |
| CascadeListener | Any RuntimeException thrown from any of the listener methods will force the given cascade to stop by calling Cascade. | Interface | cascading.cascade | Cascading |
| CascadeProps | through a CascadeConnector. | Class | cascading.cascade | Cascading |
| Cascades | instances via the CascadeConnector and FlowConnector, respectively. | Class | cascading.cascade | Cascading |
| CascadeStats | Class | cascading.stats | Cascading | |
| CascadingCache | Interface that defines a Cache. | Interface | cascading.util.cache | Cascading |
| CascadingException | Class | cascading | Cascading | |
| CascadingFactory | Factory instances are created process side (in a cluster for example) to augment any of the internal strategies. | Interface | cascading.provider | Cascading |
| CascadingService | Interface | cascading.provider | Cascading | |
| CascadingServices | monitoring and management systems. | Class | cascading.management | Cascading |
| CascadingStats | core elements that have state. | Class | cascading.stats | Cascading |
| CascadingTestCase | It included a few helpful utility methods for testing Cascading applications. | Class | cascading | Cascading |
| CharacterCoerce | Class | cascading.tuple.coerce | Cascading | |
| CharacterObjectCoerce | Class | cascading.tuple.coerce | Cascading | |
| Checkpoint | The Checkpoint pipe, if supported by the current planner, will force data to be persisted at the point in the tuple stream an instance of Checkpoint is inserted into the pipe assembly. | Class | cascading.pipe | Cascading |
| ClientState | Class | cascading.management.state | Cascading | |
| CloseableIterator | Interface | cascading.util | Cascading | |
| CloseReducingDuct | Class | cascading.flow.stream.duct | Cascading | |
| Coerce | If the given type is a primitive (long), and the tuple value is null, 0 is returned. | Class | cascading.pipe.assembly | Cascading |
| CoercibleType | It is the role of implementations of this interface to maintain a canonical representation of a given value and to allow for coercions between some type representation to the canonical type and back. | Interface | cascading.tuple.type | Cascading |
| Coercions | Coercions class is a helper class for managing primitive value coercions. | Class | cascading.tuple.coerce | Cascading |
| CoGroup | The CoGroup pipe allows for two or more tuple streams to join into a single stream via an optional Joiner. | Class | cascading.pipe | Cascading |
| Comparison | The Comparison interface allows specific underlying type mechanisms to additionally return relevant Comparator implementations when required internally. | Interface | cascading.tuple | Cascading |
| ComponentAttributeProvider | Interface | cascading.util.jgrapht | Cascading | |
| CompositeTap | This information is required by the planner in order to properly configure the underlying platform. | Interface | cascading.tap | Cascading |
| ConcreteCall | Class OperationCall is the common base class for FunctionCall, FilterCall, AggregatorCall, ValueAssertionCall, and GroupAssertionCall. | Class | cascading.operation | Cascading |
| ConcreteCall | The concrete base class for SourceCall and SinkCall. | Class | cascading.scheme | Cascading |
| ConfigDef | The ConfigDef class allows for the creation of a configuration properties template to be applied to an existing properties configuration set. | Class | cascading.property | Cascading |
| ConsecutiveTapsExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| ContractedGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
| ContractedTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
| Count | Note the resulting value for count is always a long. | Class | cascading.operation.aggregator | Cascading |
| CountBy | values for the groupingFields fields. | Class | cascading.pipe.assembly | Cascading |
| Counter | Internally, the isRemove(cascading. | Class | cascading.operation.state | Cascading |
| DateFormatter | is the number of milliseconds since January 1, 1970, 00:00:00 GMT, using the SimpleDateFormat syntax. | Class | cascading.operation.text | Cascading |
| DateOperation | Class | cascading.operation.text | Cascading | |
| DateParser | since January 1, 1970, 00:00:00 GMT, using the SimpleDateFormat syntax. | Class | cascading.operation.text | Cascading |
| DateType | Class DateCoercibleType is an implementation of CoercibleType. | Class | cascading.tuple.type | Cascading |
| Debug | Currently, if printFields is true, they will print every 10 Tuples. | Class | cascading.operation | Cascading |
| DebugLevel | Enum DebugLevel designates the level of a given Debug instance. | Class | cascading.operation | Cascading |
| DecoratedElementGraph | Class | cascading.flow.planner.graph | Cascading | |
| DecoratorTap | It also provides an additional generic field that may hold any custom type, this allows implementations to attach any meta-info to the tap being decorated. | Class | cascading.tap | Cascading |
| DelimitedParser | It maybe sub-classed to change its behavior. | Class | cascading.scheme.util | Cascading |
| DelimitedPartition | DelimitedPartition is an implementation of the Partition interface that allows for simple text delimited paths as partitions. | Class | cascading.tap.partition | Cascading |
| DirectMappedCache | DirectMappedCache is an implementation of the CascadingCache interface following the semantics of http://en. | Class | cascading.util.cache | Cascading |
| DirectMappedCacheFactory | Concrete sub-class of BaseCacheFactory for creating DirectMappedCache instances. | Class | cascading.util.cache | Cascading |
| Discard | Use this pipe to narrow a stream of tuples, removing unused data. | Class | cascading.pipe.assembly | Cascading |
| DocumentService | Interface | cascading.management | Cascading | |
| DocumentServiceException | Exception DocumentServiceException is thrown from within a DocumentService instance. | Class | cascading.management | Cascading |
| DOTExporter | Class | cascading.util.jgrapht | Cascading | |
| DOTProcessGraphWriter | This class is a derivative of the JGraphT DOTExporter, with numerous enhancements but with retained compatibility. | Class | cascading.util | Cascading |
| DoubleCoerce | Class | cascading.tuple.coerce | Cascading | |
| DoubleObjectCoerce | Class | cascading.tuple.coerce | Cascading | |
| DualStreamedAccumulatedExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| Duct | Class | cascading.flow.stream.duct | Cascading | |
| DuctException | Class | cascading.flow.stream.duct | Cascading | |
| DuctGraph | Class | cascading.flow.stream.duct | Cascading | |
| Each | The Each operator applies either a Function or a Filter to each entry in the Tuple stream. | Class | cascading.pipe | Cascading |
| EachStage | Class | cascading.flow.stream.element | Cascading | |
| ElementAnnotation | Class | cascading.flow.planner.iso | Cascading | |
| ElementCapture | Class | cascading.flow.planner.iso.expression | Cascading | |
| ElementDirectedGraph | Class | cascading.flow.planner.graph | Cascading | |
| ElementDuct | Interface | cascading.flow.stream.element | Cascading | |
| ElementExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
| ElementFactory | Interface | cascading.flow.planner.iso.transformer | Cascading | |
| ElementFlowProcess | Class | cascading.flow.stream.element | Cascading | |
| ElementGraph | An element graph represents an assembly of Pipe instances bound to source and sink Typically an element graph is fed to a FlowPlanner which in return creates | Interface | cascading.flow.planner.graph | Cascading |
| ElementGraphException | the Cascading internal "graph" representation. | Class | cascading.flow.planner | Cascading |
| ElementGraphs | Class | cascading.flow.planner.graph | Cascading | |
| ElementMaskSubGraph | Class | cascading.flow.planner.graph | Cascading | |
| ElementMultiGraph | Class | cascading.flow.planner.graph | Cascading | |
| ElementStage | Class | cascading.flow.stream.element | Cascading | |
| ElementSubGraph | Class | cascading.flow.planner.graph | Cascading | |
| EnumMultiMap | Class | cascading.util | Cascading | |
| Every | The Every operator applies an Aggregator or Buffer to every grouping. | Class | cascading.pipe | Cascading |
| EveryAfterBufferAssert | Class | cascading.flow.planner.rule.assertion | Cascading | |
| EveryAfterBufferExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
| EveryStage | Class | cascading.flow.stream.element | Cascading | |
| ExecAction | Class | cascading.flow.planner.rule | Cascading | |
| Expression | Interface | cascading.flow.planner.iso.expression | Cascading | |
| ExpressionFilter | returns true for the given expression will be removed from the stream. | Class | cascading.operation.expression | Cascading |
| ExpressionFunction | is based on the Janino compiler. | Class | cascading.operation.expression | Cascading |
| ExpressionGraph | Class | cascading.flow.planner.iso.expression | Cascading | |
| ExpressionGraphPartitioner | Class | cascading.flow.planner.iso.subgraph.partitioner | Cascading | |
| ExpressionOperation | Class | cascading.operation.expression | Cascading | |
| ExpressionRulePartitioner | sub-graphs as partitions. | Class | cascading.flow.planner.rule.partitioner | Cascading |
| ExpressionSubGraphIterator | Class | cascading.flow.planner.iso.subgraph.iterator | Cascading | |
| Extent | Enum Extent provides simple markers for the head and tail of an ElementGraph FlowElement graph. | Class | cascading.flow.planner.graph | Cascading |
| ExtentBase | Class | cascading.operation.aggregator | Cascading | |
| ExtremaValueBase | Comparable types and the Comparable. | Class | cascading.operation.aggregator | Cascading |
| FactoryLoader | CascadingFactory instances used by internal frameworks. | Class | cascading.provider | Cascading |
| FieldFormatter | This function uses the Formatter class for formatting the argument tuple values into a new string. | Class | cascading.operation.text | Cascading |
| FieldJoiner | Class | cascading.operation.text | Cascading | |
| Fields | name, or it may be a literal Integer value representing a position, where positions start at position 0. | Class | cascading.tuple | Cascading |
| FieldsResolverException | select from the sourceFields. | Class | cascading.tuple | Cascading |
| FieldTypeResolver | Interface | cascading.scheme.util | Cascading | |
| FileType | Interface | cascading.tap.type | Cascading | |
| Filter | A Filter is responsible for testing a Tuple to see if it should be removed from the tuple stream. | Interface | cascading.operation | Cascading |
| FilterCall | Interface | cascading.operation | Cascading | |
| FilterEachStage | Class | cascading.flow.stream.element | Cascading | |
| FilterNotNull | is a null value. | Class | cascading.operation.filter | Cascading |
| FilterNull | is not a null value. | Class | cascading.operation.filter | Cascading |
| First | By default, it returns the first Tuple of Fields. | Class | cascading.operation.aggregator | Cascading |
| FirstBy | Typically finding the first Tuple in a tuple stream grouping relies on a GroupBy and a First Aggregator operation. | Class | cascading.pipe.assembly | Cascading |
| FirstNBuffer | are returned the Buffer stops iterating the arguments unlike the First Aggregator which by contract sees all the values in the grouping. | Class | cascading.operation.buffer | Cascading |
| FloatCoerce | Class | cascading.tuple.coerce | Cascading | |
| FloatObjectCoerce | Class | cascading.tuple.coerce | Cascading | |
| Flow | A Flow is a logical unit of work declared by an assembly of Pipe instances connected to source and sink Tap instances. | Interface | cascading.flow | Cascading |
| FlowConnector | See the FlowDef class for a fluent way to define a new Flow. | Class | cascading.flow | Cascading |
| FlowConnectorProps | The class FlowConnectorProps is a fluent helper class for setting FlowConnector specific properties through the FlowConnector constructor. | Class | cascading.flow | Cascading |
| FlowDef | This allows for ad-hoc building of Flow data and meta-data, like tags. | Class | cascading.flow | Cascading |
| FlowDescriptors | Constants to be used as key in Flow#getFlowDescriptor. | Interface | cascading.flow | Cascading |
| FlowElement | for users to interact with these methods directly. | Interface | cascading.flow | Cascading |
| FlowElementExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
| FlowElementGraph | Class ElementGraph represents the executable FlowElement graph. | Class | cascading.flow.planner.graph | Cascading |
| FlowElements | Class | cascading.flow | Cascading | |
| FlowException | FlowException instances are thrown on errors when executing a Flow. | Class | cascading.flow | Cascading |
| FlowGraph | Class | cascading.cascade.planner | Cascading | |
| FlowListener | Any RuntimeException thrown from any of the listener methods will force the given flow to stop by calling Flow. | Interface | cascading.flow | Cascading |
| FlowNode | FlowStep and may have many siblings within the FlowStep. | Interface | cascading.flow | Cascading |
| FlowNodeGraph | Class | cascading.flow.planner.process | Cascading | |
| FlowNodeStats | Class | cascading.stats | Cascading | |
| FlowPlanner | This planner support tracing execution of each rule. | Class | cascading.flow.planner | Cascading |
| FlowProcess | FlowProcess implementations provide a call-back interface into the current computing system. | Class | cascading.flow | Cascading |
| FlowProcessWrapper | Class | cascading.flow | Cascading | |
| FlowProps | Class | cascading.flow | Cascading | |
| FlowRuntimeProps | These properties apply to the cluster or remote side of the Flow execution. | Class | cascading.flow | Cascading |
| Flows | Flows is a utility helper class. | Class | cascading.flow | Cascading |
| FlowSession | FlowSession implementations provide a call-back interface into the current flow management system, if any. | Class | cascading.flow | Cascading |
| FlowSkipIfSinkExists | true if the Flow sink exists, regardless if it is stale or not. | Class | cascading.flow | Cascading |
| FlowSkipIfSinkNotStale | true if the Flow sink exists and is not stale in relation to the Flow sources. | Class | cascading.flow | Cascading |
| FlowSkipStrategy | be skipped when executed in a Cascade. | Interface | cascading.flow | Cascading |
| FlowSliceStats | Typically CascadingStats objects have an internal state model with timings, the FlowSliceStats is a simplified Stats object and only reports what the underlying platform reports, not the client side observations. | Class | cascading.stats | Cascading |
| FlowStats | Class | cascading.stats | Cascading | |
| FlowStep | planning, pipe assemblies are broken down into "steps" and encapsulated in this class. | Interface | cascading.flow | Cascading |
| FlowStepGraph | Class | cascading.flow.planner.process | Cascading | |
| FlowStepJob | Class | cascading.flow.planner | Cascading | |
| FlowStepListener | Interface | cascading.flow | Cascading | |
| FlowStepStats | Class | cascading.stats | Cascading | |
| FlowStepStrategy | The FlowStepStrategy interface allows for on the fly customization of FlowStep configuration values before they are submitted to the underlying platform. | Interface | cascading.flow | Cascading |
| ForeverValueIterator | The ForeverValueIterator class will iterate over a single value forever. | Class | cascading.util | Cascading |
| Fork | Class | cascading.flow.stream.duct | Cascading | |
| Function | A Function is responsible for taking Tuple arguments and returning one or more result Tuples. | Interface | cascading.operation | Cascading |
| FunctionCall | Interface | cascading.operation | Cascading | |
| FunctionEachStage | Class | cascading.flow.stream.element | Cascading | |
| Gate | Class | cascading.flow.stream.duct | Cascading | |
| GraphAssert | Class | cascading.flow.planner.iso.assertion | Cascading | |
| GraphFinder | Class | cascading.flow.planner.iso.finder | Cascading | |
| GraphFinderException | Class | cascading.flow.planner.iso.finder | Cascading | |
| GraphPartitioner | Class | cascading.flow.planner.iso.subgraph | Cascading | |
| GraphResult | Class | cascading.flow.planner.iso | Cascading | |
| GraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
| Group | Interface | cascading.pipe | Cascading | |
| GroupAssertion | Implementers should also extend BaseOperation. | Interface | cascading.operation | Cascading |
| GroupAssertionCall | This interface is generic, allowing the user to set a custom 'context' object when GroupAssertion. | Interface | cascading.operation | Cascading |
| GroupAssertionEveryStage | Class | cascading.flow.stream.element | Cascading | |
| GroupBy | The GroupBy pipe groups the Tuple stream by the given groupFields. | Class | cascading.pipe | Cascading |
| Grouping | Class | cascading.flow.stream.duct | Cascading | |
| GroupingSpliceGate | Class | cascading.flow.stream.element | Cascading | |
| GroupOrMergeElementExpression | Class | cascading.flow.planner.rule.elementexpression | Cascading | |
| GroupTapExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| Hasher | The Hasher allows a Comparator implementation to also be delegated to during hashCode generation during grouping partitioning. | Interface | cascading.tuple | Cascading |
| HashJoin | The HashJoin pipe allows for two or more tuple streams to join into a single stream via a Joiner when all but one tuple stream is considered small enough to fit into memory. | Class | cascading.pipe | Cascading |
| HashJoinBlockingHashJoinAnnotator | Class | cascading.flow.planner.rule.annotator | Cascading | |
| IdentifierGraph | Class | cascading.cascade.planner | Cascading | |
| Identity | The Identity function simply passes incoming arguments back out again. | Class | cascading.operation | Cascading |
| IgnoreAnnotationsHashSet | Class | cascading.flow.planner.graph | Cascading | |
| IgnoresAnnotationsElementGraph | Class | cascading.flow.planner.graph | Cascading | |
| IncludeRemainderSubGraphIterator | Class | cascading.flow.planner.iso.subgraph.iterator | Cascading | |
| IndexTuple | Class | cascading.tuple.io | Cascading | |
| InnerJoin | and inner join of the CoGrouper internal grouped tuple collections. | Class | cascading.pipe.joiner | Cascading |
| Insert | Class | cascading.operation | Cascading | |
| InsertionGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
| IntegerCoerce | Class | cascading.tuple.coerce | Cascading | |
| IntegerNameProvider | Class | cascading.util.jgrapht | Cascading | |
| IntegerObjectCoerce | Class | cascading.tuple.coerce | Cascading | |
| IntermediateTapElementFactory | Class | cascading.flow.planner.rule.transformer | Cascading | |
| IORole | Enum IORole specifies how a FlowElement will be used during streaming. | Class | cascading.flow.stream.graph | Cascading |
| Joiner | Joins perform based on the equality of the join keys. | Interface | cascading.pipe.joiner | Cascading |
| JoinerClosure | This class is provided to a Joiner. | Class | cascading.pipe.joiner | Cascading |
| Last | By default, it returns the last Tuple of Fields. | Class | cascading.operation.aggregator | Cascading |
| LeftJoin | a left inner, right outer join of the CoGrouper internal grouped tuple collections. | Class | cascading.pipe.joiner | Cascading |
| Limit | Note that the limit value is roughly a suggestion. | Class | cascading.operation.filter | Cascading |
| Logic | Class | cascading.operation.filter | Cascading | |
| LogUtil | Class | cascading.util | Cascading | |
| LoneGroupAssert | Verifies that there are not only GroupAssertions following any given Group instance. | Class | cascading.flow.planner.rule.assertion | Cascading |
| LoneGroupExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
| LongCoerce | Class | cascading.tuple.coerce | Cascading | |
| LongObjectCoerce | Class | cascading.tuple.coerce | Cascading | |
| LRUHashMapCache | evict the least recently used key. | Class | cascading.util.cache | Cascading |
| LRUHashMapCacheFactory | Class | cascading.util.cache | Cascading | |
| Match | Class | cascading.flow.planner.iso.finder | Cascading | |
| MaxBy | Typically finding the max value of a field in a tuple stream relies on a GroupBy and a MaxValue Aggregator operation. | Class | cascading.pipe.assembly | Cascading |
| MaxValue | Values are expected to be Comparable types vs numeric representations and the Comparable. | Class | cascading.operation.aggregator | Cascading |
| MemoryCoGroupClosure | Class | cascading.flow.stream.element | Cascading | |
| MemoryCoGroupGate | Class | cascading.flow.stream.element | Cascading | |
| MemoryHashJoinGate | Class | cascading.flow.stream.element | Cascading | |
| MemorySpliceGate | Class | cascading.flow.stream.element | Cascading | |
| Merge | The Merge Pipe allows for multiple branches, with the same fields to be spliced back into a single stream. | Class | cascading.pipe | Cascading |
| MergeStage | Class | cascading.flow.stream.element | Cascading | |
| MetricsService | Interface | cascading.management | Cascading | |
| MinBy | Typically finding the min value of a field in a tuple stream relies on a GroupBy and a MinValue Aggregator operation. | Class | cascading.pipe.assembly | Cascading |
| MinValue | Class Min is an Aggregator that returns the minimum value encountered in the current group. | Class | cascading.operation.aggregator | Cascading |
| MissingGroupAssert | Class | cascading.flow.planner.rule.assertion | Cascading | |
| MissingGroupExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
| MixedJoin | Joiner and return tuples that represent a join as defined by the given boolean array. | Class | cascading.pipe.joiner | Cascading |
| MultiMap | Class | cascading.util | Cascading | |
| MultiSinkTap | multiple child Tap instances simultaneously. | Class | cascading.tap | Cascading |
| MultiSourceTap | multiple files to be concatenated into the requesting pipe assembly, if they all share the same Scheme instance. | Class | cascading.tap | Cascading |
| MultiTapGroupExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| Murmur3 | Murmur3 is a fast non cryptographic hash algorithm. | Class | cascading.util | Cascading |
| MutateGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
| NoCoGroupJoinTapExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| NodeStreamGraph | Class | cascading.flow.stream.graph | Cascading | |
| NoGroupJoinMergeBoundaryTapExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| NoGroupJoinTapExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| NoGroupTapExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| NoMergeTapExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| NonBlockedBlockedJoinAnnotatorExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
| NonBlockedBlockedJoinExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| NonBlockedBlockedJoinJoinAnnotatorExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
| NonBlockedBlockedJoinJoinExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| NonSafeAndSplitAndSyncPipeExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| NonSafeOperationExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
| NoOp | Use with Fields. | Class | cascading.operation | Cascading |
| NoOpPipeExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
| NoOpPipeExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| Not | Logically, if Filter. | Class | cascading.operation.filter | Cascading |
| NotElementExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
| NullNotEquivalentComparator | the result of lhs. | Class | cascading.util | Cascading |
| NullScheme | It is typically used as a placeholder where a Scheme instance is needed but generally ignored. | Class | cascading.scheme | Cascading |
| ObjectCoerce | Class | cascading.tuple.coerce | Cascading | |
| OnlyPipeExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| OpenDuct | Class | cascading.flow.stream.duct | Cascading | |
| OpenReducingDuct | Class | cascading.flow.stream.duct | Cascading | |
| Operation | Specifically Function, Filter, Aggregator, Buffer, and Assertion. | Interface | cascading.operation | Cascading |
| OperationCall | Interface | cascading.operation | Cascading | |
| OperationException | Class | cascading.operation | Cascading | |
| OperationExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
| Operator | An Operator is a type of Pipe. | Class | cascading.pipe | Cascading |
| OperatorException | Class | cascading.pipe | Cascading | |
| OperatorStage | Class | cascading.flow.stream.element | Cascading | |
| Or | Logically, if Filter. | Class | cascading.operation.filter | Cascading |
| Order | Order describes the order in which Property annotations shall be displayed. | Class | cascading.management.annotation | Cascading |
| OrderedHashMapCache | is used by default by Unique and AggregateBy and theirDirectMappedCacheFactory, | Class | cascading.util.cache | Cascading |
| OrderedHashMapCacheFactory | Class | cascading.util.cache | Cascading | |
| OrdinalScopeExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
| OrElementExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
| OuterJoin | and outer join of the CoGrouper internal grouped tuple collections. | Class | cascading.pipe.joiner | Cascading |
| Pair | Class | cascading.util | Cascading | |
| Partition | The Partition interface allows for custom partitioning mechanisms to be created with the BasePartitionTap A partition is a directory on a filesystem, where the directory contains data related to the files underneath | Interface | cascading.tap.partition | Cascading |
| Partitions | Class | cascading.flow.planner.iso.subgraph | Cascading | |
| PartitionTapProps | Class | cascading.tap.partition | Cascading | |
| PartitionTupleEntryIterator | Class | cascading.tap.partition | Cascading | |
| PathScopeExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
| Pipe | processing model types, specifically Each, Every, GroupBy, CoGroup, Merge, HashJoin, and SubAssembly. | Class | cascading.pipe | Cascading |
| PlannedOperation | that use a PlannerLevel value to inform the FlowPlanner how to treat the operation during job planning. | Interface | cascading.operation | Cascading |
| PlannerContext | Class | cascading.flow.planner | Cascading | |
| PlannerException | For debugging purposes, the PlannerException holds a copy of the internal job representation which can be written out to disk and visualized with tools that support the | Class | cascading.flow.planner | Cascading |
| PlannerInfo | Class | cascading.flow.planner | Cascading | |
| PlannerLevel | It should be noted that all enum implementations of this interface must declare a NONE or equivalent instance. | Interface | cascading.operation | Cascading |
| PlannerLevelElementExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
| PlannerLevelExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
| PlannerLevelPipeExpressionGraph | Class | cascading.flow.planner.iso.expression | Cascading | |
| PlanPhase | Class | cascading.flow.planner.rule | Cascading | |
| PlatformInfo | Class | cascading.flow.planner | Cascading | |
| ProcessEdge | Class | cascading.flow.planner.process | Cascading | |
| ProcessFlow | Use this class to allow custom Riffle jobs to participate in the Cascade scheduler. | Class | cascading.flow.process | Cascading |
| ProcessFlowStats | ProcessFlowStats is a sub-class of FlowStats which can fetch counters from a ProcessWrapper and hook them into the stats mechanism of Cascading. | Class | cascading.stats.process | Cascading |
| ProcessFlowStep | Class | cascading.flow.process | Cascading | |
| ProcessGraph | Interface | cascading.flow.planner.process | Cascading | |
| ProcessGraphs | Class | cascading.flow.planner.process | Cascading | |
| ProcessLevel | Class | cascading.flow.planner.rule | Cascading | |
| ProcessLogger | Interface | cascading.util | Cascading | |
| ProcessModel | Interface | cascading.flow.planner.process | Cascading | |
| ProcessModels | Class | cascading.flow.planner.process | Cascading | |
| ProcessStepStats | ProcessStepStats is an implementation of FlowStepStats used in non-hadoop based flows like ProcessFlow. | Class | cascading.stats.process | Cascading |
| Property | Property annotations can be used to send additional information about certain aspects of Cascading classes to the DocumentService. | Class | cascading.management.annotation | Cascading |
| PropertyConfigured | PropertyConfigured is an annotation to document the configuration key and the default value of a given @Property annotation on the same AnnotatedElement. | Class | cascading.management.annotation | Cascading |
| PropertyDescription | PropertyDescription is an annotation that can be used to describe the @Property annotation present on the same AnnotatedElement. | Class | cascading.management.annotation | Cascading |
| PropertyOrder | PropertyOrder is an annotation at the class level that controls the sort order of the Property annotations present Order. | Class | cascading.management.annotation | Cascading |
| PropertyRegexSanitizer | PropertyRegexSanitizer is an annotation to be used in conjunction with a Property annotation to sanitize values containing sensitive information with a given regular expression. | Class | cascading.management.annotation | Cascading |
| PropertySanitizer | PropertySanitizer is an annotation to be used in conjunction with a Property annotation to sanitize values containing sensitive information. | Class | cascading.management.annotation | Cascading |
| PropertyUtil | Class | cascading.property | Cascading | |
| Props | Use the sub-classes to either create a Properties instance with custom or default values to be passed to any sub-system that requires a Map or Properties instance of properties and values. | Class | cascading.property | Cascading |
| ProviderLoader | This loader can optinally load a provider implementation within its own ClassLoader using the ChildFirstURLClassLoader. | Class | cascading.provider | Cascading |
| ProvidesCounters | Interface | cascading.stats | Cascading | |
| RecursiveGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
| Reducing | Interface | cascading.flow.stream.duct | Cascading | |
| RegexFilter | the Tuple stream accordingly. | Class | cascading.operation.regex | Cascading |
| RegexGenerator | Note a null valued argument passed to the parser will be converted to an empty string ("") before the regex is applied. | Class | cascading.operation.regex | Cascading |
| RegexMatcher | This operation uses Matcher internally, specifically the method Matcher. | Class | cascading.operation.regex | Cascading |
| RegexOperation | Class | cascading.operation.regex | Cascading | |
| RegexParser | RegexParser only expects one field value. | Class | cascading.operation.regex | Cascading |
| RegexReplace | RegexReplace only expects one field value. | Class | cascading.operation.regex | Cascading |
| RegexSplitGenerator | Class RegexGenerator will emit a new Tuple for every split on the incoming argument value delimited by the given patternString. | Class | cascading.operation.regex | Cascading |
| RegexSplitter | RegexSplitter only expects one field value. | Class | cascading.operation.regex | Cascading |
| RemoveBranchGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
| RemoveNoOpPipeTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
| Rename | Note that if any input field names are not given, they will retain their names. | Class | cascading.pipe.assembly | Cascading |
| ReplaceGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
| ResultTree | Class | cascading.flow.planner.rule.util | Cascading | |
| Retain | Use this pipe to narrow a stream of tuples, removing unused data. | Class | cascading.pipe.assembly | Cascading |
| RightJoin | a left outer, right inner join of the CoGrouper internal grouped tuple collections. | Class | cascading.pipe.joiner | Cascading |
| Rule | Interface | cascading.flow.planner.rule | Cascading | |
| RuleAnnotationTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
| RuleAssert | The RuleAssert class is responsible for asserting the structure of a element graph. | Class | cascading.flow.planner.rule | Cascading |
| RuleContractedTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
| RuleExec | Class | cascading.flow.planner.rule | Cascading | |
| RuleExpression | A RuleExpression describes where a Rule is applied in an element graph. | Class | cascading.flow.planner.rule | Cascading |
| RuleInsertionTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
| RuleMode | Class | cascading.flow.planner.rule | Cascading | |
| RulePartitioner | The RulePartitioner class is responsible for partitioning an element graph into smaller sub-graphs. | Class | cascading.flow.planner.rule | Cascading |
| RuleRegistry | RuleRegistry contains all planner rules for a given platform. | Class | cascading.flow.planner.rule | Cascading |
| RuleRegistrySet | applied via the FlowPlanner to the given assembly. | Class | cascading.flow.planner.rule | Cascading |
| RuleRemoveBranchTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
| RuleReplaceTransformer | Class | cascading.flow.planner.rule.transformer | Cascading | |
| RuleResult | Class | cascading.flow.planner.rule | Cascading | |
| RuleSetExec | Class | cascading.flow.planner.rule | Cascading | |
| RuleTransformer | The RuleTransformer class is responsible for transforming an element graph into a new graph. | Class | cascading.flow.planner.rule | Cascading |
| Sample | Where fraction is between 1 and zero, inclusive. | Class | cascading.operation.filter | Cascading |
| Sanitizer | Sanitizer is an interface to be used in conjunction with PropertySanitizer. | Interface | cascading.management.annotation | Cascading |
| Scheme | A Scheme defines what is stored in a Tap instance by declaring the Tuple field names, and alternately parsing or rendering the incoming or outgoing Tuple | Class | cascading.scheme | Cascading |
| Scope | Class | cascading.flow.planner | Cascading | |
| ScopeExpression | If ScopeExpression is the only edge, the ScopeExpression. | Class | cascading.flow.planner.iso.expression | Cascading |
| ScriptFilter | This Filter is based on the Janino compiler. | Class | cascading.operation.expression | Cascading |
| ScriptFunction | This Function is based on the Janino compiler. | Class | cascading.operation.expression | Cascading |
| ScriptOperation | Class | cascading.operation.expression | Cascading | |
| ScriptTupleFunction | This Function is based on the Janino compiler. | Class | cascading.operation.expression | Cascading |
| SearchOrder | Class | cascading.flow.planner.iso.finder | Cascading | |
| ServiceLoader | CascadingService instances used by internal frameworks. | Class | cascading.provider | Cascading |
| SetMultiMap | Class | cascading.util | Cascading | |
| SetValue | of a given Filter operation. | Class | cascading.operation.function | Cascading |
| ShortCoerce | Class | cascading.tuple.coerce | Cascading | |
| ShortObjectCoerce | Class | cascading.tuple.coerce | Cascading | |
| ShutdownUtil | ShutdownUtil is a private helper class for registering dependent shutdown hooks to maintain internal state information reliably when a jvm is shutting down. | Class | cascading.util | Cascading |
| SingleCloseableInputIterator | Class | cascading.util | Cascading | |
| SingleValueCloseableIterator | SingleValueIterator is a utility class used for quickly presenting a single value to a consumer expecting both a Closeable and an Iterator interface. | Class | cascading.util | Cascading |
| SingleValueIterator | with interfaces that only accept Iterator instances. | Class | cascading.util | Cascading |
| SinkCall | SinkCall provides access to the current Scheme. | Interface | cascading.scheme | Cascading |
| SinkMode | Enum SinkMode identifies supported modes a Tap may utilize when used as a sink. | Class | cascading.tap | Cascading |
| SinkStage | Class | cascading.flow.stream.element | Cascading | |
| SinkTap | Some Tap instances may only be sinks (as opposed to being a source). | Class | cascading.tap | Cascading |
| SliceCounters | Class | cascading.flow | Cascading | |
| SortedListMultiMap | Class | cascading.util | Cascading | |
| SourceCall | SourceCall provides access to the current Scheme. | Interface | cascading.scheme | Cascading |
| SourceStage | Class | cascading.flow.stream.element | Cascading | |
| SourceTap | Some Tap instances may only be sources (as opposed to being a sink). | Class | cascading.tap | Cascading |
| SparseTupleComparator | Class | cascading.flow.stream.util | Cascading | |
| Spillable | Interface | cascading.tuple.collect | Cascading | |
| SpillableProps | FlowConnector before creating new Flow instances. | Class | cascading.tuple.collect | Cascading |
| SpillableTupleList | Using a threshold of -1 will disable the spill, all values will remain in memory. | Class | cascading.tuple.collect | Cascading |
| SpillableTupleMap | SpillableTupleMap is a HashMap that will allow for multiple values per key, and if the number of values for a given key reach a specific threshold, they will be spilled to disk using a SpillableTupleList instance. | Class | cascading.tuple.collect | Cascading |
| Splice | The base class for GroupBy, CoGroup, Merge, and HashJoin. | Class | cascading.pipe | Cascading |
| SpliceGate | Class | cascading.flow.stream.element | Cascading | |
| SplicePipeExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| SplitBeforeEveryAssert | Class | cascading.flow.planner.rule.assertion | Cascading | |
| SplitBeforeEveryExpression | Class | cascading.flow.planner.rule.expression | Cascading | |
| Stage | Class | cascading.flow.stream.duct | Cascading | |
| StatsListener | Interface | cascading.stats | Cascading | |
| Status | the first Tuple it sees. | Class | cascading.operation.state | Cascading |
| StepCounters | Enum StepCounters lists all countersEnum Constant Summary | Class | cascading.flow | Cascading |
| StreamComparator | The StreamComparator interface allows for two InputStream instances to be compared, typically bit-wise. | Interface | cascading.tuple | Cascading |
| StreamGraph | Under some circumstances it may make sense to see the actual graph plan. | Class | cascading.flow.stream.graph | Cascading |
| StreamMode | Class | cascading.flow.stream.annotations | Cascading | |
| StringCoerce | Class | cascading.tuple.coerce | Cascading | |
| StringEdgeNameProvider | Class | cascading.util.jgrapht | Cascading | |
| StringNameProvider | Class | cascading.util.jgrapht | Cascading | |
| SubAssembly | Subclasses of SubAssembly encapsulate complex assemblies of Pipes so they my be reused in the same manner That is, a typical SubAssembly subclass will accept a 'previous' Pipe instance, and a few | Class | cascading.pipe | Cascading |
| SubGraphIterator | Interface | cascading.flow.planner.iso.subgraph | Cascading | |
| SubGraphTransformer | Class | cascading.flow.planner.iso.transformer | Cascading | |
| Sum | Class | cascading.operation.aggregator | Cascading | |
| SumBy | Typically finding the sum of field in a tuple stream relies on a GroupBy and a Sum Aggregator operation. | Class | cascading.pipe.assembly | Cascading |
| SyncPipeExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| Tap | A Tap represents the physical data source or sink in a connected Flow. | Class | cascading.tap | Cascading |
| TapException | Use the payload Tuple constructor if being thrown from inside a Scheme and which for specific data to be trapped by a failure trap Tap. | Class | cascading.tap | Cascading |
| TapGraph | Class | cascading.cascade.planner | Cascading | |
| TapGroupTapExpressionGraph | Class | cascading.flow.planner.rule.expressiongraph | Cascading | |
| TapOrBoundaryElementExpression | Class | cascading.flow.planner.rule.elementexpression | Cascading | |
| TopologyGraph | Class | cascading.cascade.planner | Cascading | |
| Traceable | Interface | cascading.util | Cascading | |
| TraceUtil | Class | cascading.util | Cascading | |
| TraceWriter | Class | cascading.flow.planner.rule.util | Cascading | |
| Transformed | Class | cascading.flow.planner.iso.transformer | Cascading | |
| TrapException | TrapException is a pass through exception allowing trap io failures to propagate past upstream traps. | Class | cascading.flow.stream | Cascading |
| TrapHandler | Class | cascading.flow.stream.element | Cascading | |
| TrapProps | instances used as traps on a given Flow. | Class | cascading.tap | Cascading |
| Tuple | A Tuple represents a set of values. | Class | cascading.tuple | Cascading |
| TupleBuilder | Class | cascading.tuple.util | Cascading | |
| TupleChainIterable | TupleChainIterator chains the given Iterators into a single Iterator. | Class | cascading.tuple | Cascading |
| TupleChainIterator | TupleChainIterator chains the given Iterators into a single Iterator. | Class | cascading.tuple | Cascading |
| TupleCollectionFactory | used to back in memory "join" and "co-group" operations. | Interface | cascading.tuple.collect | Cascading |
| TupleEntry | Once a TupleEntry is created, its Fields cannot be changed, but the Tuple instance it holds can be replaced or modified. | Class | cascading.tuple | Cascading |
| TupleEntryChainIterator | TupleEntryChainIterator chains the given Iterators into a single Iterator. | Class | cascading.tuple | Cascading |
| TupleEntryCollector | one or more result Tuple values. | Class | cascading.tuple | Cascading |
| TupleEntryIterableChainIterator | TupleEntryChainIterator chains the given Iterators into a single Iterator. | Class | cascading.tuple | Cascading |
| TupleEntryIterator | underlying Tuple collection. | Class | cascading.tuple | Cascading |
| TupleEntrySchemeCollector | Scheme. | Class | cascading.tuple | Cascading |
| TupleEntrySchemeIterator | Scheme. | Class | cascading.tuple | Cascading |
| TupleEntrySchemeIteratorProps | TupleEntrySchemeIterator. | Class | cascading.tuple | Cascading |
| TupleException | Class | cascading.tuple | Cascading | |
| TupleHasher | Class | cascading.tuple.util | Cascading | |
| TupleInputStream | Class | cascading.tuple.io | Cascading | |
| TupleListCollector | TupleEntryCollector is a convenience class for managing a list of tuples. | Class | cascading.tuple | Cascading |
| TupleMapFactory | used to back in memory "join" and "co-group" operations. | Interface | cascading.tuple.collect | Cascading |
| TupleOutputStream | Class | cascading.tuple.io | Cascading | |
| TuplePair | part independently. | Class | cascading.tuple.io | Cascading |
| Tuples | Class | cascading.tuple | Cascading | |
| TupleViews | This class is experimental and for internal use only. | Class | cascading.tuple.util | Cascading |
| TypeExpression | Class | cascading.flow.planner.iso.expression | Cascading | |
| UnGroup | That is, for the given field positions, this function will emit a new Tuple for every value. | Class | cascading.operation.function | Cascading |
| Unique | Typically finding unique value in a tuple stream relies on a GroupBy and a FirstNBuffer If the include value is set to Unique. | Class | cascading.pipe.assembly | Cascading |
| UniquePathGraphPartitioner | Class | cascading.flow.planner.iso.subgraph.partitioner | Cascading | |
| UniquePathRulePartitioner | sub-graphs as initial partitions, then will partition the resulting graph into a unique sub-graph for each unique path between the head and tail of the graph. | Class | cascading.flow.planner.rule.partitioner | Cascading |
| UniquePathSubGraphIterator | Class | cascading.flow.planner.iso.subgraph.iterator | Cascading | |
| UniqueProps | Class | cascading.pipe.assembly | Cascading | |
| UnitOfWork | allowing them to be used interchangeably. | Interface | cascading.management | Cascading |
| UnitOfWorkDef | Class | cascading.property | Cascading | |
| UnitOfWorkExecutorStrategy | This is the default spawn strategy. | Class | cascading.management | Cascading |
| UnitOfWorkSpawnStrategy | The interface UnitOfWorkSpawnStrategy is a strategy for allowing pluggable thread management services into any UnitOfWork class. | Interface | cascading.management | Cascading |
| UnsupportedPlanException | Class | cascading.flow.planner.rule | Cascading | |
| Update | Class | cascading.util | Cascading | |
| URISanitizer | URISanitizer is an implementation of the Sanitizer interface to sanitize URIs of different kinds (file, HTTP, HDFS, JDBC etc. | Class | cascading.management.annotation | Cascading |
| Util | Class | cascading.util | Cascading | |
| ValueAssertion | Implementers must also extend BaseOperation. | Interface | cascading.operation | Cascading |
| ValueAssertionCall | Interface | cascading.operation | Cascading | |
| ValueAssertionEachStage | Class | cascading.flow.stream.element | Cascading | |
| Version | Class | cascading.util | Cascading | |
| Visibility | Visibility controls whether a certain Property is visible to a certain PRIVATE - recommended that only a developer or team/project member have access to the valuePROTECTED - recommended for interested and authorized partiesPUBLIC - recommended for use as general purpose information | Class | cascading.management.annotation | Cascading |
| WholeGraphNodePartitioner | Class | cascading.flow.planner.rule.partitioner | Cascading | |
| WholeGraphPartitioner | Class | cascading.flow.planner.iso.subgraph.partitioner | Cascading | |
| WholeGraphRulePartitioner | Class | cascading.flow.planner.rule.partitioner | Cascading | |
| WholeGraphStepPartitioner | Class | cascading.flow.planner.rule.partitioner | Cascading | |
| Xor | constructor provided Filter instances. | Class | cascading.operation.filter | Cascading |