public class MiniBatchDeduplicateKeepFirstRowFunction extends MapBundleFunction<BaseRow,BaseRow,BaseRow,BaseRow>
ctx
Constructor and Description |
---|
MiniBatchDeduplicateKeepFirstRowFunction(TypeSerializer<BaseRow> typeSerializer) |
Modifier and Type | Method and Description |
---|---|
BaseRow |
addInput(BaseRow value,
BaseRow input)
Adds the given input to the given value, returning the new bundle value.
|
void |
finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out)
Called when a bundle is finished.
|
void |
open(ExecutionContext ctx) |
close
public MiniBatchDeduplicateKeepFirstRowFunction(TypeSerializer<BaseRow> typeSerializer)
public void open(ExecutionContext ctx) throws Exception
public BaseRow addInput(@Nullable BaseRow value, BaseRow input)
MapBundleFunction
public void finishBundle(Map<BaseRow,BaseRow> buffer, Collector<BaseRow> out) throws Exception
MapBundleFunction
finishBundle
in class MapBundleFunction<BaseRow,BaseRow,BaseRow,BaseRow>
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.