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;
