This is an automated email from the ASF dual-hosted git repository. lujiajing pushed a commit to branch client-local-metadata in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb-java-client.git
commit b6449efc33dd4f82063b5b1debc6f4e5926e4978 Author: Megrez Lu <[email protected]> AuthorDate: Sun Jun 18 21:34:41 2023 +0800 add docs and changes --- CHANGES.md | 1 + .../skywalking/banyandb/v1/client/BanyanDBClient.java | 17 +++++++++++++++++ 2 files changed, 18 insertions(+) diff --git a/CHANGES.md b/CHANGES.md index 5f403a7..d3249f3 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -8,6 +8,7 @@ Release Notes. ### Features * Support new TopN query protocol * Remove ID type of TAG +* Make the global singleton MetadataCache client-local 0.3.1 ------------------ diff --git a/src/main/java/org/apache/skywalking/banyandb/v1/client/BanyanDBClient.java b/src/main/java/org/apache/skywalking/banyandb/v1/client/BanyanDBClient.java index ec9723d..04a16f3 100644 --- a/src/main/java/org/apache/skywalking/banyandb/v1/client/BanyanDBClient.java +++ b/src/main/java/org/apache/skywalking/banyandb/v1/client/BanyanDBClient.java @@ -257,10 +257,27 @@ public class BanyanDBClient implements Closeable { return new MeasureBulkWriteProcessor(this.measureServiceStub, maxBulkSize, flushInterval, concurrency); } + /** + * Build a MeasureWrite request. + * + * @param group the group of the measure + * @param name the name of the measure + * @param timestamp the timestamp of the measure + * @return the request to be built + */ public MeasureWrite createMeasureWrite(String group, String name, long timestamp) { return new MeasureWrite(this.metadataCache.findMetadata(group, name), timestamp); } + /** + * Build a StreamWrite request. + * + * @param group the group of the stream + * @param name the name of the stream + * @param elementId the primary key of the stream + * @param timestamp the timestamp of the stream + * @return the request to be built + */ public StreamWrite createStreamWrite(String group, String name, final String elementId, long timestamp) { return new StreamWrite(this.metadataCache.findMetadata(group, name), elementId, timestamp); }
