Merge pull request #12 from databrickslabs/feature/package-rename

Move code from io.delta.sharing.java to com.databricks.labs.delta.sha…

README.md

@@ -1,6 +1,8 @@
 # Delta Sharing Java Connector
-<img src="docs/source/images/delta-sharing-java-logo.png" alt="drawing" style="width:50px;"/>
-<img src="https://github.com/GIScience/badges/raw/master/status/experimental.svg" alt="drawing" style="width:140px; margin-bottom:15px;"/>
+<img src="docs/source/images/delta-sharing-java-logo.png" alt="drawing" style="width:50px; float: left;"/>
+<img src="https://github.com/GIScience/badges/raw/master/status/experimental.svg" alt="drawing" style="width:140px; margin-top:15px; float: left;"/>
+<br>
+<br>
 
 A java connector for [delta-sharing](https://delta.io/sharing/) that allows you to easily ingest data on any JVM.
 

docs/source/usage/DeltaSharing.rst

@@ -12,8 +12,8 @@ Examples
 .. tabs::
    .. code-tab:: java
 
-    import io.delta.sharing.java.DeltaSharingFactory;
-    import io.delta.sharing.java.DeltaSharing;
+    import com.databricks.labs.delta.sharing.java.DeltaSharingFactory;
+    import com.databricks.labs.delta.sharing.java.DeltaSharing;
 
     DeltaSharing sharing = DeltaSharingFactory
       .create(
@@ -24,7 +24,7 @@ Examples
 
    .. code-tab:: scala
 
-    import io.delta.sharing.java.DeltaSharingFactory
+    import com.databricks.labs.delta.sharing.java.DeltaSharingFactory
 
     val sharing = DeltaSharingFactory
       .create(

docs/source/usage/TableReader.rst

@@ -14,7 +14,7 @@ Examples
 .. tabs::
    .. code-tab:: java
 
-    import io.delta.sharing.java.format.parquet.TableReader;
+    import com.databricks.labs.delta.sharing.java.format.parquet.TableReader;
     import org.apache.avro.generic.GenericRecord;
 
     TableReader<GenericRecord> tableReader = sharing.getTableReader(“table.coordinates”);

src/main/java/io/delta/sharing/java/DeltaSharing.java → src/main/java/com/databricks/labs/delta/sharing/java/DeltaSharing.java

@@ -1,6 +1,6 @@
-package io.delta.sharing.java;
+package com.databricks.labs.delta.sharing.java;
 
-import io.delta.sharing.java.format.parquet.TableReader;
+import com.databricks.labs.delta.sharing.java.format.parquet.TableReader;
 import io.delta.sharing.spark.DeltaSharingFileSystem;
 import io.delta.sharing.spark.DeltaSharingProfileProvider;
 import io.delta.sharing.spark.DeltaSharingRestClient;

src/main/java/io/delta/sharing/java/DeltaSharingFactory.java → src/main/java/com/databricks/labs/delta/sharing/java/DeltaSharingFactory.java

@@ -1,6 +1,6 @@
-package io.delta.sharing.java;
+package com.databricks.labs.delta.sharing.java;
 
-import io.delta.sharing.java.adaptor.DeltaSharingJsonProvider;
+import com.databricks.labs.delta.sharing.java.adaptor.DeltaSharingJsonProvider;
 import io.delta.sharing.spark.DeltaSharingProfileProvider;
 import io.delta.sharing.spark.DeltaSharingRestClient;
 import java.io.IOException;

src/main/java/io/delta/sharing/java/adaptor/DeltaSharingJsonProvider.java → src/main/java/com/databricks/labs/delta/sharing/java/adaptor/DeltaSharingJsonProvider.java

@@ -1,4 +1,4 @@
-package io.delta.sharing.java.adaptor;
+package com.databricks.labs.delta.sharing.java.adaptor;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
@@ -7,7 +7,7 @@
 
 
 /**
- * Loads {@link io.delta.sharing.spark.DeltaSharingProfileProvider} based on configuration provided
+ * Loads {@link DeltaSharingProfileProvider} based on configuration provided
  * as a JSON document. JSON document has to be a valid profile file document. Required fields are
  * checked inside the constructor method and the object creation will fail in case of breaking the
  * constraints.

src/main/java/io/delta/sharing/java/adaptor/DeltaSharingProfileAdaptor.java → src/main/java/com/databricks/labs/delta/sharing/java/adaptor/DeltaSharingProfileAdaptor.java

@@ -1,4 +1,4 @@
-package io.delta.sharing.java.adaptor;
+package com.databricks.labs.delta.sharing.java.adaptor;
 
 import io.delta.sharing.spark.DeltaSharingProfile;
 import scala.Option;
@@ -66,7 +66,7 @@ public void setExpirationTime(String expirationTime) {
    * Java wrapper method that can generate Scala paired object. This is need to be able to abstract
    * from cross language APIs.
    *
-   * @return An equivalent instance of Scala {@link io.delta.sharing.spark.DeltaSharingProfile}
+   * @return An equivalent instance of Scala {@link DeltaSharingProfile}
    *         class.
    */
   public DeltaSharingProfile toProfile() {

src/main/java/io/delta/sharing/java/format/parquet/LocalInputFile.java → src/main/java/com/databricks/labs/delta/sharing/java/format/parquet/LocalInputFile.java

@@ -1,4 +1,4 @@
-package io.delta.sharing.java.format.parquet;
+package com.databricks.labs.delta.sharing.java.format.parquet;
 
 import java.io.EOFException;
 import java.io.FileNotFoundException;
@@ -13,7 +13,7 @@
  * Parquet InputFile with a local java.nio.Path. Adapted from https://github.com/haifengl/smile This
  * class is required to instantiate {@link org.apache.parquet.avro.AvroParquetReader} instances.
  */
-class LocalInputFile implements InputFile {
+public class LocalInputFile implements InputFile {
   /** Local file object. */
   private final RandomAccessFile input;
 

src/main/java/io/delta/sharing/java/format/parquet/TableReader.java → src/main/java/com/databricks/labs/delta/sharing/java/format/parquet/TableReader.java

@@ -1,4 +1,4 @@
-package io.delta.sharing.java.format.parquet;
+package com.databricks.labs.delta.sharing.java.format.parquet;
 
 import java.io.IOException;
 import java.nio.file.Path;

src/test/java/io/delta/sharing/java/DeltaSharingTestCase.java → src/test/java/com/databricks/labs/delta/sharing/java/DeltaSharingTestCase.java

@@ -1,8 +1,7 @@
-package io.delta.sharing.java;
+package com.databricks.labs.delta.sharing.java;
 
-
-import io.delta.sharing.java.adaptor.DeltaSharingJsonProvider;
-import io.delta.sharing.java.mocks.Mocks;
+import com.databricks.labs.delta.sharing.java.adaptor.DeltaSharingJsonProvider;
+import com.databricks.labs.delta.sharing.java.mocks.Mocks;
 import io.delta.sharing.spark.DeltaSharingProfileProvider;
 import io.delta.sharing.spark.model.Table;
 import java.io.IOException;

src/test/java/io/delta/sharing/java/adaptor/DeltaSharingJsonProviderTestCase.java → src/test/java/com/databricks/labs/delta/sharing/java/adaptor/DeltaSharingJsonProviderTestCase.java

@@ -1,17 +1,15 @@
-package io.delta.sharing.java.adaptor;
+package com.databricks.labs.delta.sharing.java.adaptor;
 
+import com.databricks.labs.delta.sharing.java.mocks.Mocks;
 import com.fasterxml.jackson.core.JsonParseException;
 import com.fasterxml.jackson.core.JsonProcessingException;
-import io.delta.sharing.java.mocks.Mocks;
 import java.util.Objects;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
 
 
 /** 
  * Test cases for Delta Sharing Json Provider.
- *
- * @throws JsonProcessingException for all problems encountered when processing Json
  */
 
 public class DeltaSharingJsonProviderTestCase {

src/test/java/io/delta/sharing/java/mocks/Mocks.java → src/test/java/com/databricks/labs/delta/sharing/java/mocks/Mocks.java

@@ -1,4 +1,4 @@
-package io.delta.sharing.java.mocks;
+package com.databricks.labs.delta.sharing.java.mocks;
 
 /** 
  * Mock for provider json.

src/test/java/io/delta/sharing/java/format/parquet/LocalInputFileTestCase.java → src/test/java/com/databricks/labs/delta/sharing/java/parquet/LocalInputFileTestCase.java

@@ -1,5 +1,6 @@
-package io.delta.sharing.java.format.parquet;
+package com.databricks.labs.delta.sharing.java.parquet;
 
+import com.databricks.labs.delta.sharing.java.format.parquet.LocalInputFile;
 import java.io.IOException;
 import java.nio.ByteBuffer;
 import java.nio.file.Path;
@@ -10,8 +11,6 @@
 
 /**
  * Test cases for local Input File.
- *
- * @throws IOException for all IO problems
  */
 public class LocalInputFileTestCase {
 
@@ -59,7 +58,7 @@ public void testReadByteBuffers() throws IOException {
     ByteBuffer byteBuffer = ByteBuffer.allocateDirect(8192 * 4);
     SeekableInputStream stream = localInputFile.newStream();
 
-    Assertions.assertDoesNotThrow(() -> stream.reset(), "assert no exception for reset");
+    Assertions.assertDoesNotThrow(stream::reset, "assert no exception for reset");
 
     Assertions.assertDoesNotThrow(() -> stream.read(byteBuffer),
         "assert no exception for read with byte buffer");

src/test/java/io/delta/sharing/java/format/parquet/TableReaderTestCase.java → src/test/java/com/databricks/labs/delta/sharing/java/parquet/TableReaderTestCase.java

@@ -1,5 +1,6 @@
-package io.delta.sharing.java.format.parquet;
+package com.databricks.labs.delta.sharing.java.parquet;
 
+import com.databricks.labs.delta.sharing.java.format.parquet.TableReader;
 import java.io.IOException;
 import java.nio.file.Path;
 import java.nio.file.Paths;
@@ -12,8 +13,6 @@
 
 /**
  * Test cases for Table Reader.
- *
- * @throws IOException for all IO problems
  */
 public class TableReaderTestCase {