docs: @Override
  	protected void processRecord(Tuple2<Boolean, Row> change) {
  		synchronized (resultLock) {
  			// insert
  			if (change.f0) {
  				processInsert(change.f1);
  			}
  			// delete
  			else {
  				processDelete(change.f1);
  			}
  		}
  	}