|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object cascading.operation.ConcreteCall<C>
public class ConcreteCall<C>
Class OperationCall is the common base class for FunctionCall
, FilterCall
,
AggregatorCall
, ValueAssertionCall
, and GroupAssertionCall
.
Constructor Summary | |
---|---|
ConcreteCall()
Constructor OperationCall creates a new OperationCall instance. |
|
ConcreteCall(Fields argumentFields)
Constructor ConcreteCall creates a new ConcreteCall instance. |
|
ConcreteCall(TupleEntry arguments,
TupleEntryCollector outputCollector)
Constructor OperationCall creates a new OperationCall instance. |
Method Summary | |
---|---|
Fields |
getArgumentFields()
Returns the Fields of the expected arguments TupleEntry . |
TupleEntry |
getArguments()
Returns TupleEntry of argument values. |
Iterator<TupleEntry> |
getArgumentsIterator()
Returns an Iterator of TupleEntry instances representing the arguments for the called
Buffer.operate(cascading.flow.FlowProcess, BufferCall) method. |
C |
getContext()
Returns the user set context object, C. |
TupleEntry |
getGroup()
Returns the current grouping TupleEntry . |
TupleEntryCollector |
getOutputCollector()
Returns the TupleEntryCollector used to emit result values. |
void |
setArguments(TupleEntry arguments)
|
void |
setArgumentsIterator(Iterator<TupleEntry> argumentsIterator)
|
void |
setContext(C context)
Sets the user defined 'context' object. |
void |
setGroup(TupleEntry group)
|
void |
setOutputCollector(TupleEntryCollector outputCollector)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ConcreteCall()
public ConcreteCall(Fields argumentFields)
argumentFields
- of type Fieldspublic ConcreteCall(TupleEntry arguments, TupleEntryCollector outputCollector)
arguments
- of type TupleEntryoutputCollector
- of type TupleCollectorMethod Detail |
---|
public C getContext()
OperationCall
getContext
in interface OperationCall<C>
OperationCall.getContext()
public void setContext(C context)
OperationCall
setContext
in interface OperationCall<C>
context
- user defined objectpublic TupleEntry getGroup()
AggregatorCall
TupleEntry
.
getGroup
in interface AggregatorCall<C>
getGroup
in interface BufferCall<C>
getGroup
in interface GroupAssertionCall<C>
AggregatorCall.getGroup()
public void setGroup(TupleEntry group)
public Fields getArgumentFields()
OperationCall
Fields
of the expected arguments TupleEntry
.
getArgumentFields
in interface OperationCall<C>
public Iterator<TupleEntry> getArgumentsIterator()
BufferCall
Iterator
of TupleEntry
instances representing the arguments for the called
Buffer.operate(cascading.flow.FlowProcess, BufferCall)
method.
getArgumentsIterator
in interface BufferCall<C>
BufferCall.getArgumentsIterator()
public void setArgumentsIterator(Iterator<TupleEntry> argumentsIterator)
public TupleEntry getArguments()
FunctionCall
TupleEntry
of argument values.
getArguments
in interface AggregatorCall<C>
getArguments
in interface FilterCall<C>
getArguments
in interface FunctionCall<C>
getArguments
in interface GroupAssertionCall<C>
getArguments
in interface ValueAssertionCall<C>
FunctionCall.getArguments()
public void setArguments(TupleEntry arguments)
public TupleEntryCollector getOutputCollector()
FunctionCall
TupleEntryCollector
used to emit result values.
getOutputCollector
in interface AggregatorCall<C>
getOutputCollector
in interface BufferCall<C>
getOutputCollector
in interface FunctionCall<C>
FunctionCall.getOutputCollector()
public void setOutputCollector(TupleEntryCollector outputCollector)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |