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