public class Stop extends BaseOperation implements Filter
Filter
class that will force the current pipeline to stop reading data.
When the nested filter returns true
on Filter.isRemove(FlowProcess, FilterCall)
, a
StopDataNotificationException
will be thrown.
Currently this only works reliably using the LocalFlowConnector.
fieldDeclaration, numArgs, trace
Constructor and Description |
---|
Stop(Filter filter)
Constructor Not creates a new Not instance.
|
Modifier and Type | Method and Description |
---|---|
void |
cleanup(FlowProcess flowProcess,
OperationCall operationCall)
Method cleanup does nothing, and may safely be overridden.
|
boolean |
equals(java.lang.Object object) |
Filter |
getFilter() |
protected java.lang.String |
getFilterString() |
int |
hashCode() |
boolean |
isRemove(FlowProcess flowProcess,
FilterCall filterCall)
Method isRemove returns true if input should be removed from the tuple stream.
|
void |
prepare(FlowProcess flowProcess,
OperationCall operationCall)
Method prepare does nothing, and may safely be overridden.
|
flush, getFieldDeclaration, getNumArgs, getTrace, isSafe, printOperationInternal, toString, toStringInternal
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
flush, getFieldDeclaration, getNumArgs, isSafe
public void prepare(FlowProcess flowProcess, OperationCall operationCall)
BaseOperation
prepare
in interface Operation
prepare
in class BaseOperation
public boolean isRemove(FlowProcess flowProcess, FilterCall filterCall)
Filter
protected java.lang.String getFilterString()
public void cleanup(FlowProcess flowProcess, OperationCall operationCall)
BaseOperation
cleanup
in interface Operation
cleanup
in class BaseOperation
public boolean equals(java.lang.Object object)
equals
in class BaseOperation
public int hashCode()
hashCode
in class BaseOperation
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.