@@ -144,18 +144,18 @@ std::shared_ptr<arrow::Table> spawnerHelper(std::shared_ptr<arrow::Table> const&
144144 while (true ) {
145145 auto s = reader.ReadNext (&batch);
146146 if (!s.ok ()) {
147- throw runtime_error_f (" Cannot read batches from source table to spawn %s: %s" , name, s.ToString ().c_str ());
147+ throw runtime_error_f (" Cannot read batches from the source table to spawn %s: %s" , name, s.ToString ().c_str ());
148148 }
149149 if (batch == nullptr ) {
150150 break ;
151151 }
152152 try {
153153 s = projector->Evaluate (*batch, arrow::default_memory_pool (), &v);
154154 if (!s.ok ()) {
155- throw runtime_error_f (" Cannot apply projector to source table of %s: %s" , name, s.ToString ().c_str ());
155+ throw runtime_error_f (" Cannot apply projector to the source table of %s: %s" , name, s.ToString ().c_str ());
156156 }
157157 } catch (std::exception& e) {
158- throw runtime_error_f (" Cannot apply projector to source table of %s: exception caught: %s" , name, e.what ());
158+ throw runtime_error_f (" Cannot apply projector to the source table of %s: exception caught: %s" , name, e.what ());
159159 }
160160
161161 for (auto i = 0U ; i < nColumns; ++i) {
@@ -168,7 +168,6 @@ std::shared_ptr<arrow::Table> spawnerHelper(std::shared_ptr<arrow::Table> const&
168168 arrays.push_back (std::make_shared<arrow::ChunkedArray>(chunks[i]));
169169 }
170170
171- addLabelToSchema (newSchema, name);
172171 return arrow::Table::Make (newSchema, arrays);
173172}
174173
0 commit comments