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

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

	public  MiniBatchDeduplicateKeepFirstRowFunction(
			TypeSerializer<RowData> typeSerializer,
			long minRetentionTime);

}