in src/main/java/org/apache/skywalking/banyandb/v1/client/BanyanDBClient.java [687:696]
public boolean deleteStream(String group, String name) throws BanyanDBException {
Preconditions.checkArgument(!Strings.isNullOrEmpty(group));
Preconditions.checkArgument(!Strings.isNullOrEmpty(name));
StreamMetadataRegistry streamRegistry = new StreamMetadataRegistry(checkNotNull(this.channel));
if (streamRegistry.delete(group, name)) {
this.metadataCache.unregister(group, name);
return true;
}
return false;
}