Looking for a way to dynamically terminate a job once Reporter in a Map
job hits a threshold,
Example:
public void map(WritableComparable key, Text values, Output
Collector<Text, Text> output, Reporter reporter) throws IOException {
if( reporter.getCount() > SomeConfigValue) {
return;
}
.... map job code
}
Obviously, reporter.getCount() doesn't exist. Open to other ideas, and
any advice would be appreciated.
Thanks, Brian
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
The information transmitted is intended only for the person or entity to
which it is addressed and may contain confidential and/or privileged
material. Any review, retransmission, dissemination or other use of, or
taking of any action in reliance upon, this information by persons or
entities other than the intended recipient is prohibited. If you received
this message in error, please contact the sender and delete the material
from any computer.
