You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ab...@apache.org on 2017/07/31 07:52:29 UTC
[11/77] [abbrv] incubator-gobblin git commit: Updated package names,
imports and shell scripts
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json
index 9b8dc0e..4ed7fd6 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json
@@ -2,7 +2,7 @@
"models" : [ {
"type" : "record",
"name" : "FlowStatusId",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"doc" : "Identifier for a specific execution of a flow",
"fields" : [ {
"name" : "flowName",
@@ -20,7 +20,7 @@
}, {
"type" : "record",
"name" : "FlowStatistics",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"doc" : "Statistics from a flow execution",
"fields" : [ {
"name" : "executionStartTime",
@@ -34,7 +34,7 @@
}, {
"type" : "enum",
"name" : "ExecutionStatus",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"doc" : "Execution status for a flow or job",
"symbols" : [ "RUNNING", "FAILED", "COMPLETE" ],
"symbolDocs" : {
@@ -45,7 +45,7 @@
}, {
"type" : "record",
"name" : "FlowId",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"doc" : "Identifier for a Gobblin as a Service flow",
"fields" : [ {
"name" : "flowName",
@@ -71,7 +71,7 @@
}, {
"type" : "record",
"name" : "JobId",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"doc" : "Identifier for a Gobblin job",
"fields" : [ {
"name" : "jobName",
@@ -97,7 +97,7 @@
}, {
"type" : "record",
"name" : "JobStatistics",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"doc" : "Statistics from a job execution",
"fields" : [ {
"name" : "executionStartTime",
@@ -115,7 +115,7 @@
}, {
"type" : "record",
"name" : "JobState",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"doc" : "Job state that is updated at the end of an execution",
"fields" : [ {
"name" : "lowWatermark",
@@ -129,7 +129,7 @@
}, {
"type" : "record",
"name" : "JobStatus",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"doc" : "Execution status for a job",
"fields" : [ {
"name" : "flowId",
@@ -159,7 +159,7 @@
}, {
"type" : "record",
"name" : "FlowStatus",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"doc" : "Status of a flow",
"fields" : [ {
"name" : "id",
@@ -197,9 +197,9 @@
} ],
"schema" : {
"name" : "flowstatuses",
- "namespace" : "gobblin.service",
+ "namespace" : "org.apache.gobblin.service",
"path" : "/flowstatuses",
- "schema" : "gobblin.service.FlowStatus",
+ "schema" : "org.apache.gobblin.service.FlowStatus",
"doc" : "Resource for handling flow status requests\n\ngenerated from: gobblin.service.FlowStatusResource",
"collection" : {
"identifier" : {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowConfigClient.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowConfigClient.java b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowConfigClient.java
index a2d47a5..28255bb 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowConfigClient.java
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowConfigClient.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.service;
+package org.apache.gobblin.service;
import java.io.Closeable;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowStatusClient.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowStatusClient.java b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowStatusClient.java
index 821e6cf..aeebe69 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowStatusClient.java
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowStatusClient.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.service;
+package org.apache.gobblin.service;
import com.google.common.base.Preconditions;
import com.linkedin.restli.client.FindRequest;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/java/org/apache/gobblin/service/FlowConfigTest.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/java/org/apache/gobblin/service/FlowConfigTest.java b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/java/org/apache/gobblin/service/FlowConfigTest.java
index 8e395a9..9ac7d37 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/java/org/apache/gobblin/service/FlowConfigTest.java
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/java/org/apache/gobblin/service/FlowConfigTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.service;
+package org.apache.gobblin.service;
import java.io.File;
import java.io.IOException;
@@ -42,10 +42,10 @@ import com.linkedin.restli.common.HttpStatus;
import com.linkedin.restli.server.resources.BaseResource;
import com.typesafe.config.Config;
-import gobblin.config.ConfigBuilder;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.restli.EmbeddedRestliServer;
-import gobblin.runtime.spec_catalog.FlowCatalog;
+import org.apache.gobblin.config.ConfigBuilder;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.restli.EmbeddedRestliServer;
+import org.apache.gobblin.runtime.spec_catalog.FlowCatalog;
@Test(groups = { "gobblin.service" })
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/java/org/apache/gobblin/service/FlowStatusTest.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/java/org/apache/gobblin/service/FlowStatusTest.java b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/java/org/apache/gobblin/service/FlowStatusTest.java
index 3d459dd..2d48972 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/java/org/apache/gobblin/service/FlowStatusTest.java
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/java/org/apache/gobblin/service/FlowStatusTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.service;
+package org.apache.gobblin.service;
import java.util.Iterator;
import java.util.List;
@@ -34,11 +34,11 @@ import com.google.inject.Module;
import com.google.inject.name.Names;
import com.linkedin.restli.server.resources.BaseResource;
-import gobblin.config.ConfigBuilder;
-import gobblin.metrics.event.TimingEvent;
-import gobblin.restli.EmbeddedRestliServer;
-import gobblin.service.monitoring.FlowStatusGenerator;
-import gobblin.service.monitoring.JobStatusRetriever;
+import org.apache.gobblin.config.ConfigBuilder;
+import org.apache.gobblin.metrics.event.TimingEvent;
+import org.apache.gobblin.restli.EmbeddedRestliServer;
+import org.apache.gobblin.service.monitoring.FlowStatusGenerator;
+import org.apache.gobblin.service.monitoring.JobStatusRetriever;
@Test(groups = { "gobblin.service" }, singleThreaded=true)
public class FlowStatusTest {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsResource.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsResource.java b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsResource.java
index c8a23db..bb47050 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsResource.java
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsResource.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.service;
+package org.apache.gobblin.service;
import java.net.URI;
import java.net.URISyntaxException;
@@ -40,11 +40,11 @@ import com.linkedin.restli.server.resources.ComplexKeyResourceTemplate;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.config.ConfigBuilder;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.FlowSpec;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.spec_catalog.FlowCatalog;
+import org.apache.gobblin.config.ConfigBuilder;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.FlowSpec;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.spec_catalog.FlowCatalog;
/**
* Resource for handling flow configuration requests
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
index 4303ff4..d8192d4 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.service;
+package org.apache.gobblin.service;
import com.linkedin.restli.server.PagingContext;
import com.linkedin.restli.server.annotations.Context;
@@ -35,8 +35,8 @@ import com.linkedin.restli.common.EmptyRecord;
import com.linkedin.restli.server.annotations.RestLiCollection;
import com.linkedin.restli.server.resources.ComplexKeyResourceTemplate;
-import gobblin.metrics.event.TimingEvent;
-import gobblin.service.monitoring.FlowStatusGenerator;
+import org.apache.gobblin.metrics.event.TimingEvent;
+import org.apache.gobblin.service.monitoring.FlowStatusGenerator;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/validator/CronValidator.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/validator/CronValidator.java b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/validator/CronValidator.java
index 7fa59ee..f9bf9be 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/validator/CronValidator.java
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/validator/CronValidator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.service.validator;
+package org.apache.gobblin.service.validator;
import org.quartz.CronExpression;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/validator/TemplateUriValidator.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/validator/TemplateUriValidator.java b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/validator/TemplateUriValidator.java
index 2108d8b..cc673ac 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/validator/TemplateUriValidator.java
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/validator/TemplateUriValidator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.service.validator;
+package org.apache.gobblin.service.validator;
import java.net.URI;
import java.net.URISyntaxException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/EmbeddedRestliServer.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/EmbeddedRestliServer.java b/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/EmbeddedRestliServer.java
index 2bbe55b..ed9b21f 100644
--- a/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/EmbeddedRestliServer.java
+++ b/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/EmbeddedRestliServer.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli;
+package org.apache.gobblin.restli;
import java.net.URI;
import java.net.URISyntaxException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/SharedRestClientFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/SharedRestClientFactory.java b/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/SharedRestClientFactory.java
index 16796cb..a0219d2 100644
--- a/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/SharedRestClientFactory.java
+++ b/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/SharedRestClientFactory.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli;
+package org.apache.gobblin.restli;
import java.net.URI;
import java.net.URISyntaxException;
@@ -39,16 +39,16 @@ import com.linkedin.r2.transport.http.client.HttpClientFactory;
import com.linkedin.restli.client.RestClient;
import com.typesafe.config.Config;
-import gobblin.broker.ResourceCoordinate;
-import gobblin.broker.ResourceInstance;
-import gobblin.broker.iface.ConfigView;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.ScopedConfigView;
-import gobblin.broker.iface.SharedResourceFactory;
-import gobblin.broker.iface.SharedResourceFactoryResponse;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.broker.ResourceCoordinate;
+import org.apache.gobblin.broker.ResourceInstance;
+import org.apache.gobblin.broker.iface.ConfigView;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopedConfigView;
+import org.apache.gobblin.broker.iface.SharedResourceFactory;
+import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.util.ExecutorsUtils;
import io.netty.channel.nio.NioEventLoopGroup;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/SharedRestClientKey.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/SharedRestClientKey.java b/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/SharedRestClientKey.java
index 0e3d95b..3ded545 100644
--- a/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/SharedRestClientKey.java
+++ b/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/SharedRestClientKey.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package gobblin.restli;
+package org.apache.gobblin.restli;
-import gobblin.broker.iface.SharedResourceKey;
+import org.apache.gobblin.broker.iface.SharedResourceKey;
import lombok.AllArgsConstructor;
import lombok.EqualsAndHashCode;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/UriRestClientKey.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/UriRestClientKey.java b/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/UriRestClientKey.java
index 68294e3..a3e2ea9 100644
--- a/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/UriRestClientKey.java
+++ b/gobblin-restli/gobblin-restli-utils/src/main/java/org/apache/gobblin/restli/UriRestClientKey.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli;
+package org.apache.gobblin.restli;
import java.net.URI;
import java.net.URISyntaxException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json
index dba9bee..799ecb7 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json
@@ -1,8 +1,8 @@
{
"name" : "permits",
- "namespace" : "gobblin.restli.throttling",
+ "namespace" : "org.apache.gobblin.restli.throttling",
"path" : "/permits",
- "schema" : "gobblin.restli.throttling.PermitAllocation",
+ "schema" : "org.apache.gobblin.restli.throttling.PermitAllocation",
"doc" : "Restli resource for allocating permits through Rest calls. Simply calls a {@link Limiter} in the server configured\n through {@link SharedResourcesBroker}.\n\ngenerated from: gobblin.restli.throttling.LimiterServerResource",
"collection" : {
"identifier" : {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/pegasus/org/apache/gobblin/restli/throttling/PermitAllocation.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/pegasus/org/apache/gobblin/restli/throttling/PermitAllocation.pdsc b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/pegasus/org/apache/gobblin/restli/throttling/PermitAllocation.pdsc
index 2fd5b95..7357ab9 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/pegasus/org/apache/gobblin/restli/throttling/PermitAllocation.pdsc
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/pegasus/org/apache/gobblin/restli/throttling/PermitAllocation.pdsc
@@ -1,7 +1,7 @@
{
"name": "PermitAllocation",
"type": "record",
- "namespace": "gobblin.restli.throttling",
+ "namesapce" : "org.apache.gobblin.restli.throttling",
"doc": "Used by gobblin-throttling-service to allocate permits to a client.",
"fields": [
{"name": "permits", "type": "long", "doc": "Number of permits allocated. This may be 0 if no permits are allocated, or the number of requested permits."},
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/pegasus/org/apache/gobblin/restli/throttling/PermitRequest.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/pegasus/org/apache/gobblin/restli/throttling/PermitRequest.pdsc b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/pegasus/org/apache/gobblin/restli/throttling/PermitRequest.pdsc
index b6e316a..5e4c0e4 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/pegasus/org/apache/gobblin/restli/throttling/PermitRequest.pdsc
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/pegasus/org/apache/gobblin/restli/throttling/PermitRequest.pdsc
@@ -1,7 +1,7 @@
{
"name": "PermitRequest",
"type": "record",
- "namespace": "gobblin.restli.throttling",
+ "namesapce" : "org.apache.gobblin.restli.throttling",
"doc": "Used to request permits from a gobblin-throttling-service.",
"fields": [
{"name": "resource", "type": "string", "doc": "Resource for which permits are needed."},
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/pegasus/org/apache/gobblin/restli/throttling/Policy.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/pegasus/org/apache/gobblin/restli/throttling/Policy.pdsc b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/pegasus/org/apache/gobblin/restli/throttling/Policy.pdsc
index cd0bc0f..f7d1482 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/pegasus/org/apache/gobblin/restli/throttling/Policy.pdsc
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/pegasus/org/apache/gobblin/restli/throttling/Policy.pdsc
@@ -1,7 +1,7 @@
{
"name": "Policy",
"type": "record",
- "namespace": "gobblin.restli.throttling",
+ "namesapce" : "org.apache.gobblin.restli.throttling",
"doc": "A throttling policy for Gobblin throttling service.",
"fields": [
{"name": "resource", "type": "string", "doc": "Resource for which this policy applied."},
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json
index c1c0543..65947c0 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json
@@ -2,7 +2,7 @@
"models" : [ {
"type" : "record",
"name" : "PermitAllocation",
- "namespace" : "gobblin.restli.throttling",
+ "namespace" : "org.apache.gobblin.restli.throttling",
"doc" : "Used by gobblin-throttling-service to allocate permits to a client.",
"fields" : [ {
"name" : "permits",
@@ -21,7 +21,7 @@
}, {
"type" : "record",
"name" : "PermitRequest",
- "namespace" : "gobblin.restli.throttling",
+ "namespace" : "org.apache.gobblin.restli.throttling",
"doc" : "Used to request permits from a gobblin-throttling-service.",
"fields" : [ {
"name" : "resource",
@@ -53,9 +53,9 @@
} ],
"schema" : {
"name" : "permits",
- "namespace" : "gobblin.restli.throttling",
+ "namespace" : "org.apache.gobblin.restli.throttling",
"path" : "/permits",
- "schema" : "gobblin.restli.throttling.PermitAllocation",
+ "schema" : "org.apache.gobblin.restli.throttling.PermitAllocation",
"doc" : "Restli resource for allocating permits through Rest calls. Simply calls a {@link Limiter} in the server configured\n through {@link SharedResourcesBroker}.\n\ngenerated from: gobblin.restli.throttling.LimiterServerResource",
"collection" : {
"identifier" : {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/BatchedPermitsRequester.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/BatchedPermitsRequester.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/BatchedPermitsRequester.java
index 9ea8c50..48eb60d 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/BatchedPermitsRequester.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/BatchedPermitsRequester.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import java.io.Closeable;
import java.io.IOException;
@@ -47,11 +47,11 @@ import com.linkedin.restli.client.Response;
import com.linkedin.restli.client.RestLiResponseException;
import com.linkedin.restli.common.HttpStatus;
-import gobblin.metrics.MetricContext;
-import gobblin.restli.throttling.PermitAllocation;
-import gobblin.restli.throttling.PermitRequest;
-import gobblin.util.ExecutorsUtils;
-import gobblin.util.NoopCloseable;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.restli.throttling.PermitAllocation;
+import org.apache.gobblin.restli.throttling.PermitRequest;
+import org.apache.gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.NoopCloseable;
import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
import javax.annotation.Nullable;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RedirectAwareRestClientRequestSender.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RedirectAwareRestClientRequestSender.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RedirectAwareRestClientRequestSender.java
index 7a9f33c..2f557a5 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RedirectAwareRestClientRequestSender.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RedirectAwareRestClientRequestSender.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import java.net.ConnectException;
import java.net.URI;
@@ -33,20 +33,20 @@ import com.linkedin.restli.client.RestClient;
import com.linkedin.restli.client.RestLiResponseException;
import com.linkedin.restli.common.HttpStatus;
-import gobblin.broker.ResourceInstance;
-import gobblin.broker.iface.ConfigView;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.ScopedConfigView;
-import gobblin.broker.iface.SharedResourceFactory;
-import gobblin.broker.iface.SharedResourceFactoryResponse;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.restli.SharedRestClientFactory;
-import gobblin.restli.SharedRestClientKey;
-import gobblin.restli.UriRestClientKey;
-import gobblin.restli.throttling.PermitAllocation;
-import gobblin.restli.throttling.PermitRequest;
-import gobblin.util.ExponentialBackoff;
+import org.apache.gobblin.broker.ResourceInstance;
+import org.apache.gobblin.broker.iface.ConfigView;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopedConfigView;
+import org.apache.gobblin.broker.iface.SharedResourceFactory;
+import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.restli.SharedRestClientFactory;
+import org.apache.gobblin.restli.SharedRestClientKey;
+import org.apache.gobblin.restli.UriRestClientKey;
+import org.apache.gobblin.restli.throttling.PermitAllocation;
+import org.apache.gobblin.restli.throttling.PermitRequest;
+import org.apache.gobblin.util.ExponentialBackoff;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RequestSender.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RequestSender.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RequestSender.java
index f18aaea..d2a6543 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RequestSender.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RequestSender.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import com.linkedin.common.callback.Callback;
import com.linkedin.restli.client.Response;
-import gobblin.restli.throttling.PermitAllocation;
-import gobblin.restli.throttling.PermitRequest;
+import org.apache.gobblin.restli.throttling.PermitAllocation;
+import org.apache.gobblin.restli.throttling.PermitRequest;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestClientRequestSender.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestClientRequestSender.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestClientRequestSender.java
index 02c6e53..2142d03 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestClientRequestSender.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestClientRequestSender.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import com.linkedin.common.callback.Callback;
import com.linkedin.restli.client.Request;
@@ -24,10 +24,10 @@ import com.linkedin.restli.client.RestClient;
import com.linkedin.restli.common.ComplexResourceKey;
import com.linkedin.restli.common.EmptyRecord;
-import gobblin.restli.throttling.PermitAllocation;
-import gobblin.restli.throttling.PermitRequest;
-import gobblin.restli.throttling.PermitsGetRequestBuilder;
-import gobblin.restli.throttling.PermitsRequestBuilders;
+import org.apache.gobblin.restli.throttling.PermitAllocation;
+import org.apache.gobblin.restli.throttling.PermitRequest;
+import org.apache.gobblin.restli.throttling.PermitsGetRequestBuilder;
+import org.apache.gobblin.restli.throttling.PermitsRequestBuilders;
import lombok.AllArgsConstructor;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestliLimiterFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestliLimiterFactory.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestliLimiterFactory.java
index 011737a..66f1889 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestliLimiterFactory.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestliLimiterFactory.java
@@ -15,25 +15,25 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import com.google.common.collect.ImmutableMap;
import com.linkedin.restli.client.RestClient;
-import gobblin.broker.ResourceCoordinate;
-import gobblin.broker.ResourceInstance;
-import gobblin.broker.iface.ConfigView;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.ScopedConfigView;
-import gobblin.broker.iface.SharedResourceFactory;
-import gobblin.broker.iface.SharedResourceFactoryResponse;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.metrics.broker.MetricContextFactory;
-import gobblin.metrics.broker.MetricContextKey;
-import gobblin.metrics.broker.SubTaggedMetricContextKey;
-import gobblin.restli.SharedRestClientKey;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.broker.ResourceCoordinate;
+import org.apache.gobblin.broker.ResourceInstance;
+import org.apache.gobblin.broker.iface.ConfigView;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopedConfigView;
+import org.apache.gobblin.broker.iface.SharedResourceFactory;
+import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.metrics.broker.MetricContextFactory;
+import org.apache.gobblin.metrics.broker.MetricContextKey;
+import org.apache.gobblin.metrics.broker.SubTaggedMetricContextKey;
+import org.apache.gobblin.restli.SharedRestClientKey;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
import lombok.extern.slf4j.Slf4j;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestliServiceBasedLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestliServiceBasedLimiter.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestliServiceBasedLimiter.java
index d55f5a9..fc0dc9b 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestliServiceBasedLimiter.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestliServiceBasedLimiter.java
@@ -15,16 +15,16 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import com.codahale.metrics.Meter;
import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.MetricContext;
-import gobblin.util.NoopCloseable;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.util.NoopCloseable;
import java.io.Closeable;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/FixedOperationsStressor.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/FixedOperationsStressor.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/FixedOperationsStressor.java
index 9d2cd8c..f315659 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/FixedOperationsStressor.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/FixedOperationsStressor.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package gobblin.util.limiter.stressTest;
+package org.apache.gobblin.util.limiter.stressTest;
import org.apache.hadoop.conf.Configuration;
-import gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.Limiter;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/MRStressTest.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/MRStressTest.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/MRStressTest.java
index 46f1d8f..b42af49 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/MRStressTest.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/MRStressTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter.stressTest;
+package org.apache.gobblin.util.limiter.stressTest;
import java.io.DataInput;
import java.io.DataOutput;
@@ -57,20 +57,20 @@ import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import com.typesafe.config.ConfigFactory;
-import gobblin.broker.BrokerConfigurationKeyGenerator;
-import gobblin.broker.SharedResourcesBrokerFactory;
-import gobblin.broker.SimpleScopeType;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.restli.SharedRestClientFactory;
-import gobblin.restli.SharedRestClientKey;
-import gobblin.util.ExecutorsUtils;
-import gobblin.util.limiter.Limiter;
-import gobblin.util.limiter.MultiLimiter;
-import gobblin.util.limiter.NoopLimiter;
-import gobblin.util.limiter.RateBasedLimiter;
-import gobblin.util.limiter.RestliLimiterFactory;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.broker.BrokerConfigurationKeyGenerator;
+import org.apache.gobblin.broker.SharedResourcesBrokerFactory;
+import org.apache.gobblin.broker.SimpleScopeType;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.restli.SharedRestClientFactory;
+import org.apache.gobblin.restli.SharedRestClientKey;
+import org.apache.gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.MultiLimiter;
+import org.apache.gobblin.util.limiter.NoopLimiter;
+import org.apache.gobblin.util.limiter.RateBasedLimiter;
+import org.apache.gobblin.util.limiter.RestliLimiterFactory;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
import lombok.Data;
import lombok.RequiredArgsConstructor;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RandomDelayStartStressor.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RandomDelayStartStressor.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RandomDelayStartStressor.java
index 0f37e01..b1a24c5 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RandomDelayStartStressor.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RandomDelayStartStressor.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.util.limiter.stressTest;
+package org.apache.gobblin.util.limiter.stressTest;
import java.util.Random;
import org.apache.hadoop.conf.Configuration;
-import gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.Limiter;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RandomRuntimeStressor.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RandomRuntimeStressor.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RandomRuntimeStressor.java
index a215e54..412102e 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RandomRuntimeStressor.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RandomRuntimeStressor.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.util.limiter.stressTest;
+package org.apache.gobblin.util.limiter.stressTest;
import java.util.Random;
import org.apache.hadoop.conf.Configuration;
-import gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.Limiter;
import lombok.extern.slf4j.Slf4j;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RateComputingLimiterContainer.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RateComputingLimiterContainer.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RateComputingLimiterContainer.java
index 8abc3cb..cad9376 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RateComputingLimiterContainer.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RateComputingLimiterContainer.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter.stressTest;
+package org.apache.gobblin.util.limiter.stressTest;
import java.io.Closeable;
import java.util.ArrayList;
@@ -32,9 +32,9 @@ import com.google.common.base.Function;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
-import gobblin.util.Decorator;
-import gobblin.util.limiter.Limiter;
-import gobblin.util.limiter.RestliServiceBasedLimiter;
+import org.apache.gobblin.util.Decorator;
+import org.apache.gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.RestliServiceBasedLimiter;
import javax.annotation.Nullable;
import lombok.AccessLevel;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/StressTestUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/StressTestUtils.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/StressTestUtils.java
index 4e14a9e..dc5c370 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/StressTestUtils.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/StressTestUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter.stressTest;
+package org.apache.gobblin.util.limiter.stressTest;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/Stressor.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/Stressor.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/Stressor.java
index e1493be..2ccdc98 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/Stressor.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/Stressor.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package gobblin.util.limiter.stressTest;
+package org.apache.gobblin.util.limiter.stressTest;
import org.apache.hadoop.conf.Configuration;
-import gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.Limiter;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/restli/throttling/LocalStressTest.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/restli/throttling/LocalStressTest.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/restli/throttling/LocalStressTest.java
index 5b80feb..e72f67d 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/restli/throttling/LocalStressTest.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/restli/throttling/LocalStressTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import java.util.LinkedList;
import java.util.Map;
@@ -38,15 +38,15 @@ import com.google.inject.Key;
import com.google.inject.name.Names;
import com.typesafe.config.ConfigFactory;
-import gobblin.broker.BrokerConfigurationKeyGenerator;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.util.limiter.Limiter;
-import gobblin.util.limiter.MockRequester;
-import gobblin.util.limiter.RestliServiceBasedLimiter;
-import gobblin.util.limiter.broker.SharedLimiterKey;
-import gobblin.util.limiter.stressTest.RateComputingLimiterContainer;
-import gobblin.util.limiter.stressTest.StressTestUtils;
-import gobblin.util.limiter.stressTest.Stressor;
+import org.apache.gobblin.broker.BrokerConfigurationKeyGenerator;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.MockRequester;
+import org.apache.gobblin.util.limiter.RestliServiceBasedLimiter;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.util.limiter.stressTest.RateComputingLimiterContainer;
+import org.apache.gobblin.util.limiter.stressTest.StressTestUtils;
+import org.apache.gobblin.util.limiter.stressTest.Stressor;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/restli/throttling/ThrottlingClientTest.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/restli/throttling/ThrottlingClientTest.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/restli/throttling/ThrottlingClientTest.java
index 8205a0d..135f462 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/restli/throttling/ThrottlingClientTest.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/restli/throttling/ThrottlingClientTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import java.util.Collections;
import java.util.Map;
@@ -39,9 +39,9 @@ import com.linkedin.restli.common.HttpStatus;
import com.linkedin.restli.server.resources.BaseResource;
import com.typesafe.config.ConfigFactory;
-import gobblin.broker.BrokerConfigurationKeyGenerator;
-import gobblin.restli.EmbeddedRestliServer;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.broker.BrokerConfigurationKeyGenerator;
+import org.apache.gobblin.restli.EmbeddedRestliServer;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
import avro.shaded.com.google.common.collect.ImmutableMap;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/BatchedPermitsRequesterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/BatchedPermitsRequesterTest.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/BatchedPermitsRequesterTest.java
index c00e8ca..b02f545 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/BatchedPermitsRequesterTest.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/BatchedPermitsRequesterTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import java.io.Closeable;
import java.io.IOException;
@@ -39,9 +39,9 @@ import com.linkedin.restli.client.RestClient;
import com.linkedin.restli.client.RestLiResponseException;
import com.linkedin.restli.common.HttpStatus;
-import gobblin.restli.throttling.PermitAllocation;
-import gobblin.restli.throttling.PermitRequest;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.restli.throttling.PermitAllocation;
+import org.apache.gobblin.restli.throttling.PermitRequest;
+import org.apache.gobblin.util.ExecutorsUtils;
import lombok.AllArgsConstructor;
import lombok.Builder;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/MockRequester.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/MockRequester.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/MockRequester.java
index 3ca26ec..80084f1 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/MockRequester.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/MockRequester.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
@@ -32,9 +32,9 @@ import com.linkedin.restli.common.ComplexResourceKey;
import com.linkedin.restli.common.EmptyRecord;
import com.linkedin.restli.server.RestLiServiceException;
-import gobblin.restli.throttling.LimiterServerResource;
-import gobblin.restli.throttling.PermitAllocation;
-import gobblin.restli.throttling.PermitRequest;
+import org.apache.gobblin.restli.throttling.LimiterServerResource;
+import org.apache.gobblin.restli.throttling.PermitAllocation;
+import org.apache.gobblin.restli.throttling.PermitRequest;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/RestliLimiterFactoryTest.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/RestliLimiterFactoryTest.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/RestliLimiterFactoryTest.java
index 951612f..4649f29 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/RestliLimiterFactoryTest.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/RestliLimiterFactoryTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import java.util.List;
import java.util.Map;
@@ -30,15 +30,15 @@ import com.linkedin.common.callback.Callback;
import com.linkedin.restli.client.Response;
import com.typesafe.config.ConfigFactory;
-import gobblin.broker.BrokerConfigurationKeyGenerator;
-import gobblin.broker.SharedResourcesBrokerFactory;
-import gobblin.broker.SimpleScopeType;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.restli.SharedRestClientKey;
-import gobblin.restli.throttling.PermitAllocation;
-import gobblin.restli.throttling.PermitRequest;
-import gobblin.util.limiter.broker.SharedLimiterFactory;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.broker.BrokerConfigurationKeyGenerator;
+import org.apache.gobblin.broker.SharedResourcesBrokerFactory;
+import org.apache.gobblin.broker.SimpleScopeType;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.restli.SharedRestClientKey;
+import org.apache.gobblin.restli.throttling.PermitAllocation;
+import org.apache.gobblin.restli.throttling.PermitRequest;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterFactory;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
public class RestliLimiterFactoryTest {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/RestliServiceBasedLimiterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/RestliServiceBasedLimiterTest.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/RestliServiceBasedLimiterTest.java
index e0f2c54..feb7386 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/RestliServiceBasedLimiterTest.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/test/java/org/apache/gobblin/util/limiter/RestliServiceBasedLimiterTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.Lists;
@@ -25,16 +25,16 @@ import com.google.inject.Injector;
import com.linkedin.restli.server.resources.BaseResource;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.broker.BrokerConfigurationKeyGenerator;
-import gobblin.broker.SharedResourcesBrokerFactory;
-import gobblin.broker.SimpleScopeType;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.restli.EmbeddedRestliServer;
-import gobblin.restli.throttling.CountBasedPolicy;
-import gobblin.restli.throttling.LimiterServerResource;
-import gobblin.restli.throttling.ThrottlingGuiceServletConfig;
-import gobblin.restli.throttling.ThrottlingPolicyFactory;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.broker.BrokerConfigurationKeyGenerator;
+import org.apache.gobblin.broker.SharedResourcesBrokerFactory;
+import org.apache.gobblin.broker.SimpleScopeType;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.restli.EmbeddedRestliServer;
+import org.apache.gobblin.restli.throttling.CountBasedPolicy;
+import org.apache.gobblin.restli.throttling.LimiterServerResource;
+import org.apache.gobblin.restli.throttling.ThrottlingGuiceServletConfig;
+import org.apache.gobblin.restli.throttling.ThrottlingPolicyFactory;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
import java.net.URI;
import java.net.URISyntaxException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ConfigClientBasedPolicyFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ConfigClientBasedPolicyFactory.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ConfigClientBasedPolicyFactory.java
index 562d559..1d310a3 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ConfigClientBasedPolicyFactory.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ConfigClientBasedPolicyFactory.java
@@ -15,21 +15,21 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import java.net.URI;
import java.net.URISyntaxException;
import com.typesafe.config.Config;
-import gobblin.broker.TTLResourceEntry;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.config.client.ConfigClient;
-import gobblin.config.client.api.ConfigStoreFactoryDoesNotExistsException;
-import gobblin.config.client.api.VersionStabilityPolicy;
-import gobblin.config.store.api.ConfigStoreCreationException;
-import gobblin.util.ConfigUtils;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.broker.TTLResourceEntry;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.config.client.ConfigClient;
+import org.apache.gobblin.config.client.api.ConfigStoreFactoryDoesNotExistsException;
+import org.apache.gobblin.config.client.api.VersionStabilityPolicy;
+import org.apache.gobblin.config.store.api.ConfigStoreCreationException;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/CountBasedPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/CountBasedPolicy.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/CountBasedPolicy.java
index 6146f07..4288270 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/CountBasedPolicy.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/CountBasedPolicy.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import java.util.Map;
@@ -25,10 +25,10 @@ import com.linkedin.restli.common.HttpStatus;
import com.linkedin.restli.server.RestLiServiceException;
import com.typesafe.config.Config;
-import gobblin.annotation.Alias;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.util.limiter.CountBasedLimiter;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.util.limiter.CountBasedLimiter;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/DynamicTokenBucket.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/DynamicTokenBucket.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/DynamicTokenBucket.java
index 35bbad6..c0f1d33 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/DynamicTokenBucket.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/DynamicTokenBucket.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import java.util.concurrent.TimeUnit;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LeaderFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LeaderFinder.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LeaderFinder.java
index 5a3c221..830a925 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LeaderFinder.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LeaderFinder.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import java.io.Serializable;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java
index 73be3bc..94b303f 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import java.io.Closeable;
import java.io.IOException;
@@ -38,15 +38,15 @@ import com.linkedin.restli.server.annotations.RestLiCollection;
import com.linkedin.restli.server.annotations.RestMethod;
import com.linkedin.restli.server.resources.ComplexKeyResourceAsyncTemplate;
-import gobblin.annotation.Alpha;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.broker.MetricContextFactory;
-import gobblin.metrics.broker.SubTaggedMetricContextKey;
-import gobblin.util.NoopCloseable;
-import gobblin.util.limiter.Limiter;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.broker.MetricContextFactory;
+import org.apache.gobblin.metrics.broker.SubTaggedMetricContextKey;
+import org.apache.gobblin.util.NoopCloseable;
+import org.apache.gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
import javax.inject.Inject;
import javax.inject.Named;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/NoopPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/NoopPolicy.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/NoopPolicy.java
index 012323a..f25c167 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/NoopPolicy.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/NoopPolicy.java
@@ -15,17 +15,17 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import java.util.Map;
import com.google.common.collect.ImmutableMap;
import com.typesafe.config.Config;
-import gobblin.annotation.Alias;
-import gobblin.annotation.Alpha;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/PoliciesResource.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/PoliciesResource.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/PoliciesResource.java
index ea02fd9..9242717 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/PoliciesResource.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/PoliciesResource.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import java.util.Map;
@@ -27,17 +27,17 @@ import com.linkedin.restli.server.RestLiServiceException;
import com.linkedin.restli.server.annotations.RestLiCollection;
import com.linkedin.restli.server.resources.CollectionResourceTemplate;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.broker.MetricContextFactory;
-import gobblin.metrics.broker.SubTaggedMetricContextKey;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.broker.MetricContextFactory;
+import org.apache.gobblin.metrics.broker.SubTaggedMetricContextKey;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
import javax.inject.Inject;
import javax.inject.Named;
-import static gobblin.restli.throttling.LimiterServerResource.*;
+import static org.apache.gobblin.restli.throttling.LimiterServerResource.*;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/QPSPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/QPSPolicy.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/QPSPolicy.java
index 56ecd7f..dbb05b9 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/QPSPolicy.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/QPSPolicy.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import java.util.Map;
@@ -25,10 +25,10 @@ import com.google.common.collect.ImmutableMap;
import com.linkedin.data.template.GetMode;
import com.typesafe.config.Config;
-import gobblin.annotation.Alias;
-import gobblin.annotation.Alpha;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java
index e0d88ef..b2f18ff 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java
@@ -10,7 +10,7 @@
* CONDITIONS OF ANY KIND, either express or implied.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import com.codahale.metrics.Timer;
import com.google.common.base.Optional;
@@ -36,12 +36,12 @@ import com.linkedin.restli.server.guice.GuiceRestliServlet;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.broker.SharedResourcesBrokerFactory;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.broker.MetricContextFactory;
-import gobblin.metrics.broker.MetricContextKey;
+import org.apache.gobblin.broker.SharedResourcesBrokerFactory;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.broker.MetricContextFactory;
+import org.apache.gobblin.metrics.broker.MetricContextKey;
import java.io.Closeable;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingPolicy.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingPolicy.java
index 6e2bd2b..ca25f52 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingPolicy.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingPolicy.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import java.util.Map;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingPolicyFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingPolicyFactory.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingPolicyFactory.java
index 667f00d..4e54f5b 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingPolicyFactory.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingPolicyFactory.java
@@ -15,21 +15,21 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import com.typesafe.config.Config;
-import gobblin.broker.ResourceInstance;
-import gobblin.broker.TTLResourceEntry;
-import gobblin.broker.iface.ConfigView;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.ScopedConfigView;
-import gobblin.broker.iface.SharedResourceFactory;
-import gobblin.broker.iface.SharedResourceFactoryResponse;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.util.ClassAliasResolver;
-import gobblin.util.ConfigUtils;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.broker.ResourceInstance;
+import org.apache.gobblin.broker.TTLResourceEntry;
+import org.apache.gobblin.broker.iface.ConfigView;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.ScopedConfigView;
+import org.apache.gobblin.broker.iface.SharedResourceFactory;
+import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingServerScopes.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingServerScopes.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingServerScopes.java
index 557427b..2866b9d 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingServerScopes.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingServerScopes.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import java.util.Collection;
import java.util.List;
@@ -24,9 +24,9 @@ import java.util.Set;
import com.google.common.collect.Lists;
import com.google.common.collect.Sets;
-import gobblin.broker.SimpleScope;
-import gobblin.broker.iface.ScopeInstance;
-import gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.SimpleScope;
+import org.apache.gobblin.broker.iface.ScopeInstance;
+import org.apache.gobblin.broker.iface.ScopeType;
import javax.annotation.Nullable;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/TokenBucket.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/TokenBucket.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/TokenBucket.java
index a345023..ac21e87 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/TokenBucket.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/TokenBucket.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import java.util.concurrent.TimeUnit;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/URIMetadata.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/URIMetadata.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/URIMetadata.java
index 6826b28..1b3986e 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/URIMetadata.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/URIMetadata.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import java.net.URI;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ZookeeperLeaderElection.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ZookeeperLeaderElection.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ZookeeperLeaderElection.java
index 1a9ea07..7a645b7 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ZookeeperLeaderElection.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ZookeeperLeaderElection.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.restli.throttling;
+package org.apache.gobblin.restli.throttling;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
@@ -38,7 +38,7 @@ import org.apache.zookeeper.data.Stat;
import com.google.common.util.concurrent.AbstractIdleService;
-import gobblin.util.SerializationUtils;
+import org.apache.gobblin.util.SerializationUtils;
import lombok.extern.slf4j.Slf4j;