|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
Serialization#accept(Class).
Tuple to this list.
TupleEntry to this list.
TupleEntry into the outgoing stream.
Tuple into the outgoing stream.
Flow {2link FlowStats} instance.
TupleEntry value in the current grouping.
TupleEntry value in the current grouping.
Aggregator invocation arguments.Filter class that will logically 'and' the results of the constructor provided Filter
instances.Tuple instance into an Object[].
Tuple instance into an Object[].
Tuple and each constructor value is .equals() to its corresponding argument value.Tuple is equal to the value
provided on the constructor.Tuple values.GroupAssertion that asserts the number of items in the current group
is equal the given size.GroupAssertion that asserts the number of items in the current group
is less than the given size.GroupAssertion that asserts the number of items in the current group
is more than the given size.Assertion instance.Tuple by joining each individual element of the Tuple with a tab character (\t).Tuple element individually.Tuple is not a null value.Tuple is a null value.Tuple in the stream is exactly the given size.Tuple in the stream has a size less than (<) the given size.Tuple in the stream has a size more than (>) the given size.Aggregator that returns the average of all numeric values in the current group.Assertion implementations.Tuple streams via
the Each or Every Pipe.Fields.UNKNOWN Tuple and accepts any number of arguments.
Aggregator by the fact that it operates on unique groups of values.Buffer invocation arguments.Flow instances that share or depend the same Tap instances and are executed as
a single group.Cascade instance from a collection of Flow instance.Cascade class.Cascade and Flow
instances via the CascadeConnector and FlowConnector, respectively.Cascade specific statistics.Pipe instance.
Pipe instance.
Pipe instance.
Pipe instance.
Pipe instance.
Pipe instance.
Pipe instance.
Pipe instance.
Tap this instance encapsulates.
Comparable.compareTo(Object).
Comparable.compareTo(Object) method.
Cascade.start() was not previously called.
TupleEntry has been passed to the
Aggregator.aggregate(cascading.flow.FlowProcess, AggregatorCall)
method.
FunctionCall, FilterCall,
AggregatorCall, ValueAssertionCall, and GroupAssertionCall.Flow objects, it will connect them and return a new Cascade instance.
Flow objects, it will connect them and return a new Cascade instance.
Aggregator that calculates the number of items in the current group.SimpleDateFormat syntax.DateFormatter and DateParser.SimpleDateFormat syntax.Calendar field
values.
Calendar field
values.
Filter that will never remove an item from a stream, but will print the Tuple to either
stdout or stderr.Tap class that provides access to the Hadoop Distributed File System.