This is an automated email from the ASF dual-hosted git repository. lujiajing pushed a commit to branch add-stream-create-without-ts in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb-java-client.git
commit 21b145d05270acf17bd104e69356d6509f746bea Author: Megrez Lu <[email protected]> AuthorDate: Mon Jun 26 09:28:04 2023 +0800 add API --- .../apache/skywalking/banyandb/v1/client/BanyanDBClient.java | 12 ++++++++++++ 1 file changed, 12 insertions(+) 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 04a16f3..8f68f31 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 @@ -269,6 +269,18 @@ public class BanyanDBClient implements Closeable { 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 + * @return the request to be built + */ + public StreamWrite createStreamWrite(String group, String name, final String elementId) { + return new StreamWrite(this.metadataCache.findMetadata(group, name), elementId); + } + /** * Build a StreamWrite request. *
