From a94f3a638e82193e0243d8227b998046255efbb3 Mon Sep 17 00:00:00 2001 From: Zeeshan Qureshi Date: Thu, 16 Mar 2017 23:04:36 -0400 Subject: [PATCH] Pass table path as argument to HoodieClientExample --- hoodie-client/src/test/java/HoodieClientExample.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/hoodie-client/src/test/java/HoodieClientExample.java b/hoodie-client/src/test/java/HoodieClientExample.java index 54aa10938..eb7e56f70 100644 --- a/hoodie-client/src/test/java/HoodieClientExample.java +++ b/hoodie-client/src/test/java/HoodieClientExample.java @@ -42,6 +42,7 @@ public class HoodieClientExample { private static Logger logger = LogManager.getLogger(HoodieClientExample.class); public static void main(String[] args) throws Exception { + String tablePath = args.length == 1 ? args[0] : "file:///tmp/hoodie/sample-table"; HoodieTestDataGenerator dataGen = new HoodieTestDataGenerator(); @@ -53,7 +54,7 @@ public class HoodieClientExample { // generate some records to be loaded in. HoodieWriteConfig cfg = - HoodieWriteConfig.newBuilder().withPath("file:///tmp/hoodie/sample-table") + HoodieWriteConfig.newBuilder().withPath(tablePath) .withSchema(HoodieTestDataGenerator.TRIP_EXAMPLE_SCHEMA).withParallelism(2, 2) .forTable("sample-table").withIndexConfig( HoodieIndexConfig.newBuilder().withIndexType(HoodieIndex.IndexType.BLOOM).build()) @@ -61,7 +62,7 @@ public class HoodieClientExample { Properties properties = new Properties(); properties.put(HoodieWriteConfig.TABLE_NAME, "sample-table"); HoodieTableMetaClient - .initializePathAsHoodieDataset(FSUtils.getFs(), "file:///tmp/hoodie/sample-table", + .initializePathAsHoodieDataset(FSUtils.getFs(), tablePath, properties); HoodieWriteClient client = new HoodieWriteClient(jsc, cfg);