apache · npawar · Jan 10, 2019 · Jan 10, 2019 · Jan 10, 2019
diff --git a/contrib/pinot-druid-benchmark/pom.xml b/contrib/pinot-druid-benchmark/pom.xml
@@ -24,7 +24,7 @@
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
 
-  <groupId>com.linkedin.pinotdruidbenchmark</groupId>
+  <groupId>org.apache.pinotdruidbenchmark</groupId>
   <artifactId>pinot-druid-benchmark</artifactId>
   <version>1.0-SNAPSHOT</version>
   <packaging>jar</packaging>
@@ -52,27 +52,27 @@
         <configuration>
           <programs>
             <program>
-              <mainClass>com.linkedin.pinotdruidbenchmark.DataSeparator</mainClass>
+              <mainClass>org.apache.pinotdruidbenchmark.DataSeparator</mainClass>
               <name>data-separator</name>
             </program>
             <program>
-              <mainClass>com.linkedin.pinotdruidbenchmark.DataMerger</mainClass>
+              <mainClass>org.apache.pinotdruidbenchmark.DataMerger</mainClass>
               <name>data-merger</name>
             </program>
             <program>
-              <mainClass>com.linkedin.pinotdruidbenchmark.PinotResponseTime</mainClass>
+              <mainClass>org.apache.pinotdruidbenchmark.PinotResponseTime</mainClass>
               <name>pinot-response-time</name>
             </program>
             <program>
-              <mainClass>com.linkedin.pinotdruidbenchmark.DruidResponseTime</mainClass>
+              <mainClass>org.apache.pinotdruidbenchmark.DruidResponseTime</mainClass>
               <name>druid-response-time</name>
             </program>
             <program>
-              <mainClass>com.linkedin.pinotdruidbenchmark.PinotThroughput</mainClass>
+              <mainClass>org.apache.pinotdruidbenchmark.PinotThroughput</mainClass>
               <name>pinot-throughput</name>
             </program>
             <program>
-              <mainClass>com.linkedin.pinotdruidbenchmark.DruidThroughput</mainClass>
+              <mainClass>org.apache.pinotdruidbenchmark.DruidThroughput</mainClass>
               <name>druid-throughput</name>
             </program>
           </programs>

diff --git a/contrib/pinot-druid-benchmark/src/main/java/com/linkedin/pinotdruidbenchmark/DataMerger.java b/contrib/pinot-druid-benchmark/src/main/java/com/linkedin/pinotdruidbenchmark/DataMerger.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinotdruidbenchmark;
+package org.apache.pinotdruidbenchmark;
 
 import java.io.BufferedReader;
 import java.io.BufferedWriter;

diff --git a/...b/pinot-druid-benchmark/src/main/java/com/linkedin/pinotdruidbenchmark/DataSeparator.java b/...b/pinot-druid-benchmark/src/main/java/com/linkedin/pinotdruidbenchmark/DataSeparator.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinotdruidbenchmark;
+package org.apache.pinotdruidbenchmark;
 
 import java.io.BufferedReader;
 import java.io.BufferedWriter;

diff --git a/...not-druid-benchmark/src/main/java/com/linkedin/pinotdruidbenchmark/DruidResponseTime.java b/...not-druid-benchmark/src/main/java/com/linkedin/pinotdruidbenchmark/DruidResponseTime.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinotdruidbenchmark;
+package org.apache.pinotdruidbenchmark;
 
 import java.io.BufferedInputStream;
 import java.io.BufferedReader;

diff --git a/...pinot-druid-benchmark/src/main/java/com/linkedin/pinotdruidbenchmark/DruidThroughput.java b/...pinot-druid-benchmark/src/main/java/com/linkedin/pinotdruidbenchmark/DruidThroughput.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinotdruidbenchmark;
+package org.apache.pinotdruidbenchmark;
 
 import java.io.BufferedReader;
 import java.io.File;

diff --git a/...not-druid-benchmark/src/main/java/com/linkedin/pinotdruidbenchmark/PinotResponseTime.java b/...not-druid-benchmark/src/main/java/com/linkedin/pinotdruidbenchmark/PinotResponseTime.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinotdruidbenchmark;
+package org.apache.pinotdruidbenchmark;
 
 import java.io.BufferedInputStream;
 import java.io.BufferedReader;

