File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -232,8 +232,8 @@ class TransportMessageWriter final : public FlightMessageWriter {
232232 return Close ();
233233 }
234234 // Those messages are not written through the batch writer,
235- // count them separately for stats.
236- extra_metadata_messages_ ++;
235+ // count them separately to include them in the stats.
236+ extra_messages_ ++;
237237 return Status::OK ();
238238 }
239239
@@ -258,7 +258,7 @@ class TransportMessageWriter final : public FlightMessageWriter {
258258 ipc::WriteStats stats () const override {
259259 ARROW_CHECK_NE (batch_writer_, nullptr );
260260 auto write_stats = batch_writer_->stats ();
261- write_stats.num_messages += extra_metadata_messages_ ;
261+ write_stats.num_messages += extra_messages_ ;
262262 return write_stats;
263263 }
264264
@@ -275,7 +275,7 @@ class TransportMessageWriter final : public FlightMessageWriter {
275275 std::shared_ptr<Buffer> app_metadata_;
276276 ::arrow::ipc::IpcWriteOptions ipc_options_;
277277 bool started_ = false ;
278- int64_t extra_metadata_messages_ = 0 ;
278+ int64_t extra_messages_ = 0 ;
279279};
280280
281281// / \brief Adapt TransportDataStream to the FlightMetadataWriter
You can’t perform that action at this time.
0 commit comments