|Constructor and Description|
|Modifier and Type||Method and Description|
Initialize this DoFn.
Processes the records from a
cleanup, configure, disableDeepCopy, scaleFactor, setConfiguration, setContext
public void initialize()
DoFn.process(Object, Emitter)is triggered. Subclasses may override this method to do appropriate initialization.
Called during the setup of the job instance this
DoFn is associated
public void process(Pair<Integer,Iterable<Pair<K,V>>> input, Emitter<Pair<Integer,Pair<K,V>>> emitter)
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.