Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id AF11E200CD6 for ; Mon, 31 Jul 2017 09:52:33 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id AD73A1649C9; Mon, 31 Jul 2017 07:52:33 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 4195816499A for ; Mon, 31 Jul 2017 09:52:31 +0200 (CEST) Received: (qmail 18588 invoked by uid 500); 31 Jul 2017 07:52:30 -0000 Mailing-List: contact commits-help@gobblin.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@gobblin.incubator.apache.org Delivered-To: mailing list commits@gobblin.incubator.apache.org Received: (qmail 16458 invoked by uid 99); 31 Jul 2017 07:52:23 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 31 Jul 2017 07:52:23 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 29D81F336C; Mon, 31 Jul 2017 07:52:19 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: abti@apache.org To: commits@gobblin.apache.org Date: Mon, 31 Jul 2017 07:52:38 -0000 Message-Id: <863e26200b1e4b7d8cf34e63e1e694ca@git.apache.org> In-Reply-To: <50c2ce484ba041a294296078b24418ae@git.apache.org> References: <50c2ce484ba041a294296078b24418ae@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [20/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts archived-at: Mon, 31 Jul 2017 07:52:33 -0000 http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatabaseJobHistoryStore.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatabaseJobHistoryStore.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatabaseJobHistoryStore.java index 914ab42..986cd90 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatabaseJobHistoryStore.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatabaseJobHistoryStore.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore; +package org.apache.gobblin.metastore; import javax.annotation.Nullable; import javax.sql.DataSource; @@ -40,10 +40,10 @@ import com.google.common.collect.Lists; import com.google.common.collect.Sets; import com.google.inject.Inject; -import gobblin.metastore.database.SupportedDatabaseVersion; -import gobblin.metastore.database.VersionedDatabaseJobHistoryStore; -import gobblin.rest.JobExecutionInfo; -import gobblin.rest.JobExecutionQuery; +import org.apache.gobblin.metastore.database.SupportedDatabaseVersion; +import org.apache.gobblin.metastore.database.VersionedDatabaseJobHistoryStore; +import org.apache.gobblin.rest.JobExecutionInfo; +import org.apache.gobblin.rest.JobExecutionQuery; import org.reflections.util.ClasspathHelper; import org.reflections.util.ConfigurationBuilder; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatasetStateStore.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatasetStateStore.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatasetStateStore.java index 3334354..16b3442 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatasetStateStore.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatasetStateStore.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore; +package org.apache.gobblin.metastore; import java.io.IOException; import java.util.Collection; @@ -23,7 +23,7 @@ import java.util.Map; import com.typesafe.config.Config; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; public interface DatasetStateStore extends StateStore { String DATASET_STATE_STORE_TABLE_SUFFIX = ".jst"; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/FsStateStore.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/FsStateStore.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/FsStateStore.java index 835db66..96c3e51 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/FsStateStore.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/FsStateStore.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.metastore; +package org.apache.gobblin.metastore; -import static gobblin.util.HadoopUtils.FS_SCHEMES_NON_ATOMIC; +import static org.apache.gobblin.util.HadoopUtils.FS_SCHEMES_NON_ATOMIC; import com.google.common.base.Predicate; -import gobblin.util.HadoopUtils; +import org.apache.gobblin.util.HadoopUtils; import java.io.IOException; import java.net.URI; import java.util.Collection; @@ -39,8 +39,8 @@ import com.google.common.base.Strings; import com.google.common.collect.Lists; import com.google.common.io.Closer; -import gobblin.configuration.State; -import gobblin.util.WritableShimSerialization; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.WritableShimSerialization; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/FsStateStoreFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/FsStateStoreFactory.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/FsStateStoreFactory.java index 5ce44f2..1331362 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/FsStateStoreFactory.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/FsStateStoreFactory.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.metastore; +package org.apache.gobblin.metastore; import com.typesafe.config.Config; import com.typesafe.config.ConfigValue; -import gobblin.annotation.Alias; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.ConfigUtils; import java.io.IOException; import java.net.URI; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java index 79e56fd..13a398f 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.metastore; +package org.apache.gobblin.metastore; import java.util.Properties; import com.google.inject.Inject; import com.google.inject.name.Named; -import gobblin.configuration.ConfigurationKeys; -import gobblin.password.PasswordManager; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.password.PasswordManager; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryStore.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryStore.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryStore.java index 3833897..3e05daf 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryStore.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryStore.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.metastore; +package org.apache.gobblin.metastore; import java.io.Closeable; import java.io.IOException; import java.util.List; -import gobblin.rest.JobExecutionInfo; -import gobblin.rest.JobExecutionQuery; +import org.apache.gobblin.rest.JobExecutionInfo; +import org.apache.gobblin.rest.JobExecutionQuery; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MetaStoreModule.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MetaStoreModule.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MetaStoreModule.java index 6363aa0..3b0d77f 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MetaStoreModule.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MetaStoreModule.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore; +package org.apache.gobblin.metastore; import java.util.Properties; import javax.sql.DataSource; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStore.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStore.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStore.java index 1d3a133..3e2b928 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStore.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStore.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package gobblin.metastore; +package org.apache.gobblin.metastore; import com.google.common.base.Predicate; import com.google.common.base.Strings; import com.google.common.collect.Lists; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.password.PasswordManager; -import gobblin.util.ConfigUtils; -import gobblin.util.io.StreamUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.password.PasswordManager; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.io.StreamUtils; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.DataInputStream; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStoreFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStoreFactory.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStoreFactory.java index 44103d0..aad441a 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStoreFactory.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStoreFactory.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.metastore; +package org.apache.gobblin.metastore; import com.typesafe.config.Config; -import gobblin.annotation.Alias; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.ConfigUtils; import java.util.Properties; import org.apache.commons.dbcp.BasicDataSource; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/StateStore.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/StateStore.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/StateStore.java index 65f11c4..578c94a 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/StateStore.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/StateStore.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore; +package org.apache.gobblin.metastore; import com.google.common.base.Predicate; import com.typesafe.config.Config; @@ -23,7 +23,7 @@ import java.io.IOException; import java.util.Collection; import java.util.List; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV100.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV100.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV100.java index 38cd464..4bbae5a 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV100.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV100.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore.database; +package org.apache.gobblin.metastore.database; import java.io.IOException; import java.sql.Connection; @@ -48,22 +48,22 @@ import com.google.common.collect.Maps; import com.linkedin.data.template.StringMap; -import gobblin.metastore.DatabaseJobHistoryStore; -import gobblin.metastore.JobHistoryStore; -import gobblin.rest.JobExecutionInfo; -import gobblin.rest.JobExecutionQuery; -import gobblin.rest.JobStateEnum; -import gobblin.rest.LauncherTypeEnum; -import gobblin.rest.Metric; -import gobblin.rest.MetricArray; -import gobblin.rest.MetricTypeEnum; -import gobblin.rest.QueryListType; -import gobblin.rest.Table; -import gobblin.rest.TableTypeEnum; -import gobblin.rest.TaskExecutionInfo; -import gobblin.rest.TaskExecutionInfoArray; -import gobblin.rest.TaskStateEnum; -import gobblin.rest.TimeRange; +import org.apache.gobblin.metastore.DatabaseJobHistoryStore; +import org.apache.gobblin.metastore.JobHistoryStore; +import org.apache.gobblin.rest.JobExecutionInfo; +import org.apache.gobblin.rest.JobExecutionQuery; +import org.apache.gobblin.rest.JobStateEnum; +import org.apache.gobblin.rest.LauncherTypeEnum; +import org.apache.gobblin.rest.Metric; +import org.apache.gobblin.rest.MetricArray; +import org.apache.gobblin.rest.MetricTypeEnum; +import org.apache.gobblin.rest.QueryListType; +import org.apache.gobblin.rest.Table; +import org.apache.gobblin.rest.TableTypeEnum; +import org.apache.gobblin.rest.TaskExecutionInfo; +import org.apache.gobblin.rest.TaskExecutionInfoArray; +import org.apache.gobblin.rest.TaskStateEnum; +import org.apache.gobblin.rest.TimeRange; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV101.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV101.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV101.java index e24bc31..88e5cfa 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV101.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV101.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore.database; +package org.apache.gobblin.metastore.database; import javax.sql.DataSource; import java.io.IOException; @@ -51,21 +51,21 @@ import com.google.common.collect.Sets; import com.linkedin.data.template.GetMode; import com.linkedin.data.template.StringMap; -import gobblin.metastore.JobHistoryStore; -import gobblin.rest.JobExecutionInfo; -import gobblin.rest.JobExecutionQuery; -import gobblin.rest.JobStateEnum; -import gobblin.rest.LauncherTypeEnum; -import gobblin.rest.Metric; -import gobblin.rest.MetricArray; -import gobblin.rest.MetricTypeEnum; -import gobblin.rest.QueryListType; -import gobblin.rest.Table; -import gobblin.rest.TableTypeEnum; -import gobblin.rest.TaskExecutionInfo; -import gobblin.rest.TaskExecutionInfoArray; -import gobblin.rest.TaskStateEnum; -import gobblin.rest.TimeRange; +import org.apache.gobblin.metastore.JobHistoryStore; +import org.apache.gobblin.rest.JobExecutionInfo; +import org.apache.gobblin.rest.JobExecutionQuery; +import org.apache.gobblin.rest.JobStateEnum; +import org.apache.gobblin.rest.LauncherTypeEnum; +import org.apache.gobblin.rest.Metric; +import org.apache.gobblin.rest.MetricArray; +import org.apache.gobblin.rest.MetricTypeEnum; +import org.apache.gobblin.rest.QueryListType; +import org.apache.gobblin.rest.Table; +import org.apache.gobblin.rest.TableTypeEnum; +import org.apache.gobblin.rest.TaskExecutionInfo; +import org.apache.gobblin.rest.TaskExecutionInfoArray; +import org.apache.gobblin.rest.TaskStateEnum; +import org.apache.gobblin.rest.TimeRange; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV102.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV102.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV102.java index f59bf78..1c951b5 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV102.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV102.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.metastore.database; +package org.apache.gobblin.metastore.database; -import gobblin.metastore.JobHistoryStore; +import org.apache.gobblin.metastore.JobHistoryStore; import java.io.IOException; -import gobblin.rest.JobExecutionInfo; +import org.apache.gobblin.rest.JobExecutionInfo; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/Filter.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/Filter.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/Filter.java index 8a62b2e..3bfbfb5 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/Filter.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/Filter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore.database; +package org.apache.gobblin.metastore.database; import com.google.common.base.Preconditions; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/SupportedDatabaseVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/SupportedDatabaseVersion.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/SupportedDatabaseVersion.java index d6bc456..1fb7285 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/SupportedDatabaseVersion.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/SupportedDatabaseVersion.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore.database; +package org.apache.gobblin.metastore.database; import java.lang.annotation.Documented; import java.lang.annotation.ElementType; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/VersionedDatabaseJobHistoryStore.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/VersionedDatabaseJobHistoryStore.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/VersionedDatabaseJobHistoryStore.java index dd432d0..8651f8f 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/VersionedDatabaseJobHistoryStore.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/VersionedDatabaseJobHistoryStore.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.metastore.database; +package org.apache.gobblin.metastore.database; -import gobblin.metastore.JobHistoryStore; +import org.apache.gobblin.metastore.JobHistoryStore; import javax.sql.DataSource; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/nameParser/DatasetUrnStateStoreNameParser.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/nameParser/DatasetUrnStateStoreNameParser.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/nameParser/DatasetUrnStateStoreNameParser.java index f50ffe0..ace61af 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/nameParser/DatasetUrnStateStoreNameParser.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/nameParser/DatasetUrnStateStoreNameParser.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore.nameParser; +package org.apache.gobblin.metastore.nameParser; import java.io.IOException; import java.util.Collection; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/nameParser/GuidDatasetUrnStateStoreNameParser.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/nameParser/GuidDatasetUrnStateStoreNameParser.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/nameParser/GuidDatasetUrnStateStoreNameParser.java index f660c22..cbb35b4 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/nameParser/GuidDatasetUrnStateStoreNameParser.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/nameParser/GuidDatasetUrnStateStoreNameParser.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore.nameParser; +package org.apache.gobblin.metastore.nameParser; import java.io.IOException; import java.io.InputStream; @@ -34,7 +34,7 @@ import com.google.common.collect.HashBiMap; import com.google.common.collect.Maps; import com.google.common.io.LineReader; -import gobblin.util.guid.Guid; +import org.apache.gobblin.util.guid.Guid; import lombok.AllArgsConstructor; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/nameParser/SimpleDatasetUrnStateStoreNameParser.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/nameParser/SimpleDatasetUrnStateStoreNameParser.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/nameParser/SimpleDatasetUrnStateStoreNameParser.java index 967ecda..31fdfb3 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/nameParser/SimpleDatasetUrnStateStoreNameParser.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/nameParser/SimpleDatasetUrnStateStoreNameParser.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore.nameParser; +package org.apache.gobblin.metastore.nameParser; import java.io.IOException; import java.util.Collection; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/DatabaseJobHistoryStoreSchemaManager.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/DatabaseJobHistoryStoreSchemaManager.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/DatabaseJobHistoryStoreSchemaManager.java index 60ee54a..57f8027 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/DatabaseJobHistoryStoreSchemaManager.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/DatabaseJobHistoryStoreSchemaManager.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore.util; +package org.apache.gobblin.metastore.util; import java.io.Closeable; import java.io.IOException; @@ -36,7 +36,7 @@ import org.flywaydb.core.api.MigrationInfoService; import org.flywaydb.core.Flyway; import org.flywaydb.core.internal.info.MigrationInfoDumper; -import gobblin.metastore.DatabaseJobHistoryStore; +import org.apache.gobblin.metastore.DatabaseJobHistoryStore; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/MySqlJdbcUrl.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/MySqlJdbcUrl.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/MySqlJdbcUrl.java index e34e243..a1cbb99 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/MySqlJdbcUrl.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/MySqlJdbcUrl.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore.util; +package org.apache.gobblin.metastore.util; import org.apache.http.client.utils.URIBuilder; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/StateStoreCleaner.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/StateStoreCleaner.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/StateStoreCleaner.java index b3a9b74..5e125a5 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/StateStoreCleaner.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/StateStoreCleaner.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore.util; +package org.apache.gobblin.metastore.util; import java.io.Closeable; import java.io.FileInputStream; @@ -44,9 +44,9 @@ import com.google.common.collect.Lists; import com.google.common.io.Closer; import com.google.common.io.Files; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metastore.nameParser.GuidDatasetUrnStateStoreNameParser; -import gobblin.util.ExecutorsUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metastore.nameParser.GuidDatasetUrnStateStoreNameParser; +import org.apache.gobblin.util.ExecutorsUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/DatabaseJobHistoryStoreTest.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/DatabaseJobHistoryStoreTest.java b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/DatabaseJobHistoryStoreTest.java index 31f4312..7a48105 100644 --- a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/DatabaseJobHistoryStoreTest.java +++ b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/DatabaseJobHistoryStoreTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore; +package org.apache.gobblin.metastore; import java.io.IOException; import java.util.List; @@ -34,22 +34,22 @@ import com.google.inject.Injector; import com.linkedin.data.template.StringMap; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metastore.testing.ITestMetastoreDatabase; -import gobblin.metastore.testing.TestMetastoreDatabaseFactory; -import gobblin.rest.JobExecutionInfo; -import gobblin.rest.JobExecutionQuery; -import gobblin.rest.JobStateEnum; -import gobblin.rest.LauncherTypeEnum; -import gobblin.rest.Metric; -import gobblin.rest.MetricArray; -import gobblin.rest.MetricTypeEnum; -import gobblin.rest.QueryIdTypeEnum; -import gobblin.rest.Table; -import gobblin.rest.TableTypeEnum; -import gobblin.rest.TaskExecutionInfo; -import gobblin.rest.TaskExecutionInfoArray; -import gobblin.rest.TaskStateEnum; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metastore.testing.ITestMetastoreDatabase; +import org.apache.gobblin.metastore.testing.TestMetastoreDatabaseFactory; +import org.apache.gobblin.rest.JobExecutionInfo; +import org.apache.gobblin.rest.JobExecutionQuery; +import org.apache.gobblin.rest.JobStateEnum; +import org.apache.gobblin.rest.LauncherTypeEnum; +import org.apache.gobblin.rest.Metric; +import org.apache.gobblin.rest.MetricArray; +import org.apache.gobblin.rest.MetricTypeEnum; +import org.apache.gobblin.rest.QueryIdTypeEnum; +import org.apache.gobblin.rest.Table; +import org.apache.gobblin.rest.TableTypeEnum; +import org.apache.gobblin.rest.TaskExecutionInfo; +import org.apache.gobblin.rest.TaskExecutionInfoArray; +import org.apache.gobblin.rest.TaskStateEnum; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/DatabaseJobHistoryStoreV100Test.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/DatabaseJobHistoryStoreV100Test.java b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/DatabaseJobHistoryStoreV100Test.java index 83e6b95..afe3805 100644 --- a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/DatabaseJobHistoryStoreV100Test.java +++ b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/DatabaseJobHistoryStoreV100Test.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore; +package org.apache.gobblin.metastore; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/DatabaseJobHistoryStoreV101Test.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/DatabaseJobHistoryStoreV101Test.java b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/DatabaseJobHistoryStoreV101Test.java index e6efcb0..04fbf17 100644 --- a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/DatabaseJobHistoryStoreV101Test.java +++ b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/DatabaseJobHistoryStoreV101Test.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore; +package org.apache.gobblin.metastore; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/FsStateStoreTest.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/FsStateStoreTest.java b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/FsStateStoreTest.java index 72cd6f3..052f1d2 100644 --- a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/FsStateStoreTest.java +++ b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/FsStateStoreTest.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.metastore; +package org.apache.gobblin.metastore; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.util.ClassAliasResolver; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.util.ClassAliasResolver; import java.io.IOException; import java.net.URL; import java.util.List; @@ -36,7 +36,7 @@ import org.testng.annotations.Test; import com.google.common.collect.Lists; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/nameParser/GuidDatasetUrnStateStoreNameParserTest.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/nameParser/GuidDatasetUrnStateStoreNameParserTest.java b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/nameParser/GuidDatasetUrnStateStoreNameParserTest.java index e685f57..8ca4492 100644 --- a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/nameParser/GuidDatasetUrnStateStoreNameParserTest.java +++ b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/nameParser/GuidDatasetUrnStateStoreNameParserTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore.nameParser; +package org.apache.gobblin.metastore.nameParser; import java.io.IOException; @@ -29,7 +29,7 @@ import org.testng.annotations.Test; import com.google.common.collect.Lists; -import gobblin.util.guid.Guid; +import org.apache.gobblin.util.guid.Guid; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/ITestMetastoreDatabase.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/ITestMetastoreDatabase.java b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/ITestMetastoreDatabase.java index a2a4a6b..1ee3bf2 100644 --- a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/ITestMetastoreDatabase.java +++ b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/ITestMetastoreDatabase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore.testing; +package org.apache.gobblin.metastore.testing; import java.io.Closeable; import java.net.URISyntaxException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/TestMetadataDatabase.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/TestMetadataDatabase.java b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/TestMetadataDatabase.java index 63a05d4..d755e83 100644 --- a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/TestMetadataDatabase.java +++ b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/TestMetadataDatabase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore.testing; +package org.apache.gobblin.metastore.testing; import org.apache.commons.lang.StringUtils; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/TestMetastoreDatabaseFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/TestMetastoreDatabaseFactory.java b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/TestMetastoreDatabaseFactory.java index adb49c2..bf5295d 100644 --- a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/TestMetastoreDatabaseFactory.java +++ b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/TestMetastoreDatabaseFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore.testing; +package org.apache.gobblin.metastore.testing; import java.io.Closeable; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/TestMetastoreDatabaseServer.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/TestMetastoreDatabaseServer.java b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/TestMetastoreDatabaseServer.java index 170aa50..599d16f 100644 --- a/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/TestMetastoreDatabaseServer.java +++ b/gobblin-metastore/src/test/java/org/apache/gobblin/metastore/testing/TestMetastoreDatabaseServer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metastore.testing; +package org.apache.gobblin.metastore.testing; import java.io.Closeable; import java.io.IOException; @@ -41,10 +41,10 @@ import com.wix.mysql.EmbeddedMysql; import com.wix.mysql.config.MysqldConfig; import com.wix.mysql.distribution.Version; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metastore.MetaStoreModule; -import gobblin.metastore.util.DatabaseJobHistoryStoreSchemaManager; -import gobblin.metastore.util.MySqlJdbcUrl; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metastore.MetaStoreModule; +import org.apache.gobblin.metastore.util.DatabaseJobHistoryStoreSchemaManager; +import org.apache.gobblin.metastore.util.MySqlJdbcUrl; class TestMetastoreDatabaseServer implements Closeable { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/FlatGobblinMetric.avsc ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/FlatGobblinMetric.avsc b/gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/FlatGobblinMetric.avsc index fc129f8..f00a548 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/FlatGobblinMetric.avsc +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/FlatGobblinMetric.avsc @@ -4,7 +4,7 @@ { "type": "record", "name": "FlatGobblinMetric", - "namespace": "gobblin.metrics", + "namesapce" : "org.apache.gobblin.metrics", "fields" : [ { "name": "tags", http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/GobblinTrackingEvent.avsc ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/GobblinTrackingEvent.avsc b/gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/GobblinTrackingEvent.avsc index 3290404..844138a 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/GobblinTrackingEvent.avsc +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/GobblinTrackingEvent.avsc @@ -1,7 +1,7 @@ { "type": "record", "name": "GobblinTrackingEvent", - "namespace": "gobblin.metrics", + "namesapce" : "org.apache.gobblin.metrics", "fields": [ { "name": "timestamp", http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/MetricReport.avsc ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/MetricReport.avsc b/gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/MetricReport.avsc index 7ec96fb..04310b9 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/MetricReport.avsc +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/MetricReport.avsc @@ -4,7 +4,7 @@ { "type": "record", "name": "MetricReport", - "namespace": "gobblin.metrics", + "namesapce" : "org.apache.gobblin.metrics", "fields" : [ { "name": "tags", http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java index 6e41133..d6e8a70 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java @@ -3,7 +3,7 @@ * * DO NOT EDIT DIRECTLY */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import org.apache.avro.specific.SpecificData; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/GobblinTrackingEvent.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/GobblinTrackingEvent.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/GobblinTrackingEvent.java index c8acdf7..59c956c 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/GobblinTrackingEvent.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/GobblinTrackingEvent.java @@ -3,7 +3,7 @@ * * DO NOT EDIT DIRECTLY */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import org.apache.avro.specific.SpecificData; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/Metric.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/Metric.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/Metric.java index 84823b9..1160507 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/Metric.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/Metric.java @@ -3,7 +3,7 @@ * * DO NOT EDIT DIRECTLY */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import org.apache.avro.specific.SpecificData; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/MetricReport.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/MetricReport.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/MetricReport.java index ae16f2e..6cbf097 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/MetricReport.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/MetricReport.java @@ -3,7 +3,7 @@ * * DO NOT EDIT DIRECTLY */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import org.apache.avro.specific.SpecificData; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/filesystem/MetricsFileSystemInstrumentation.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/filesystem/MetricsFileSystemInstrumentation.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/filesystem/MetricsFileSystemInstrumentation.java index 8f157fb..1ba09a8 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/filesystem/MetricsFileSystemInstrumentation.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/filesystem/MetricsFileSystemInstrumentation.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.filesystem; +package org.apache.gobblin.filesystem; import java.io.Closeable; import java.io.FileNotFoundException; @@ -31,14 +31,14 @@ import com.google.common.annotations.VisibleForTesting; import com.google.common.collect.ImmutableList; import com.google.common.io.Closer; -import gobblin.broker.iface.ConfigView; -import gobblin.broker.iface.ScopeType; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.metrics.ContextAwareTimer; -import gobblin.metrics.MetricContext; -import gobblin.util.filesystem.FileSystemInstrumentation; -import gobblin.util.filesystem.FileSystemInstrumentationFactory; -import gobblin.util.filesystem.FileSystemKey; +import org.apache.gobblin.broker.iface.ConfigView; +import org.apache.gobblin.broker.iface.ScopeType; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.metrics.ContextAwareTimer; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.util.filesystem.FileSystemInstrumentation; +import org.apache.gobblin.util.filesystem.FileSystemInstrumentationFactory; +import org.apache.gobblin.util.filesystem.FileSystemKey; import org.apache.hadoop.fs.*; import org.apache.hadoop.fs.permission.FsPermission; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ConsoleEventReporterFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ConsoleEventReporterFactory.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ConsoleEventReporterFactory.java index 168e5ea..dfc7eed 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ConsoleEventReporterFactory.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ConsoleEventReporterFactory.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.io.IOException; import java.util.Properties; @@ -22,7 +22,7 @@ import java.util.Properties; import com.codahale.metrics.MetricRegistry; import com.codahale.metrics.ScheduledReporter; -import gobblin.metrics.reporter.OutputStreamEventReporter; +import org.apache.gobblin.metrics.reporter.OutputStreamEventReporter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ConsoleReporterFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ConsoleReporterFactory.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ConsoleReporterFactory.java index 43abef9..6a86d98 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ConsoleReporterFactory.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ConsoleReporterFactory.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.io.IOException; import java.util.Properties; -import gobblin.metrics.reporter.OutputStreamReporter; -import gobblin.metrics.reporter.ScheduledReporter; +import org.apache.gobblin.metrics.reporter.OutputStreamReporter; +import org.apache.gobblin.metrics.reporter.ScheduledReporter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareCounter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareCounter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareCounter.java index 8451563..bada80d 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareCounter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareCounter.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import com.codahale.metrics.Counter; -import gobblin.metrics.metric.InnerMetric; -import gobblin.metrics.metric.ProxyMetric; +import org.apache.gobblin.metrics.metric.InnerMetric; +import org.apache.gobblin.metrics.metric.ProxyMetric; import lombok.experimental.Delegate; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareGauge.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareGauge.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareGauge.java index 0aa7608..292a584 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareGauge.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareGauge.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import lombok.experimental.Delegate; import com.codahale.metrics.Gauge; -import gobblin.metrics.metric.InnerMetric; +import org.apache.gobblin.metrics.metric.InnerMetric; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareHistogram.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareHistogram.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareHistogram.java index eedeebf..94b3615 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareHistogram.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareHistogram.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import lombok.experimental.Delegate; import com.codahale.metrics.ExponentiallyDecayingReservoir; import com.codahale.metrics.Histogram; -import gobblin.metrics.metric.InnerMetric; +import org.apache.gobblin.metrics.metric.InnerMetric; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMeter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMeter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMeter.java index 8087707..13de0b6 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMeter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMeter.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import com.codahale.metrics.Meter; -import gobblin.metrics.metric.InnerMetric; +import org.apache.gobblin.metrics.metric.InnerMetric; import lombok.experimental.Delegate; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMetric.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMetric.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMetric.java index bb3fd20..8375737 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMetric.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMetric.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import com.codahale.metrics.Metric; -import gobblin.metrics.metric.ProxyMetric; +import org.apache.gobblin.metrics.metric.ProxyMetric; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMetricFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMetricFactory.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMetricFactory.java index 20e1ba4..d699b06 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMetricFactory.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMetricFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import com.codahale.metrics.Counter; import com.codahale.metrics.Histogram; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareTimer.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareTimer.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareTimer.java index 28a06e2..25c81dd 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareTimer.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareTimer.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import com.codahale.metrics.Timer; -import gobblin.metrics.metric.InnerMetric; +import org.apache.gobblin.metrics.metric.InnerMetric; import lombok.experimental.Delegate; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Counters.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Counters.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Counters.java index 1588c43..7d1737f 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Counters.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Counters.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.util.Arrays; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/CustomCodahaleReporterFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/CustomCodahaleReporterFactory.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/CustomCodahaleReporterFactory.java index e5c95b6..81dfd3c 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/CustomCodahaleReporterFactory.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/CustomCodahaleReporterFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.io.IOException; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/CustomReporterFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/CustomReporterFactory.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/CustomReporterFactory.java index ae6dbf9..55d0bec 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/CustomReporterFactory.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/CustomReporterFactory.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.io.IOException; import java.util.Properties; -import gobblin.metrics.reporter.ScheduledReporter; +import org.apache.gobblin.metrics.reporter.ScheduledReporter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerCounter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerCounter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerCounter.java index a613255..9e95888 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerCounter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerCounter.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.lang.ref.WeakReference; import com.codahale.metrics.Counter; import com.google.common.base.Optional; -import gobblin.metrics.metric.InnerMetric; +import org.apache.gobblin.metrics.metric.InnerMetric; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerGauge.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerGauge.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerGauge.java index eeff694..5c13915 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerGauge.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerGauge.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.lang.ref.WeakReference; import com.codahale.metrics.Gauge; -import gobblin.metrics.metric.InnerMetric; +import org.apache.gobblin.metrics.metric.InnerMetric; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerHistogram.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerHistogram.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerHistogram.java index feb5194..7fb5401 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerHistogram.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerHistogram.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.lang.ref.WeakReference; @@ -23,7 +23,7 @@ import com.codahale.metrics.ExponentiallyDecayingReservoir; import com.codahale.metrics.Histogram; import com.google.common.base.Optional; -import gobblin.metrics.metric.InnerMetric; +import org.apache.gobblin.metrics.metric.InnerMetric; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMeter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMeter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMeter.java index 3d07f61..5f4f89c 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMeter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMeter.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.lang.ref.WeakReference; import com.codahale.metrics.Meter; import com.google.common.base.Optional; -import gobblin.metrics.metric.InnerMetric; +import org.apache.gobblin.metrics.metric.InnerMetric; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMetricContext.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMetricContext.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMetricContext.java index 41f4300..ac7e7e3 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMetricContext.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMetricContext.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.io.Closeable; import java.io.IOException; @@ -50,10 +50,10 @@ import com.google.common.io.Closer; import lombok.Getter; -import gobblin.metrics.context.ContextWeakReference; -import gobblin.metrics.context.NameConflictException; -import gobblin.metrics.context.ReportableContext; -import gobblin.metrics.metric.InnerMetric; +import org.apache.gobblin.metrics.context.ContextWeakReference; +import org.apache.gobblin.metrics.context.NameConflictException; +import org.apache.gobblin.metrics.context.ReportableContext; +import org.apache.gobblin.metrics.metric.InnerMetric; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerTimer.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerTimer.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerTimer.java index b840039..db4fc0a 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerTimer.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerTimer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.lang.ref.WeakReference; import java.util.concurrent.TimeUnit; @@ -23,7 +23,7 @@ import java.util.concurrent.TimeUnit; import com.codahale.metrics.Timer; import com.google.common.base.Optional; -import gobblin.metrics.metric.InnerMetric; +import org.apache.gobblin.metrics.metric.InnerMetric; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Measurements.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Measurements.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Measurements.java index 5ffd4c2..fe0fb98 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Measurements.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Measurements.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricContext.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricContext.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricContext.java index b4b0313..7552876 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricContext.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricContext.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import lombok.Getter; @@ -59,11 +59,11 @@ import com.google.common.collect.Sets; import com.google.common.io.Closer; import com.google.common.util.concurrent.MoreExecutors; -import gobblin.metrics.context.NameConflictException; -import gobblin.metrics.context.ReportableContext; -import gobblin.metrics.notification.EventNotification; -import gobblin.metrics.notification.Notification; -import gobblin.util.ExecutorsUtils; +import org.apache.gobblin.metrics.context.NameConflictException; +import org.apache.gobblin.metrics.context.ReportableContext; +import org.apache.gobblin.metrics.notification.EventNotification; +import org.apache.gobblin.metrics.notification.Notification; +import org.apache.gobblin.util.ExecutorsUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricNames.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricNames.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricNames.java index fe58076..f2c58d3 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricNames.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricNames.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; /** * Contains names for all metrics generated in gobblin-core. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/RootMetricContext.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/RootMetricContext.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/RootMetricContext.java index d60305a..ac61943 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/RootMetricContext.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/RootMetricContext.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import lombok.Getter; import lombok.extern.slf4j.Slf4j; @@ -34,12 +34,12 @@ import com.google.common.collect.Lists; import com.google.common.collect.Sets; import com.google.common.util.concurrent.MoreExecutors; -import gobblin.metrics.context.ContextWeakReference; -import gobblin.metrics.context.NameConflictException; -import gobblin.metrics.notification.MetricContextCleanupNotification; -import gobblin.metrics.notification.NewMetricContextNotification; -import gobblin.metrics.reporter.ContextAwareReporter; -import gobblin.util.ExecutorsUtils; +import org.apache.gobblin.metrics.context.ContextWeakReference; +import org.apache.gobblin.metrics.context.NameConflictException; +import org.apache.gobblin.metrics.notification.MetricContextCleanupNotification; +import org.apache.gobblin.metrics.notification.NewMetricContextNotification; +import org.apache.gobblin.metrics.reporter.ContextAwareReporter; +import org.apache.gobblin.util.ExecutorsUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Tag.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Tag.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Tag.java index a092a7f..341408d 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Tag.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Tag.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.util.AbstractMap; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/TagBasedMetricFilter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/TagBasedMetricFilter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/TagBasedMetricFilter.java index 2438458..ddc08d1 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/TagBasedMetricFilter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/TagBasedMetricFilter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.util.Collection; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Taggable.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Taggable.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Taggable.java index 54a4bfe..5c0f7d7 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Taggable.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Taggable.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.util.Collection; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Tagged.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Tagged.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Tagged.java index fa8f10f..0296e16 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Tagged.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Tagged.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.util.Collection; import java.util.Collections; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/MetricContextFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/MetricContextFactory.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/MetricContextFactory.java index 6269698..4912915 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/MetricContextFactory.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/MetricContextFactory.java @@ -15,22 +15,22 @@ * limitations under the License. */ -package gobblin.metrics.broker; +package org.apache.gobblin.metrics.broker; import com.typesafe.config.ConfigValue; -import gobblin.broker.ResourceInstance; -import gobblin.broker.iface.ConfigView; -import gobblin.broker.iface.NoSuchScopeException; -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.MetricContext; -import gobblin.metrics.RootMetricContext; -import gobblin.metrics.Tag; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.broker.ResourceInstance; +import org.apache.gobblin.broker.iface.ConfigView; +import org.apache.gobblin.broker.iface.NoSuchScopeException; +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.MetricContext; +import org.apache.gobblin.metrics.RootMetricContext; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.util.ConfigUtils; import java.util.Collection; import java.util.Map; import java.util.UUID; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/MetricContextKey.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/MetricContextKey.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/MetricContextKey.java index 4dc12b9..70a8f22 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/MetricContextKey.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/MetricContextKey.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.metrics.broker; +package org.apache.gobblin.metrics.broker; -import gobblin.broker.iface.SharedResourceKey; +import org.apache.gobblin.broker.iface.SharedResourceKey; import lombok.Data; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/SubTaggedMetricContextKey.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/SubTaggedMetricContextKey.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/SubTaggedMetricContextKey.java index 035af28..cad2317 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/SubTaggedMetricContextKey.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/SubTaggedMetricContextKey.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.broker; +package org.apache.gobblin.metrics.broker; import com.google.common.collect.ImmutableMap; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/ContextWeakReference.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/ContextWeakReference.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/ContextWeakReference.java index 2df8c09..aa4be39 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/ContextWeakReference.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/ContextWeakReference.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.metrics.context; +package org.apache.gobblin.metrics.context; import lombok.Getter; import java.lang.ref.WeakReference; -import gobblin.metrics.InnerMetricContext; -import gobblin.metrics.MetricContext; -import gobblin.metrics.RootMetricContext; +import org.apache.gobblin.metrics.InnerMetricContext; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.RootMetricContext; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/NameConflictException.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/NameConflictException.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/NameConflictException.java index 671dd6c..2788a7e 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/NameConflictException.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/NameConflictException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.context; +package org.apache.gobblin.metrics.context; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/ReportableContext.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/ReportableContext.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/ReportableContext.java index 91f7904..3e58c9d 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/ReportableContext.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/ReportableContext.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.context; +package org.apache.gobblin.metrics.context; import java.util.List; import java.util.Map; @@ -30,8 +30,8 @@ import com.codahale.metrics.MetricFilter; import com.codahale.metrics.Timer; import com.google.common.base.Optional; -import gobblin.metrics.MetricContext; -import gobblin.metrics.Tag; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.Tag; /** * Interface for a context that can be reported (e.g. {@link gobblin.metrics.InnerMetricContext}, http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/AllContextFilter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/AllContextFilter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/AllContextFilter.java index 634c633..e6a982a 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/AllContextFilter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/AllContextFilter.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.metrics.context.filter; +package org.apache.gobblin.metrics.context.filter; import java.util.Set; import com.google.common.collect.ImmutableSet; -import gobblin.metrics.InnerMetricContext; -import gobblin.metrics.MetricContext; -import gobblin.metrics.RootMetricContext; +import org.apache.gobblin.metrics.InnerMetricContext; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.RootMetricContext; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/ContextFilter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/ContextFilter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/ContextFilter.java index 1839eb3..b85ac87 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/ContextFilter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/ContextFilter.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.metrics.context.filter; +package org.apache.gobblin.metrics.context.filter; import java.util.Set; -import gobblin.metrics.InnerMetricContext; -import gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.InnerMetricContext; +import org.apache.gobblin.metrics.MetricContext; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/ContextFilterFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/ContextFilterFactory.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/ContextFilterFactory.java index 7a5f2b4..ef31d17 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/ContextFilterFactory.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/ContextFilterFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.context.filter; +package org.apache.gobblin.metrics.context.filter; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/EventName.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/EventName.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/EventName.java index 679da12..ff2e9c7 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/EventName.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/EventName.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.event; +package org.apache.gobblin.metrics.event; import java.util.HashMap; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/EventSubmitter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/EventSubmitter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/EventSubmitter.java index e9306fb..c8f4aa5 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/EventSubmitter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/EventSubmitter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.event; +package org.apache.gobblin.metrics.event; import java.util.Map; @@ -23,8 +23,8 @@ import com.google.common.base.Optional; import com.google.common.collect.ImmutableMap; import com.google.common.collect.Maps; -import gobblin.metrics.GobblinTrackingEvent; -import gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.GobblinTrackingEvent; +import org.apache.gobblin.metrics.MetricContext; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/JobEvent.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/JobEvent.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/JobEvent.java index de21e78..d9310fb 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/JobEvent.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/JobEvent.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.metrics.event; +package org.apache.gobblin.metrics.event; -import gobblin.metrics.GobblinTrackingEvent; +import org.apache.gobblin.metrics.GobblinTrackingEvent; /** * Job-related event types and their metadata, stored in {@link GobblinTrackingEvent#metadata}