From 4dc5b399eeb176b7182668b1e47ebf3b6493e1ec Mon Sep 17 00:00:00 2001 From: jgjesdal Date: Mon, 5 Oct 2026 13:18:53 +0200 Subject: [PATCH] Import BinaryIngestBuffer and SubscriptionListener from sdk.client Java SDK 1.0.0 moved both classes into ai.intellistream.datahub.sdk.client (platform commit 945e3cdb2), so the old ingest and subscriptions imports no longer compile. This is what fails the 'Java and Rust examples compile' check on master since the 1.0.0 install change. Co-Authored-By: Claude Sonnet 5.5 Signed-off-by: jgjesdal --- docs/guides/ingest-timeseries.mdx | 2 +- docs/guides/realtime-subscriptions.mdx | 2 +- docs/reference/subscriptions.md | 2 +- docs/reference/timeseries.md | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/docs/guides/ingest-timeseries.mdx b/docs/guides/ingest-timeseries.mdx index 2d41e82..cb0dbf0 100644 --- a/docs/guides/ingest-timeseries.mdx +++ b/docs/guides/ingest-timeseries.mdx @@ -290,7 +290,7 @@ sends once 10 000 points have accumulated or the oldest is 200 ms old. `add` nev network, and closing the buffer flushes what is left: ```java -import ai.intellistream.datahub.sdk.ingest.BinaryIngestBuffer; +import ai.intellistream.datahub.sdk.client.BinaryIngestBuffer; try (BinaryIngestBuffer buffer = client.timeseries().binaryBuffer()) { buffer.add("engine_temperature", Instant.now(), 92.4); diff --git a/docs/guides/realtime-subscriptions.mdx b/docs/guides/realtime-subscriptions.mdx index b78a4fb..303cb61 100644 --- a/docs/guides/realtime-subscriptions.mdx +++ b/docs/guides/realtime-subscriptions.mdx @@ -93,7 +93,7 @@ to the timeout and returns `null` on a quiet interval (it is a blocking queue ha **not** network polling): ```java -import ai.intellistream.datahub.sdk.subscriptions.SubscriptionListener; +import ai.intellistream.datahub.sdk.client.SubscriptionListener; import java.time.Duration; try (SubscriptionListener listener = client.subscriptions().listen(List.of("engine_room"))) { diff --git a/docs/reference/subscriptions.md b/docs/reference/subscriptions.md index 26db41b..0e0f950 100644 --- a/docs/reference/subscriptions.md +++ b/docs/reference/subscriptions.md @@ -154,7 +154,7 @@ Or drive `poll` yourself, a blocking queue hand-off (not network polling) that r to ack on your own schedule: ```java -import ai.intellistream.datahub.sdk.subscriptions.SubscriptionListener; +import ai.intellistream.datahub.sdk.client.SubscriptionListener; import java.time.Duration; try (SubscriptionListener listener = client.subscriptions().listen(List.of("engine_temps"))) { diff --git a/docs/reference/timeseries.md b/docs/reference/timeseries.md index 5caebf0..9cdd395 100644 --- a/docs/reference/timeseries.md +++ b/docs/reference/timeseries.md @@ -720,7 +720,7 @@ never blocks on the network; flushes run on a thread of their own. Python and Ru binary buffer: collect the readings and call `insert_datapoints_binary` yourself. ```java -import ai.intellistream.datahub.sdk.ingest.BinaryIngestBuffer; +import ai.intellistream.datahub.sdk.client.BinaryIngestBuffer; try (BinaryIngestBuffer buffer = client.timeseries().binaryBuffer()) { // 10 000 points or 200 ms buffer.add("engine_temperature", Instant.now(), 92.4);