class MiniBatchDeduplicateKeepFirstRowFunction extends MapBundleFunction<BaseRow, BaseRow, BaseRow, BaseRow> {

	@Override
	public void open(ExecutionContext ctx) throws Exception {
		super.open(ctx);
		ValueStateDescriptor<Boolean> stateDesc = new ValueStateDescriptor<>("existsState", Types.BOOLEAN);
		state = ctx.getRuntimeContext().getState(stateDesc);
	}

	public  MiniBatchDeduplicateKeepFirstRowFunction(TypeSerializer<BaseRow> typeSerializer);

}