lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

Pass table path as argument to HoodieClientExample

Browse Source
This commit is contained in:
Zeeshan Qureshi
2017-03-16 23:04:36 -04:00
committed by vinoth chandar
parent b7047ab4fb
commit a94f3a638e
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
hoodie-client/src/test/java/HoodieClientExample.java
View File

@@ -42,6 +42,7 @@ public class HoodieClientExample {
private static Logger logger = LogManager.getLogger(HoodieClientExample.class); private static Logger logger = LogManager.getLogger(HoodieClientExample.class);
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
String tablePath = args.length == 1 ? args[0] : "file:///tmp/hoodie/sample-table";
HoodieTestDataGenerator dataGen = new HoodieTestDataGenerator(); HoodieTestDataGenerator dataGen = new HoodieTestDataGenerator();
@@ -53,7 +54,7 @@ public class HoodieClientExample {
// generate some records to be loaded in. // generate some records to be loaded in.
HoodieWriteConfig cfg = HoodieWriteConfig cfg =
HoodieWriteConfig.newBuilder().withPath("file:///tmp/hoodie/sample-table") HoodieWriteConfig.newBuilder().withPath(tablePath)
.withSchema(HoodieTestDataGenerator.TRIP_EXAMPLE_SCHEMA).withParallelism(2, 2) .withSchema(HoodieTestDataGenerator.TRIP_EXAMPLE_SCHEMA).withParallelism(2, 2)
.forTable("sample-table").withIndexConfig( .forTable("sample-table").withIndexConfig(
HoodieIndexConfig.newBuilder().withIndexType(HoodieIndex.IndexType.BLOOM).build()) HoodieIndexConfig.newBuilder().withIndexType(HoodieIndex.IndexType.BLOOM).build())
@@ -61,7 +62,7 @@ public class HoodieClientExample {
Properties properties = new Properties(); Properties properties = new Properties();
properties.put(HoodieWriteConfig.TABLE_NAME, "sample-table"); properties.put(HoodieWriteConfig.TABLE_NAME, "sample-table");
HoodieTableMetaClient HoodieTableMetaClient
.initializePathAsHoodieDataset(FSUtils.getFs(), "file:///tmp/hoodie/sample-table", .initializePathAsHoodieDataset(FSUtils.getFs(), tablePath,
properties); properties);
HoodieWriteClient client = new HoodieWriteClient(jsc, cfg); HoodieWriteClient client = new HoodieWriteClient(jsc, cfg);