diff --git a/...pinot-druid-benchmark/src/main/java/com/linkedin/pinotdruidbenchmark/PinotThroughput.java b/...pinot-druid-benchmark/src/main/java/com/linkedin/pinotdruidbenchmark/PinotThroughput.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinotdruidbenchmark;
+package org.apache.pinotdruidbenchmark;
 
 import java.io.BufferedReader;
 import java.io.File;

diff --git a/pinot-api/pom.xml b/pinot-api/pom.xml
@@ -24,7 +24,7 @@
   <modelVersion>4.0.0</modelVersion>
   <parent>
     <artifactId>pinot</artifactId>
-    <groupId>com.linkedin.pinot</groupId>
+    <groupId>org.apache.pinot</groupId>
     <version>0.016</version>
   </parent>
   <artifactId>pinot-api</artifactId>

diff --git a/...kedin/pinot/client/AbstractResultSet.java → ...pache/pinot/client/AbstractResultSet.java b/...kedin/pinot/client/AbstractResultSet.java → ...pache/pinot/client/AbstractResultSet.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 /**
  * Shared implementation between the different ResultSets.

diff --git a/...in/pinot/client/AggregationResultSet.java → ...he/pinot/client/AggregationResultSet.java b/...in/pinot/client/AggregationResultSet.java → ...he/pinot/client/AggregationResultSet.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 import org.json.JSONException;
 import org.json.JSONObject;

diff --git a/...linkedin/pinot/client/BrokerResponse.java → ...g/apache/pinot/client/BrokerResponse.java b/...linkedin/pinot/client/BrokerResponse.java → ...g/apache/pinot/client/BrokerResponse.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 import java.util.List;
 import org.json.JSONArray;

diff --git a/...linkedin/pinot/client/BrokerSelector.java → ...g/apache/pinot/client/BrokerSelector.java b/...linkedin/pinot/client/BrokerSelector.java → ...g/apache/pinot/client/BrokerSelector.java
@@ -16,14 +16,14 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 public interface BrokerSelector {
   /**
    * Returns the broker address in the form host:port
    * @param table
    * @return
    */
-  String selectBroker(String table); 
-  
+  String selectBroker(String table);
+
 }
diff --git a/...com/linkedin/pinot/client/Connection.java → ...a/org/apache/pinot/client/Connection.java b/...com/linkedin/pinot/client/Connection.java → ...a/org/apache/pinot/client/Connection.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 import java.util.List;
 import java.util.concurrent.ExecutionException;

diff --git a/...kedin/pinot/client/ConnectionFactory.java → ...pache/pinot/client/ConnectionFactory.java b/...kedin/pinot/client/ConnectionFactory.java → ...pache/pinot/client/ConnectionFactory.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 import java.util.Arrays;
 import java.util.Properties;
@@ -63,5 +63,5 @@ public static Connection fromProperties(Properties properties) {
    */
   public static Connection fromHostList(String... brokers) {
     return new Connection(Arrays.asList(brokers), _transportFactory.buildTransport());
-  }  
+  }
 }
diff --git a/...n/pinot/client/DynamicBrokerSelector.java → ...e/pinot/client/DynamicBrokerSelector.java b/...n/pinot/client/DynamicBrokerSelector.java → ...e/pinot/client/DynamicBrokerSelector.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 import java.util.ArrayList;
 import java.util.HashSet;
@@ -31,8 +31,8 @@
 import org.I0Itec.zkclient.ZkClient;
 import org.I0Itec.zkclient.serialize.BytesPushThroughSerializer;
 
