docs: static void processFirstRow(BaseRow currentRow, ValueState<Boolean> state, Collector<BaseRow> out)
  			throws Exception {
  		// Check message should be accumulate
  		Preconditions.checkArgument(BaseRowUtil.isAccumulateMsg(currentRow));
  		// ignore record with timestamp bigger than preRow
  		if (state.value() != null) {
  			return;
  		}
  		state.update(true);
  		out.collect(currentRow);
  	}