This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a commit to branch main
in repository
https://gitbox.apache.org/repos/asf/skywalking-banyandb-java-client.git
The following commit(s) were added to refs/heads/main by this push:
new 546180d Add timeout in the doc (#64)
546180d is described below
commit 546180d96055e6677c51caa56c3db6842c3e046a
Author: 吴晟 Wu Sheng <[email protected]>
AuthorDate: Sat Jul 13 22:40:06 2024 -0700
Add timeout in the doc (#64)
---
README.md | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/README.md b/README.md
index 17f6236..80b7865 100644
--- a/README.md
+++ b/README.md
@@ -247,11 +247,11 @@ segmentIds.forEach(id ->
query.or(PairQueryCondition.LongQueryCondition.eq("segm
### Stream
Since grpc bidi streaming is used for write protocol, build a
`StreamBulkWriteProcessor` which would handle back-pressure for you.
-Adjust `maxBulkSize`, `flushInterval` and `concurrency` of the consumer in
different scenarios to meet requirements.
+Adjust `maxBulkSize`, `flushInterval`, `concurrency` and `timeout` of the
consumer in different scenarios to meet requirements.
```java
// build a StreamBulkWriteProcessor from client
-StreamBulkWriteProcessor streamBulkWriteProcessor =
client.buildStreamWriteProcessor(maxBulkSize, flushInterval, concurrency);
+StreamBulkWriteProcessor streamBulkWriteProcessor =
client.buildStreamWriteProcessor(maxBulkSize, flushInterval, concurrency,
timeout);
```
The `StreamBulkWriteProcessor` is thread-safe and thus can be used across
threads.
@@ -288,7 +288,7 @@ The writing procedure for `Measure` is similar to the above
described process an
```java
// build a MeasureBulkWriteProcessor from client
-MeasureBulkWriteProcessor measureBulkWriteProcessor =
client.buildMeasureWriteProcessor(maxBulkSize, flushInterval, concurrency);
+MeasureBulkWriteProcessor measureBulkWriteProcessor =
client.buildMeasureWriteProcessor(maxBulkSize, flushInterval, concurrency,
timeout);
```
A `BulkWriteProcessor` is created by calling `buildMeasureWriteProcessor`.
Then build the `MeasureWrite` object and send with bulk processor,
