Updating logging example for 0.8.0.

Same changes as logging-webapp: use URIs and don't call
repo.getMetadataProvider.

Author: rdblue

logging/src/main/java/com/cloudera/cdk/examples/logging/App.java

@@ -15,8 +15,8 @@
  */
 package com.cloudera.cdk.examples.logging;
 
-import com.cloudera.cdk.data.filesystem.FileSystemDatasetRepository;
-import java.net.URI;
+import com.cloudera.cdk.data.DatasetRepositories;
+import com.cloudera.cdk.data.DatasetRepository;
 import org.apache.avro.Schema;
 import org.apache.avro.generic.GenericRecord;
 import org.apache.avro.generic.GenericRecordBuilder;
@@ -37,9 +37,8 @@ public int run(String[] args) throws Exception {
     Logger logger = Logger.getLogger(App.class);
 
     // Find the schema from the repository
-    FileSystemDatasetRepository repo = new FileSystemDatasetRepository.Builder()
-        .rootDirectory(new URI("/tmp/data")).configuration(getConf()).get();
-    Schema schema = repo.getMetadataProvider().load("events").getSchema();
+    DatasetRepository repo = DatasetRepositories.open("repo:file:/tmp/data");
+    Schema schema = repo.load("events").getDescriptor().getSchema();
 
     // Build some events using the generic Avro API and log them using log4j
     GenericRecordBuilder builder = new GenericRecordBuilder(schema);

logging/src/main/java/com/cloudera/cdk/examples/logging/CreateDataset.java

@@ -16,11 +16,8 @@
 package com.cloudera.cdk.examples.logging;
 
 import com.cloudera.cdk.data.DatasetDescriptor;
+import com.cloudera.cdk.data.DatasetRepositories;
 import com.cloudera.cdk.data.DatasetRepository;
-import com.cloudera.cdk.data.filesystem.FileSystemDatasetRepository;
-import com.google.common.io.Resources;
-import java.net.URI;
-import org.apache.avro.Schema;
 import org.apache.hadoop.conf.Configured;
 import org.apache.hadoop.util.Tool;
 import org.apache.hadoop.util.ToolRunner;
@@ -34,15 +31,12 @@ public class CreateDataset extends Configured implements Tool {
   public int run(String[] args) throws Exception {
 
     // Construct a local filesystem dataset repository rooted at /tmp/data
-    DatasetRepository repo = new FileSystemDatasetRepository.Builder()
-        .rootDirectory(new URI("/tmp/data")).configuration(getConf()).get();
-
-    // Read an Avro schema from the event.avsc file on the classpath
-    Schema schema = new Schema.Parser().parse(
-        Resources.getResource("event.avsc").openStream());
+    DatasetRepository repo = DatasetRepositories.open("repo:file:/tmp/data");
 
     // Create a dataset of events with the Avro schema in the repository
-    DatasetDescriptor descriptor = new DatasetDescriptor.Builder().schema(schema).get();
+    DatasetDescriptor descriptor = new DatasetDescriptor.Builder()
+        .schemaUri("resource:event.avsc")
+        .get();
     repo.create("events", descriptor);
 
     return 0;

logging/src/main/java/com/cloudera/cdk/examples/logging/DeleteDataset.java

@@ -15,9 +15,8 @@
  */
 package com.cloudera.cdk.examples.logging;
 
+import com.cloudera.cdk.data.DatasetRepositories;
 import com.cloudera.cdk.data.DatasetRepository;
-import com.cloudera.cdk.data.filesystem.FileSystemDatasetRepository;
-import java.net.URI;
 import org.apache.hadoop.conf.Configured;
 import org.apache.hadoop.util.Tool;
 import org.apache.hadoop.util.ToolRunner;
@@ -31,8 +30,7 @@ public class DeleteDataset extends Configured implements Tool {
   public int run(String[] args) throws Exception {
 
     // Construct a local filesystem dataset repository rooted at /tmp/data
-    DatasetRepository repo = new FileSystemDatasetRepository.Builder()
-        .rootDirectory(new URI("/tmp/data")).configuration(getConf()).get();
+    DatasetRepository repo = DatasetRepositories.open("repo:file:/tmp/data");
 
     // Drop the events dataset
     boolean success = repo.delete("events");

logging/src/main/java/com/cloudera/cdk/examples/logging/ReadDataset.java

@@ -17,9 +17,8 @@
 
 import com.cloudera.cdk.data.Dataset;
 import com.cloudera.cdk.data.DatasetReader;
+import com.cloudera.cdk.data.DatasetRepositories;
 import com.cloudera.cdk.data.DatasetRepository;
-import com.cloudera.cdk.data.filesystem.FileSystemDatasetRepository;
-import java.net.URI;
 import org.apache.avro.generic.GenericRecord;
 import org.apache.hadoop.conf.Configured;
 import org.apache.hadoop.util.Tool;
@@ -34,8 +33,7 @@ public class ReadDataset extends Configured implements Tool {
   public int run(String[] args) throws Exception {
 
     // Construct a local filesystem dataset repository rooted at /tmp/data
-    DatasetRepository repo = new FileSystemDatasetRepository.Builder()
-        .rootDirectory(new URI("/tmp/data")).configuration(getConf()).get();
+    DatasetRepository repo = DatasetRepositories.open("repo:file:/tmp/data");
 
     // Load the events dataset
     Dataset events = repo.load("events");