Searched refs:DbConnector (Results 1 – 6 of 6) sorted by relevance
30 class DbConnector : public Connector<TensorRow> {38 DbConnector(int32_t n_producers, int32_t n_consumers, int32_t queue_capacity) in DbConnector() function42 ~DbConnector() = default;
33 class DbConnector; variable118 …std::unique_ptr<DbConnector> worker_connector_; // The internal connector for worker threads
38 class DbConnector; variable
53 …worker_connector_ = std::make_unique<DbConnector>(num_workers_, num_producers_, worker_connector_s… in CreateWorkerConnector()
384 std::unique_ptr<DbConnector> out_connector_; // Output Connector
216 out_connector_ = std::make_unique<DbConnector>(num_producers, // The number of producers in CreateConnector()