public class Counter extends BaseOperation implements Filter
Filter that increments a given Enum counter by 1 or by the given increment value.
Internally, the isRemove(cascading.flow.FlowProcess, cascading.operation.FilterCall) method calls
FlowProcess.increment(Enum, long).
No Tuple instances are ever discarded.FlowProcess,
Filter,
Serialized FormfieldDeclaration, numArgs, trace| Constructor and Description |
|---|
Counter(Enum counter)
Constructor Counter creates a new Counter instance.
|
Counter(Enum counter,
int increment)
Constructor Counter creates a new Counter instance.
|
Counter(String group,
String counter) |
Counter(String group,
String counter,
int increment) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(Object object) |
Enum |
getCounterEnum() |
String |
getCounterString() |
String |
getGroupString() |
int |
getIncrement() |
int |
hashCode() |
boolean |
isRemove(FlowProcess flowProcess,
FilterCall filterCall)
Method isRemove returns true if input should be removed from the tuple stream.
|
cleanup, flush, getFieldDeclaration, getNumArgs, getTrace, isSafe, prepare, printOperationInternal, toString, toStringInternalclone, finalize, getClass, notify, notifyAll, wait, wait, waitcleanup, flush, getFieldDeclaration, getNumArgs, isSafe, prepare@ConstructorProperties(value="counter") public Counter(Enum counter)
counter - of type Enum@ConstructorProperties(value={"counter","increment"}) public Counter(Enum counter, int increment)
counter - of type Enumincrement - of type int@ConstructorProperties(value={"group","counter"}) public Counter(String group, String counter)
@ConstructorProperties(value={"group","counter","increment"}) public Counter(String group, String counter, int increment)
public Enum getCounterEnum()
public String getGroupString()
public String getCounterString()
public int getIncrement()
public boolean isRemove(FlowProcess flowProcess, FilterCall filterCall)
Filterpublic boolean equals(Object object)
equals in class BaseOperationpublic int hashCode()
hashCode in class BaseOperationCopyright © 2007-2015 Concurrent, Inc. All Rights Reserved.