code: @Override
    public void onCompleted() {
      completionMarkerFound.set(true);
      addEntry("setting completion", ResultQueueEntry.<FlatRow> completionMarker());
      markerCounter.incrementAndGet();
    }
docs: {@inheritDoc}