-import static com.linkedin.pinot.client.ExternalViewReader.OFFLINE_SUFFIX;
-import static com.linkedin.pinot.client.ExternalViewReader.REALTIME_SUFFIX;
+import static org.apache.pinot.client.ExternalViewReader.OFFLINE_SUFFIX;
+import static org.apache.pinot.client.ExternalViewReader.REALTIME_SUFFIX;
 
 
 /**
@@ -74,7 +74,7 @@ private void refresh() {
         return null;
       }
     }
-    String tableName = table.replace(OFFLINE_SUFFIX, "").replace(REALTIME_SUFFIX, "");
+    String tableName = table.replace(ExternalViewReader.OFFLINE_SUFFIX, "").replace(ExternalViewReader.REALTIME_SUFFIX, "");
     List<String> list = tableToBrokerListMapRef.get().get(tableName);
     if (list != null && !list.isEmpty()) {
       return list.get(_random.nextInt(list.size()));

diff --git a/...edin/pinot/client/ExternalViewReader.java → ...ache/pinot/client/ExternalViewReader.java b/...edin/pinot/client/ExternalViewReader.java → ...ache/pinot/client/ExternalViewReader.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;

diff --git a/...nkedin/pinot/client/GroupByResultSet.java → ...apache/pinot/client/GroupByResultSet.java b/...nkedin/pinot/client/GroupByResultSet.java → ...apache/pinot/client/GroupByResultSet.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 import org.json.JSONArray;
 import org.json.JSONException;

diff --git a/...nt/JsonAsyncHttpPinotClientTransport.java → ...nt/JsonAsyncHttpPinotClientTransport.java b/...nt/JsonAsyncHttpPinotClientTransport.java → ...nt/JsonAsyncHttpPinotClientTransport.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 import com.ning.http.client.AsyncHttpClient;
 import com.ning.http.client.Response;

diff --git a/...AsyncHttpPinotClientTransportFactory.java → ...AsyncHttpPinotClientTransportFactory.java b/...AsyncHttpPinotClientTransportFactory.java → ...AsyncHttpPinotClientTransportFactory.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 /**
  * Pinot client transport factory for JSON encoded BrokerResults through HTTP.

diff --git a/...in/pinot/client/PinotClientException.java → ...he/pinot/client/PinotClientException.java b/...in/pinot/client/PinotClientException.java → ...he/pinot/client/PinotClientException.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 /**
  * Pinot client exception.

diff --git a/...in/pinot/client/PinotClientTransport.java → ...he/pinot/client/PinotClientTransport.java b/...in/pinot/client/PinotClientTransport.java → ...he/pinot/client/PinotClientTransport.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 import java.util.concurrent.Future;
 

diff --git a/...t/client/PinotClientTransportFactory.java → ...t/client/PinotClientTransportFactory.java b/...t/client/PinotClientTransportFactory.java → ...t/client/PinotClientTransportFactory.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 /**
  * Factory for client transports.

diff --git a/...kedin/pinot/client/PreparedStatement.java → ...pache/pinot/client/PreparedStatement.java b/...kedin/pinot/client/PreparedStatement.java → ...pache/pinot/client/PreparedStatement.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 import java.util.concurrent.Future;
 

diff --git a/.../com/linkedin/pinot/client/ResultSet.java → ...va/org/apache/pinot/client/ResultSet.java b/.../com/linkedin/pinot/client/ResultSet.java → ...va/org/apache/pinot/client/ResultSet.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 /**
  * A Pinot result group, representing an aggregation function in the original query.
@@ -139,10 +139,10 @@ public interface ResultSet {
   /**
    * Get the group key name for the given key column index. use getGroupKeyLength() to know the number of groupKey
    * @param groupKeyColumnIndex
-   * @return group key column name 
+   * @return group key column name
    */
   String getGroupKeyColumnName(int groupKeyColumnIndex);
-  
+
   /**
    * Obtains the group key value for the given row and key column index.
    *

diff --git a/...linkedin/pinot/client/ResultSetGroup.java → ...g/apache/pinot/client/ResultSetGroup.java b/...linkedin/pinot/client/ResultSetGroup.java → ...g/apache/pinot/client/ResultSetGroup.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -74,7 +74,7 @@ public int getResultSetCount() {
   public ResultSet getResultSet(int index) {
     return _resultSets.get(index);
   }
-  
+
   @Override
   public String toString() {
     StringBuilder sb = new StringBuilder();

diff --git a/...edin/pinot/client/SelectionResultSet.java → ...ache/pinot/client/SelectionResultSet.java b/...edin/pinot/client/SelectionResultSet.java → ...ache/pinot/client/SelectionResultSet.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 import org.json.JSONArray;
 import org.json.JSONException;

diff --git a/...in/pinot/client/SimpleBrokerSelector.java → ...he/pinot/client/SimpleBrokerSelector.java b/...in/pinot/client/SimpleBrokerSelector.java → ...he/pinot/client/SimpleBrokerSelector.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 import java.util.List;
 import java.util.Random;

diff --git a/.../com/linkedin/pinot/client/TextTable.java → ...va/org/apache/pinot/client/TextTable.java b/.../com/linkedin/pinot/client/TextTable.java → ...va/org/apache/pinot/client/TextTable.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package com.linkedin.pinot.client;
+package org.apache.pinot.client;
 
 import java.util.LinkedList;
 import java.util.List;