|
|||||||||
| 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
fails.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 on equivalent 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.
SimpleDateFormat instance.
Calendar field
values.
Filter that will never remove an item from a stream, but will print the Tuple to either
stdout or stderr.SinkMode.APPEND.
SinkMode.APPEND flag.
Tap class that provides access to the Hadoop Distributed File System.Function or a Filter to each entry in the Tuple
stream.Aggregator or Buffer to every grouping.Tuple values.Tuple values.ExpressionFunction, ExpressionFilter,
AssertExpression.Tuple.Operation as a filter, as opposed to being a Function.Filter invocation arguments.Tuple
is a null value.Tuple
is not a null value.Aggregator that returns the first Tuple encountered.Pipe assembly is connected to the necessary number of Tap sinks and
sources into a Flow.Tuple instances
between operations.Tap instances with an assembly of Pipe instances into
an executable Flow.Properties instance as
default value for the underlying jobs.
Flow instance.
Flow execution.FlowSkipStrategy implementation that returns
true if the Flow sink exists, regardless if it is stale or not.FlowSkipStrategy implementation that returns
true if the Flow sink exists and is stale in relation to the Flow sources.Flow should
be skipped when executed in a Cascade.Flow specific statistics.Formatter class for formatting this tuples values into a new string.
FSInputStream implementation that can verify a MessageDigest and will count
the number of bytes read for use in progress status.BaseOperation as a function, as opposed to being a Filter.Function invocation arguments.TupleEntry of argument values.
TupleEntry of argument values.
TupleEntry of argument values.
TupleEntry of argument values.
TupleEntry of argument values.
TupleEntry for the declared arguments of this scope.
Iterator of TupleEntry instances representing the arguments for the called
Buffer.operate(cascading.flow.FlowProcess, BufferCall) method.
AssertionLevel.
Serialization#getDeserializer(Class).
Flows executed by the Cascade.
Flow instance.
FlowSkipStrategy used by this Flow.
FlowSkipStrategy used by this Flow.
TupleEntry.
TupleEntry.
TupleEntry.
Every.EveryHandler for this instnce.
Each or
Every Operator.
TupleEntryCollector used to emit result values.
TupleEntryCollector used to emit result values.
TupleEntryCollector used to emit result values.
Formatter format String of this TemplateTap object.
Serialization#getSerializer(Class).
Tap managed by this Flow instance.
ZipInputFormat.listPathsInternal(JobConf).
GroupBy and CoGroup.Fields.ALL fields.
Assertion used with the Every pipe Operator.GroupAssertion invocation arguments.Tuple stream by the given groupFields.Fields.ALL fields.
RawComparator.Partitioner.FlowProcess for Hadoop.FlowListener instances have been registered.
Tuple instances available.
FileSystem for accessing remote HTTP and HTTPS data.InnerJoin.JoinIterator that will iterate over a given Joiner and return tuples that represent
and inner join of the CoGrouper internal grouped tuple collections.Aggregator operation.
Fields.ALL field set.
Fields.ALL, Fields.GROUP, or
Fields.VALUES.
Fields.ARGS field set.
Assertion.
Buffer operation.
Fields.ALL or Fields.UNKNOWN.
Fields.GROUP field set.
Fields.ALL or Fields.RESULTS.
Fields.RESULTS field set.
Cascade should skip this Flow instance.
Fields.UNKNOWN field set.
Fields.VALUES field set.
Tap instances TupleEntryCollector should be used to sink values.
TupleEntryCollector should be used to sink values.
Tuple instance.
Iterator over this Tuple instances values.
CoGroupClosure.Aggregator that returns the last Tuple encountered.Tuple.remove(int[]).
LeftJoin.JoinIterator that will iterate over a given Joiner and return tuples that represent
a left inner, right outer join of the CoGrouper internal grouped tuple collections.Tap class that provides access to the Local File System via Hadoop.Filter that will limit the number of Tuple instances that it will
allow to pass.Filter operations.Flow subclass that supports custom MapReduce jobs preconfigured via the JobConf
object.JobConf and allows it to be executed as a Flow.Aggregator that returns the maximum value encountered in the current group.Aggregator that returns the minimum value encountered in the current group.Iterator that will iterate over a given
Joiner and return tuples that represent a join as defined by the given boolean array.Tap instances into a single resource.Tuple.
Filter class that will logically 'not' (negation) the results of the constructor provided Filter
instance.FlowStep throws a Throwable type.
TupleIterator for the given Tap instance.
TupleIterator for the given Tap instance.
Tuple streams.BaseOperation classes.Pipe.Filter class that will logically 'or' the results of the constructor provided Filter
instances.OuterJoin.JoinIterator that will iterate over a given Joiner and return tuples that represent
and outer join of the CoGrouper internal grouped tuple collections.Tuple.print() String representation of a Tuple instance and return a new Tuple instance.
Each, Every, GroupBy, and
CoGroup.groups are stored in the appropriate number of new fields.
groups are stored in the named fieldDeclarations.
Pipe or SubAssembly.
RawComparator.RightJoin.JoinIterator that will iterate over a given Joiner and return tuples that represent
a left outer, right inner join of the CoGrouper internal grouped tuple collections.Filter that only allows the given percent of Tuple instances to pass.Tap instance by declaring the Tuple
field names, and alternately parsing or rendering the incoming or outgoing Tuple
stream, respectively.Scheme, which is a flat files consisting of
binary key/value pairs.TupleInputStream and TupleOutputStream
to substitute Integer values for a class name when writing out nested objects inside a Tuple.AssertionLevel.
Parser#setFeature(String, boolean).
FlowSkipStrategy, the current strategy, if any, is returned.
FlowSkipStrategy, the current strategy is returned.
TupleEntryCollector should be used to sink values.
Tuple instance to the outputCollector.
TemplateTap.Tuple instance.
Tuple
MultiTap.Iterable object that can store an unlimited number of Tuple instances by spilling
excess to a temporary disk file.FlowStep instances.FileSystem implementations that manage remote resources.Pipes so they my be reused in the same manner
a Pipe is used.Aggregator that returns the sum of all numeric values in the current group.Flow.TupleEntryCollector that writes tuples to the resource managed by
a particular Tap instance.