docs: protected Collector<OT> createWorksetUpdateOutputCollector(Collector<OT> delegate) {
  		DataOutputView outputView = worksetBackChannel.getWriteEnd();
  		TypeSerializer<OT> serializer = getOutputSerializer();
  		return new WorksetUpdateOutputCollector<OT>(outputView, serializer, delegate);
  	}