This is an automated email from the ASF dual-hosted git repository.
jiacai2050 pushed a commit to branch memtable-poc
in repository https://gitbox.apache.org/repos/asf/incubator-horaedb.git
The following commit(s) were added to refs/heads/memtable-poc by this push:
new 460dd5f7 remote remote read stream metrics
460dd5f7 is described below
commit 460dd5f782134b1c7def06fe40636c69063d0341
Author: jiacai2050 <[email protected]>
AuthorDate: Thu Jan 4 14:24:03 2024 +0800
remote remote read stream metrics
---
remote_engine_client/src/client.rs | 12 ------------
1 file changed, 12 deletions(-)
diff --git a/remote_engine_client/src/client.rs
b/remote_engine_client/src/client.rs
index 22dd36a8..28ef0a5a 100644
--- a/remote_engine_client/src/client.rs
+++ b/remote_engine_client/src/client.rs
@@ -115,18 +115,12 @@ impl Client {
// When success to get the stream, table has been found in remote, not
need to
// evict cache entry.
let response = response.into_inner();
-<<<<<<< ours
- let remote_read_record_batch_stream =
- ClientReadRecordBatchStream::new(table_ident, response,
record_schema);
-=======
let remote_read_record_batch_stream = ClientReadRecordBatchStream::new(
route_context.endpoint,
table_ident,
response,
record_schema,
- Default::default(),
);
->>>>>>> theirs
Ok(remote_read_record_batch_stream)
}
@@ -503,18 +497,12 @@ impl Client {
// When success to get the stream, table has been found in remote, not
need to
// evict cache entry.
let response = response.into_inner();
-<<<<<<< ours
- let remote_execute_plan_stream =
- ClientReadRecordBatchStream::new(table_ident, response,
plan_schema);
-=======
let remote_execute_plan_stream = ClientReadRecordBatchStream::new(
route_context.endpoint,
table_ident,
response,
plan_schema,
- request.remote_metrics,
);
->>>>>>> theirs
Ok(remote_execute_plan_stream)
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
