code: public void registerObserver(ObserverProvider.Registry obsRegistry,
        org.apache.fluo.recipes.core.export.function.Exporter<K, V> exporter) {
      Preconditions.checkState(opts.exporterType == null,
          "Expected exporter type not be set, it was set to %s.  Cannot not use the old and new way of configuring "
              + "exporters at the same time.",
          opts.exporterType);
      Observer obs;
      try {
        obs = new ExportObserverImpl<K, V>(queueId, opts, serializer, exporter);
      } catch (Exception e) {
        throw new RuntimeException(e);
      }
      obsRegistry.forColumn(ExportBucket.newNotificationColumn(queueId), NotificationType.WEAK)
          .withId("exportq-" + queueId).useObserver(obs);
    }
docs: Registers an observer that will export queued data. Use this method in conjunction with
  {@link ExportQueue#configure(String)}.
  
  @since 1.1.0