Skip to content

Commit 649c3f4

Browse files
Add stream create without timestamp (#43)
1 parent 5fed3cc commit 649c3f4

File tree

2 files changed

+13
-0
lines changed

2 files changed

+13
-0
lines changed

CHANGES.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ Release Notes.
99
* Support new TopN query protocol
1010
* Remove ID type of TAG
1111
* Make the global singleton MetadataCache client-local
12+
* Add createStreamWrite API to allow late timestamp set
1213

1314
0.3.1
1415
------------------

src/main/java/org/apache/skywalking/banyandb/v1/client/BanyanDBClient.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -269,6 +269,18 @@ public MeasureWrite createMeasureWrite(String group, String name, long timestamp
269269
return new MeasureWrite(this.metadataCache.findMetadata(group, name), timestamp);
270270
}
271271

272+
/**
273+
* Build a StreamWrite request.
274+
*
275+
* @param group the group of the stream
276+
* @param name the name of the stream
277+
* @param elementId the primary key of the stream
278+
* @return the request to be built
279+
*/
280+
public StreamWrite createStreamWrite(String group, String name, final String elementId) {
281+
return new StreamWrite(this.metadataCache.findMetadata(group, name), elementId);
282+
}
283+
272284
/**
273285
* Build a StreamWrite request.
274286
*

0 commit comments

Comments
 (0)