Skip to content

Commit 35eb8b8

Browse files
authored
Move write logic to OAP Server. (#101)
1 parent a4b0057 commit 35eb8b8

File tree

10 files changed

+121
-856
lines changed

10 files changed

+121
-856
lines changed

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

Lines changed: 0 additions & 204 deletions
This file was deleted.

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@ public abstract class AbstractWrite<P extends com.google.protobuf.GeneratedMessa
4444

4545
protected final Object[] tags;
4646

47+
@Getter
4748
protected final MetadataCache.EntityMetadata entityMetadata;
4849

4950
public AbstractWrite(MetadataCache.EntityMetadata entityMetadata, long timestamp) {
@@ -71,7 +72,7 @@ public AbstractWrite<P> tag(String tagName, Serializable<BanyandbModel.TagValue>
7172
return this;
7273
}
7374

74-
P build() {
75+
public P build() {
7576
BanyandbCommon.Metadata metadata = BanyandbCommon.Metadata.newBuilder()
7677
.setGroup(entityMetadata.getGroup()).setName(entityMetadata.getName()).setModRevision(entityMetadata.getModRevision()).build();
7778

0 commit comments

Comments
 (0)