public abstract class SFlatMapFunction2<K,V,R> extends DoFn<Pair<K,V>,R> implements org.apache.spark.api.java.function.FlatMapFunction2<K,V,R>
FlatMapFunction2. Subclasses of this class may be used against either Crunch
|Constructor and Description|
|Modifier and Type||Method and Description|
Processes the records from a
cleanup, configure, disableDeepCopy, initialize, scaleFactor, setConfiguration, setContext
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
DoFn.process(Object, Emitter)method call. This functionality is imposed by Hadoop's Reducer implementation: The framework will reuse the key and value objects that are passed into the reduce, therefore the application should clone the objects they want to keep a copy of.
Copyright © 2017 The Apache Software Foundation. All rights reserved.