Method flushPending

pj_datastore/src/plugin_data_host.cpp:834–840

  }

  void flushPending() {
    auto lock = engine.lockEngine();
    auto flushed = writer.flushAll();
    if (!flushed.empty()) {
      engine.commitChunks(std::move(flushed));
    }
  }
};

struct CatalogSnapshotState {