This is an automated email from the ASF dual-hosted git repository.
wusheng 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 649c3f4 Add stream create without timestamp (#43)
649c3f4 is described below
commit 649c3f41e5e9cab029f38e72c257e1301110675f
Author: Jiajing LU <[email protected]>
AuthorDate: Mon Jun 26 11:01:06 2023 +0800
Add stream create without timestamp (#43)
---
CHANGES.md | 1 +
.../apache/skywalking/banyandb/v1/client/BanyanDBClient.java | 12 ++++++++++++
2 files changed, 13 insertions(+)
diff --git a/CHANGES.md b/CHANGES.md
index d3249f3..2ef214e 100644
--- a/CHANGES.md
+++ b/CHANGES.md
@@ -9,6 +9,7 @@ Release Notes.
* Support new TopN query protocol
* Remove ID type of TAG
* Make the global singleton MetadataCache client-local
+* Add createStreamWrite API to allow late timestamp set
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 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.
*
