From c1d3bb3eb2d1b8fa4261206183a501f92670433d Mon Sep 17 00:00:00 2001 From: s12f Date: Fri, 29 Apr 2022 14:08:14 +0800 Subject: [PATCH] delete examples and format-sources.sh --- examples/README.md | 15 ----- examples/build.gradle | 19 ------- .../io/hstream/example/ConsumerExample.java | 25 --------- .../hstream/example/CreateStreamExample.java | 15 ----- .../example/CreateSubscriptionExample.java | 37 ------------ .../io/hstream/example/ProducerExample.java | 25 --------- .../hstream/example/StreamQueryExample.java | 56 ------------------- script/format-sources.sh | 15 ----- settings.gradle | 1 - 9 files changed, 208 deletions(-) delete mode 100644 examples/README.md delete mode 100644 examples/build.gradle delete mode 100644 examples/src/main/java/io/hstream/example/ConsumerExample.java delete mode 100644 examples/src/main/java/io/hstream/example/CreateStreamExample.java delete mode 100644 examples/src/main/java/io/hstream/example/CreateSubscriptionExample.java delete mode 100644 examples/src/main/java/io/hstream/example/ProducerExample.java delete mode 100644 examples/src/main/java/io/hstream/example/StreamQueryExample.java delete mode 100755 script/format-sources.sh diff --git a/examples/README.md b/examples/README.md deleted file mode 100644 index aed861b6..00000000 --- a/examples/README.md +++ /dev/null @@ -1,15 +0,0 @@ -# hstreamdb-java-example - -## Prerequisites - -- hstreamdb server [v0.6.0.0](https://hub.docker.com/layers/hstreamdb/hstream/v0.6.0/images/sha256-8502a7e4d609becc1d6f998f59f38a2785f878795a6ed8c81be8b38d0aed3109?context=explore) -- hstreamdb-java [v0.6.0](https://search.maven.org/artifact/io.hstream/hstreamdb-java/0.6.0/jar) - -## Examples - -- [CreateStreamExample.java](src/main/java/io/hstream/example/CreateStreamExample.java) - How to create a stream -- [CreateSubscriptionExample.java](src/main/java/io/hstream/example/CreateSubscriptionExample.java) - How to create a subscription -- [ProducerExample.java](src/main/java/io/hstream/example/ProducerExample.java) - How to produce messages to a stream -- [ConsumerExample.java](src/main/java/io/hstream/example/ConsumerExample.java) - How to consume messages from a subscription -- [StreamQueryExample.java](src/main/java/io/hstream/example/StreamQueryExample.java) - How to use SQL commands to query data from streams - diff --git a/examples/build.gradle b/examples/build.gradle deleted file mode 100644 index fe9fc3e4..00000000 --- a/examples/build.gradle +++ /dev/null @@ -1,19 +0,0 @@ -plugins { - // Apply the application plugin to add support for building a CLI application in Java. - id 'application' -} - -repositories { - // Use Maven Central for resolving dependencies. - mavenCentral() - // mavenLocal() -} - -dependencies { - implementation 'io.hstream:hstreamdb-java:0.6.0' -} - -application { - // Define the main class for the application. - mainClass = 'io.hstream.example.ConsumerExample' -} diff --git a/examples/src/main/java/io/hstream/example/ConsumerExample.java b/examples/src/main/java/io/hstream/example/ConsumerExample.java deleted file mode 100644 index c6cb971d..00000000 --- a/examples/src/main/java/io/hstream/example/ConsumerExample.java +++ /dev/null @@ -1,25 +0,0 @@ -package io.hstream.example; - -import io.hstream.*; - -/** This example shows how to consume data from specified subscription */ -public class ConsumerExample { - private static final String SERVICE_URL = "localhost:6570"; - private static final String DEMO_SUBSCRIPTION = "demo_stream"; - - public static void main(String[] args) { - HStreamClient client = HStreamClient.builder().serviceUrl(SERVICE_URL).build(); - - Consumer consumer = - client - .newConsumer() - .subscription(DEMO_SUBSCRIPTION) - .rawRecordReceiver( - (receivedRawRecord, responder) -> { - System.out.println("get record: " + receivedRawRecord.getRecordId()); - responder.ack(); - }) - .build(); - consumer.startAsync().awaitRunning(); - } -} diff --git a/examples/src/main/java/io/hstream/example/CreateStreamExample.java b/examples/src/main/java/io/hstream/example/CreateStreamExample.java deleted file mode 100644 index c900cfad..00000000 --- a/examples/src/main/java/io/hstream/example/CreateStreamExample.java +++ /dev/null @@ -1,15 +0,0 @@ -package io.hstream.example; - -import io.hstream.HStreamClient; - -/** This example shows how to create a stream */ -public class CreateStreamExample { - private static final String SERVICE_URL = "localhost:6570"; - private static final String DEMO_STREAM = "demo_stream"; - - public static void main(String[] args) { - HStreamClient client = HStreamClient.builder().serviceUrl(SERVICE_URL).build(); - - client.createStream(DEMO_STREAM); - } -} diff --git a/examples/src/main/java/io/hstream/example/CreateSubscriptionExample.java b/examples/src/main/java/io/hstream/example/CreateSubscriptionExample.java deleted file mode 100644 index 5be6d209..00000000 --- a/examples/src/main/java/io/hstream/example/CreateSubscriptionExample.java +++ /dev/null @@ -1,37 +0,0 @@ -package io.hstream.example; - -import io.hstream.*; - -/** This example shows how to create a subscription associated to the specified stream */ -public class CreateSubscriptionExample { - private static final String SERVICE_URL = "localhost:6570"; - private static final String DEMO_STREAM = "demo_stream"; - private static final String DEMO_SUBSCRIPTION = "demo_subscription"; - - public static void main(String[] args) { - HStreamClient client = HStreamClient.builder().serviceUrl(SERVICE_URL).build(); - // create a subscription which consume data from the tail of the stream. - Subscription subscriptionFromEarlist = - Subscription.newBuilder().subscription(DEMO_SUBSCRIPTION).stream(DEMO_STREAM) - .offset(new SubscriptionOffset(SubscriptionOffset.SpecialOffset.EARLIEST)) - .ackTimeoutSeconds(600) - .build(); - client.createSubscription(subscriptionFromEarlist); - - // create a subscription which consume data from the tail of the stream. - Subscription subscriptionFromLatest = - Subscription.newBuilder().subscription(DEMO_SUBSCRIPTION).stream(DEMO_STREAM) - .offset(new SubscriptionOffset(SubscriptionOffset.SpecialOffset.LATEST)) - .ackTimeoutSeconds(600) - .build(); - client.createSubscription(subscriptionFromLatest); - - // create a subscription which consume data from specified RecordId. - Subscription subscription = - Subscription.newBuilder().subscription(DEMO_SUBSCRIPTION).stream(DEMO_STREAM) - .offset(new SubscriptionOffset(new RecordId(1, 2))) - .ackTimeoutSeconds(600) - .build(); - client.createSubscription(subscription); - } -} diff --git a/examples/src/main/java/io/hstream/example/ProducerExample.java b/examples/src/main/java/io/hstream/example/ProducerExample.java deleted file mode 100644 index 1c58c32b..00000000 --- a/examples/src/main/java/io/hstream/example/ProducerExample.java +++ /dev/null @@ -1,25 +0,0 @@ -package io.hstream.example; - -import io.hstream.*; -import java.util.Random; -import java.util.concurrent.CompletableFuture; - -/** This example shows how to write data to an existed stream */ -public class ProducerExample { - private static final String SERVICE_URL = "localhost:6570"; - private static final String DEMO_STREAM = "demo_stream"; - - public static void main(String[] args) { - HStreamClient client = HStreamClient.builder().serviceUrl(SERVICE_URL).build(); - - Producer producer = - client.newProducer().stream(DEMO_STREAM).enableBatch().recordCountLimit(1000).build(); - - Random random = new Random(); - byte[] rawRecord = new byte[100]; - for (int i = 0; i < 1000; ++i) { - random.nextBytes(rawRecord); - CompletableFuture future = producer.write(rawRecord); - } - } -} diff --git a/examples/src/main/java/io/hstream/example/StreamQueryExample.java b/examples/src/main/java/io/hstream/example/StreamQueryExample.java deleted file mode 100644 index 7f1c4b8a..00000000 --- a/examples/src/main/java/io/hstream/example/StreamQueryExample.java +++ /dev/null @@ -1,56 +0,0 @@ -package io.hstream.example; - -import io.hstream.*; - -public class StreamQueryExample { - private static final String SERVICE_URL = "localhost:6570"; - private static final String DEMO_STREAM = "demo_stream"; - private static final String DEMO_SUBSCRIPTION = "demo_stream"; - - public static void main(String[] args) throws Exception { - - HStreamClient client = HStreamClient.builder().serviceUrl(SERVICE_URL).build(); - client.createStream(DEMO_STREAM); - - // first, create an observer for sql results - Observer observer = - new Observer() { - @Override - public void onNext(HRecord value) { - System.out.println(value); - } - - @Override - public void onError(Throwable t) { - System.out.println("error happend!"); - } - - @Override - public void onCompleted() {} - }; - - // second, create a queryer to execute a sql - Queryer queryer = - client - .newQueryer() - .sql("select * from " + DEMO_STREAM + " where temperature > 30 emit changes;") - .resultObserver(observer) - .build(); - - // third, start the queryer - queryer.startAsync().awaitRunning(); - - Producer producer = client.newProducer().stream(DEMO_STREAM).build(); - HRecord hRecord1 = HRecord.newBuilder().put("temperature", 29).put("humidity", 20).build(); - HRecord hRecord2 = HRecord.newBuilder().put("temperature", 34).put("humidity", 21).build(); - HRecord hRecord3 = HRecord.newBuilder().put("temperature", 35).put("humidity", 22).build(); - producer.write(hRecord1); - producer.write(hRecord2); - producer.write(hRecord3); - - Thread.sleep(5000); - - queryer.stopAsync().awaitTerminated(); - client.close(); - } -} diff --git a/script/format-sources.sh b/script/format-sources.sh deleted file mode 100755 index cc4c23af..00000000 --- a/script/format-sources.sh +++ /dev/null @@ -1,15 +0,0 @@ -#! /usr/bin/env bash - -CLIENT_JAVA_FILES=$(find client/src/ -name "*.java") -for CLIENT_JAVA_FILE in ${CLIENT_JAVA_FILES} -do - echo "formatting ${CLIENT_JAVA_FILE}" - google-java-format -r ${CLIENT_JAVA_FILE} -done - -EXAMPLE_JAVA_FILES=$(find examples/src/ -name "*.java") -for EXAMPLE_JAVA_FILE in ${EXAMPLE_JAVA_FILES} -do - echo "formatting ${EXAMPLE_JAVA_FILE}" - google-java-format -r ${EXAMPLE_JAVA_FILE} -done diff --git a/settings.gradle b/settings.gradle index 92e144c4..c490c0fb 100644 --- a/settings.gradle +++ b/settings.gradle @@ -1,3 +1,2 @@ rootProject.name = 'hstreamdb-java' include 'client' -include 'examples'