feat: more quick start (#7)

GreptimeTeam · Dec 21, 2023 · 947ca88 · 947ca88
1 parent 4d9fca9
commit 947ca88
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 21 deletions.
diff --git a/ingester-example/src/main/java/io/greptime/StreamWritePOJOsQuickStart.java b/ingester-example/src/main/java/io/greptime/StreamWritePOJOsQuickStart.java
@@ -43,11 +43,7 @@ public static void main(String[] args) throws ExecutionException, InterruptedExc
         GreptimeOptions opts = GreptimeOptions.newBuilder(endpoints, database) //
                 .build();
 
-        GreptimeDB greptimeDB = new GreptimeDB();
-
-        if (!greptimeDB.init(opts)) {
-            throw new RuntimeException("Failed to start GreptimeDB client");
-        }
+        GreptimeDB greptimeDB = GreptimeDB.create(opts);
 
         List<MyMetric1> myMetric1s = new ArrayList<>();
         for (int i = 0; i < 10; i++) {

diff --git a/ingester-example/src/main/java/io/greptime/StreamWriteTableRowsQuickStart.java b/ingester-example/src/main/java/io/greptime/StreamWriteTableRowsQuickStart.java
@@ -46,11 +46,7 @@ public static void main(String[] args) throws ExecutionException, InterruptedExc
         GreptimeOptions opts = GreptimeOptions.newBuilder(endpoints, database) //
                 .build();
 
-        GreptimeDB greptimeDB = new GreptimeDB();
-
-        if (!greptimeDB.init(opts)) {
-            throw new RuntimeException("Failed to start GreptimeDB client");
-        }
+        GreptimeDB greptimeDB = GreptimeDB.create(opts);
 
         TableSchema myMetric3Schema = TableSchema.newBuilder("my_metric3") //
                 .addColumn("tag1", SemanticType.Tag, DataType.String) //

diff --git a/ingester-example/src/main/java/io/greptime/WritePOJOsQuickStart.java b/ingester-example/src/main/java/io/greptime/WritePOJOsQuickStart.java
@@ -46,11 +46,7 @@ public static void main(String[] args) throws ExecutionException, InterruptedExc
         GreptimeOptions opts = GreptimeOptions.newBuilder(endpoints, database) //
                 .build();
 
-        GreptimeDB greptimeDB = new GreptimeDB();
-
-        if (!greptimeDB.init(opts)) {
-            throw new RuntimeException("Failed to start GreptimeDB client");
-        }
+        GreptimeDB greptimeDB = GreptimeDB.create(opts);
 
         List<MyMetric1> myMetric1s = new ArrayList<>();
         for (int i = 0; i < 10; i++) {

diff --git a/ingester-example/src/main/java/io/greptime/WriteTableRowsQuickStart.java b/ingester-example/src/main/java/io/greptime/WriteTableRowsQuickStart.java
@@ -51,11 +51,7 @@ public static void main(String[] args) throws ExecutionException, InterruptedExc
         GreptimeOptions opts = GreptimeOptions.newBuilder(endpoints, database) //
                 .build();
 
-        GreptimeDB greptimeDB = new GreptimeDB();
-
-        if (!greptimeDB.init(opts)) {
-            throw new RuntimeException("Failed to start GreptimeDB client");
-        }
+        GreptimeDB greptimeDB = GreptimeDB.create(opts);
 
         TableSchema myMetric3Schema = TableSchema.newBuilder("my_metric3") //
                 .addColumn("tag1", SemanticType.Tag, DataType.String) //

diff --git a/ingester-protocol/src/main/java/io/greptime/GreptimeDB.java b/ingester-protocol/src/main/java/io/greptime/GreptimeDB.java
@@ -79,7 +79,15 @@ public static List<GreptimeDB> instances() {
         return new ArrayList<>(INSTANCES.values());
     }
 
-    public GreptimeDB() {
+    public static GreptimeDB create(GreptimeOptions opts) {
+        GreptimeDB greptimeDB = new GreptimeDB();
+        if (!greptimeDB.init(opts)) {
+            throw new RuntimeException("Failed to start GreptimeDB client");
+        }
+        return greptimeDB;
+    }
+
+    private GreptimeDB() {
         this.id = ID.incrementAndGet();
     }