Bring back streamers.

khustup2 · khustup2 · commit a1907e0e0d63 · 2025-12-24T22:17:44.000Z
diff --git a/cpp/deeplake_pg/table_data_impl.hpp b/cpp/deeplake_pg/table_data_impl.hpp
@@ -526,7 +526,6 @@ inline std::pair<int64_t, int64_t> table_data::get_row_range(int32_t worker_id)
 
 inline void table_data::create_streamer(int32_t idx, int32_t worker_id)
 {
-    return;
     if (streamers_.streamers.empty()) {
         const auto s = num_columns();
         streamers_.streamers.resize(s);

Original file line number	Diff line number	Diff line change
`@@ -526,7 +526,6 @@ inline std::pair<int64_t, int64_t> table_data::get_row_range(int32_t worker_id)`
`526`	`526`
`527`	`527`	`inline void table_data::create_streamer(int32_t idx, int32_t worker_id)`
`528`	`528`	`{`
`529`		`- return;`
`530`	`529`	`if (streamers_.streamers.empty()) {`
`531`	`530`	`const auto s = num_columns();`
`532`	`531`	`streamers_.streamers.resize(s);`