# 流(Streams)

HStreamDB 以 streams 的形式存储数据, 那么如何通过 Java SDK 来对管理 HStreamDB 中的 streams。

# 前提条件

  • 确保有一个运行中并可用的 HStreamDB
  • 包含下列 import 语句:

import io.hstream.HStreamClient;
import io.hstream.Stream;

1
2
3
4

# 连接到一个 HStreamDB 示例

首先你需要连接到一个 HStreamDB 示例,然后得到一个 HStreamClient 对象。


HStreamClient client = HStreamClient.builder().serviceUrl("SERVER_HOST:SERVER_PORT").build();

1
2
3

# 拿到当前存在的 stream 列表

通过 HStreamClient.listStreams() 可以拿到当前存在的 stream 列表


for(Stream stream: client.listStreams()) {
  System.out.println(stream.getStreamName());
}

1
2
3
4
5

# 创建一个新的 stream

通过 HStreamClient.createStream() 可以创建一个新的 stream with 3(默认值) replicates:


client.createStream("test_stream");

1
2
3

你也可以给定 replicate 的个数:


client.createStream("test_stream", 5);

1
2
3

# 删除一个 stream

通过 HStreamClient.deleteStream() 可以删除一个stream:


client.deleteStream("test_stream");

1
2
3