+ * http://www.apache.org/licenses/LICENSE-2.0 + *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.hadoop.ozone.recon.codegen;
+
+import java.io.File;
+import java.sql.SQLException;
+import java.util.Set;
+
+import javax.sql.DataSource;
+
+import org.apache.commons.io.FileUtils;
+import org.hadoop.ozone.recon.schema.ReconSchemaDefinition;
+import org.jooq.codegen.GenerationTool;
+import org.jooq.meta.jaxb.Configuration;
+import org.jooq.meta.jaxb.Database;
+import org.jooq.meta.jaxb.Generate;
+import org.jooq.meta.jaxb.Generator;
+import org.jooq.meta.jaxb.Jdbc;
+import org.jooq.meta.jaxb.Strategy;
+import org.jooq.meta.jaxb.Target;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.sqlite.SQLiteDataSource;
+
+import com.google.inject.AbstractModule;
+import com.google.inject.Guice;
+import com.google.inject.Inject;
+import com.google.inject.Injector;
+import com.google.inject.Provider;
+
+/**
+ * Utility class that generates the Dao and Pojos for Recon schema. The
+ * implementations of {@link ReconSchemaDefinition} are discovered through
+ * Guice bindings in order to avoid ugly reflection code, and invoked to
+ * generate the schema over an embedded database. The jooq code generator then
+ * runs over the embedded database to generate classes for recon.
+ */
+public class JooqCodeGenerator {
+
+ private static final Logger LOG =
+ LoggerFactory.getLogger(JooqCodeGenerator.class);
+
+ private static final String SQLITE_DB =
+ System.getProperty("java.io.tmpdir") + "/recon-generated-schema";
+ private static final String JDBC_URL = "jdbc:sqlite:" + SQLITE_DB;
+
+ private final Set
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.hadoop.ozone.recon.codegen;
+
+import org.hadoop.ozone.recon.schema.ReconSchemaDefinition;
+import org.hadoop.ozone.recon.schema.UtilizationSchemaDefinition;
+
+import com.google.inject.AbstractModule;
+import com.google.inject.multibindings.Multibinder;
+
+/**
+ * Bindings for DDL generation and used by
+ * {@link org.hadoop.ozone.recon.codegen.JooqCodeGenerator}.
+ */
+public class ReconSchemaGenerationModule extends AbstractModule {
+ @Override
+ protected void configure() {
+ // SQL schema creation and related bindings
+ Multibinder
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.hadoop.ozone.recon.codegen;
+
+import org.jooq.codegen.DefaultGeneratorStrategy;
+import org.jooq.meta.Definition;
+import org.jooq.meta.TableDefinition;
+import org.jooq.tools.StringUtils;
+
+/**
+ * Generate Table classes with a different name from POJOS to improve
+ * readability, loaded at runtime.
+ */
+public class TableNamingStrategy extends DefaultGeneratorStrategy {
+ @Override
+ public String getJavaClassName(Definition definition, Mode mode) {
+ if (definition instanceof TableDefinition && mode == Mode.DEFAULT) {
+ StringBuilder result = new StringBuilder();
+
+ result.append(StringUtils.toCamelCase(
+ definition.getOutputName()
+ .replace(' ', '_')
+ .replace('-', '_')
+ .replace('.', '_')
+ ));
+
+ result.append("Table");
+ return result.toString();
+ } else {
+ return super.getJavaClassName(definition, mode);
+ }
+ }
+}
diff --git a/hadoop-ozone/ozone-recon-codegen/src/main/java/org/hadoop/ozone/recon/codegen/package-info.java b/hadoop-ozone/ozone-recon-codegen/src/main/java/org/hadoop/ozone/recon/codegen/package-info.java
new file mode 100644
index 0000000000..2e5cf0f5af
--- /dev/null
+++ b/hadoop-ozone/ozone-recon-codegen/src/main/java/org/hadoop/ozone/recon/codegen/package-info.java
@@ -0,0 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Recon code generation support for entities and daos.
+ */
+package org.hadoop.ozone.recon.codegen;
\ No newline at end of file
diff --git a/hadoop-ozone/ozone-recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/ReconSchemaDefinition.java b/hadoop-ozone/ozone-recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/ReconSchemaDefinition.java
new file mode 100644
index 0000000000..72a105e5ff
--- /dev/null
+++ b/hadoop-ozone/ozone-recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/ReconSchemaDefinition.java
@@ -0,0 +1,34 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.hadoop.ozone.recon.schema;
+
+import java.sql.SQLException;
+
+/**
+ * Classes meant to initialize the SQL schema for Recon. The implementations of
+ * this class will be used to create the SQL schema programmatically.
+ * Note: Make sure add a binding for your implementation to the Guice module,
+ * otherwise code-generator will not pick up the schema changes.
+ */
+public interface ReconSchemaDefinition {
+
+ /**
+ * Execute DDL that will create Recon schema.
+ */
+ void initializeSchema() throws SQLException;
+}
diff --git a/hadoop-ozone/ozone-recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/UtilizationSchemaDefinition.java b/hadoop-ozone/ozone-recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/UtilizationSchemaDefinition.java
new file mode 100644
index 0000000000..977a3b3526
--- /dev/null
+++ b/hadoop-ozone/ozone-recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/UtilizationSchemaDefinition.java
@@ -0,0 +1,69 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.hadoop.ozone.recon.schema;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+
+import javax.sql.DataSource;
+
+import org.jooq.impl.DSL;
+import org.jooq.impl.SQLDataType;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.google.inject.Inject;
+
+/**
+ * Programmatic definition of Recon DDL.
+ */
+public class UtilizationSchemaDefinition implements ReconSchemaDefinition {
+
+ private final DataSource dataSource;
+
+ public static final String CLUSTER_GROWTH_DAILY_TABLE_NAME =
+ "cluster_growth_daily";
+
+ @Inject
+ UtilizationSchemaDefinition(DataSource dataSource) {
+ this.dataSource = dataSource;
+ }
+
+ @Override
+ @Transactional
+ public void initializeSchema() throws SQLException {
+ Connection conn = dataSource.getConnection();
+ createClusterGrowthTable(conn);
+ }
+
+ void createClusterGrowthTable(Connection conn) {
+ DSL.using(conn).createTableIfNotExists(CLUSTER_GROWTH_DAILY_TABLE_NAME)
+ .column("timestamp", SQLDataType.TIMESTAMP)
+ .column("datanode_id", SQLDataType.INTEGER)
+ .column("datanode_host", SQLDataType.VARCHAR(1024))
+ .column("rack_id", SQLDataType.VARCHAR(1024))
+ .column("available_size", SQLDataType.BIGINT)
+ .column("used_size", SQLDataType.BIGINT)
+ .column("container_count", SQLDataType.INTEGER)
+ .column("block_count", SQLDataType.INTEGER)
+ .constraint(DSL.constraint("pk_timestamp_datanode_id")
+ .primaryKey("timestamp", "datanode_id"))
+ .execute();
+ }
+
+
+}
diff --git a/hadoop-ozone/ozone-recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/package-info.java b/hadoop-ozone/ozone-recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/package-info.java
new file mode 100644
index 0000000000..3c701f989d
--- /dev/null
+++ b/hadoop-ozone/ozone-recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/package-info.java
@@ -0,0 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Classes in this package define the schema for Recon Sql database.
+ */
+package org.hadoop.ozone.recon.schema;
\ No newline at end of file
diff --git a/hadoop-ozone/ozone-recon/dev-support/findbugsExcludeFile.xml b/hadoop-ozone/ozone-recon/dev-support/findbugsExcludeFile.xml
new file mode 100644
index 0000000000..7c0ba4dd4e
--- /dev/null
+++ b/hadoop-ozone/ozone-recon/dev-support/findbugsExcludeFile.xml
@@ -0,0 +1,28 @@
+
+
+
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Common configuration needed to instantiate {@link javax.sql.DataSource}.
+ */
+public interface DataSourceConfiguration {
+ /**
+ * Get database driver class name available on the classpath.
+ */
+ String getDriverClass();
+
+ /**
+ * Get Jdbc Url for the database server.
+ */
+ String getJdbcUrl();
+
+ /**
+ * Get username for the db.
+ */
+ String getUserName();
+
+ /**
+ * Get password for the db.
+ */
+ String getPassword();
+
+ /**
+ * Should autocommit be turned on for the datasource.
+ */
+ boolean setAutoCommit();
+
+ /**
+ * Sets the maximum time (in milliseconds) to wait before a call to
+ * getConnection is timed out.
+ */
+ long getConnectionTimeout();
+
+ /**
+ * Get a string representation of {@link org.jooq.SQLDialect}.
+ */
+ String getSqlDialect();
+
+ /**
+ * In a production database this should be set to something like 10.
+ * SQLite does not allow multiple connections, hence this defaults to 1.
+ */
+ Integer getMaxActiveConnections();
+
+ /**
+ * Sets the maximum connection age (in seconds).
+ */
+ Integer getMaxConnectionAge();
+
+ /**
+ * Sets the maximum idle connection age (in seconds).
+ */
+ Integer getMaxIdleConnectionAge();
+
+ /**
+ * Statement specific to database, usually SELECT 1.
+ */
+ String getConnectionTestStatement();
+
+ /**
+ * How often to test idle connections for being active (in seconds).
+ */
+ Integer getIdleConnectionTestPeriod();
+}
diff --git a/hadoop-ozone/ozone-recon/src/main/java/org/apache/hadoop/ozone/recon/persistence/DefaultDataSourceProvider.java b/hadoop-ozone/ozone-recon/src/main/java/org/apache/hadoop/ozone/recon/persistence/DefaultDataSourceProvider.java
new file mode 100644
index 0000000000..7b28d00488
--- /dev/null
+++ b/hadoop-ozone/ozone-recon/src/main/java/org/apache/hadoop/ozone/recon/persistence/DefaultDataSourceProvider.java
@@ -0,0 +1,74 @@
+package org.apache.hadoop.ozone.recon.persistence;
+
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import javax.sql.DataSource;
+
+import org.apache.commons.lang3.StringUtils;
+import org.sqlite.SQLiteDataSource;
+
+import com.google.inject.Inject;
+import com.google.inject.Provider;
+import com.jolbox.bonecp.BoneCPDataSource;
+
+/**
+ * Provide a {@link javax.sql.DataSource} for the application.
+ */
+public class DefaultDataSourceProvider implements Provider
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hadoop.ozone.recon.persistence;
+
+import static com.google.inject.matcher.Matchers.annotatedWith;
+import static com.google.inject.matcher.Matchers.any;
+
+import java.sql.Connection;
+import javax.sql.DataSource;
+
+import org.jooq.Configuration;
+import org.jooq.ConnectionProvider;
+import org.jooq.SQLDialect;
+import org.jooq.impl.DefaultConfiguration;
+import org.springframework.dao.DataAccessException;
+import org.springframework.jdbc.datasource.DataSourceTransactionManager;
+import org.springframework.jdbc.datasource.DataSourceUtils;
+import org.springframework.jdbc.datasource.TransactionAwareDataSourceProxy;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.google.inject.AbstractModule;
+import com.google.inject.Provider;
+import com.google.inject.Provides;
+import com.google.inject.Singleton;
+
+/**
+ * Persistence module that provides binding for {@link DataSource} and
+ * a MethodInterceptor for nested transactions support.
+ */
+public class JooqPersistenceModule extends AbstractModule {
+
+ private Provider
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hadoop.ozone.recon.persistence;
+
+import org.aopalliance.intercept.MethodInterceptor;
+import org.aopalliance.intercept.MethodInvocation;
+import org.springframework.jdbc.datasource.DataSourceTransactionManager;
+import org.springframework.transaction.TransactionStatus;
+import org.springframework.transaction.UnexpectedRollbackException;
+import org.springframework.transaction.support.DefaultTransactionDefinition;
+
+import com.google.inject.Provider;
+
+/**
+ * A {@link MethodInterceptor} that implements nested transactions.
+ *
+ * Only the outermost transactional method will
+ */
+public class TransactionalMethodInterceptor implements MethodInterceptor {
+
+ private Provider
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * This package defines the persistence interfaces for Recon SQL DB.
+ */
+package org.apache.hadoop.ozone.recon.persistence;
\ No newline at end of file
diff --git a/hadoop-ozone/ozone-recon/src/test/java/org/apache/hadoop/ozone/recon/persistence/AbstractSqlDatabaseTest.java b/hadoop-ozone/ozone-recon/src/test/java/org/apache/hadoop/ozone/recon/persistence/AbstractSqlDatabaseTest.java
new file mode 100644
index 0000000000..2fab93219e
--- /dev/null
+++ b/hadoop-ozone/ozone-recon/src/test/java/org/apache/hadoop/ozone/recon/persistence/AbstractSqlDatabaseTest.java
@@ -0,0 +1,146 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hadoop.ozone.recon.persistence;
+
+import java.io.File;
+import java.io.IOException;
+
+import javax.sql.DataSource;
+
+import org.jooq.DSLContext;
+import org.jooq.SQLDialect;
+import org.jooq.impl.DSL;
+import org.jooq.impl.DefaultConfiguration;
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.ClassRule;
+import org.junit.rules.TemporaryFolder;
+
+import com.google.inject.Guice;
+import com.google.inject.Injector;
+import com.google.inject.Provider;
+
+/**
+ * Create an injector for tests that need to access the SQl database.
+ */
+public abstract class AbstractSqlDatabaseTest {
+
+ @ClassRule
+ public static TemporaryFolder temporaryFolder = new TemporaryFolder();
+ private static File tempDir;
+
+ private static Injector injector;
+ private static DSLContext dslContext;
+
+ @BeforeClass
+ public static void setup() throws IOException {
+ tempDir = temporaryFolder.newFolder();
+
+ DataSourceConfigurationProvider configurationProvider =
+ new DataSourceConfigurationProvider();
+ JooqPersistenceModule persistenceModule =
+ new JooqPersistenceModule(configurationProvider);
+
+ injector = Guice.createInjector(persistenceModule);
+ dslContext = DSL.using(new DefaultConfiguration().set(
+ injector.getInstance(DataSource.class)));
+ }
+
+ @AfterClass
+ public static void tearDown() {
+ temporaryFolder.delete();
+ }
+
+ protected Injector getInjector() {
+ return injector;
+ }
+
+ protected DSLContext getDslContext() {
+ return dslContext;
+ }
+
+ static class DataSourceConfigurationProvider implements
+ Provider
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hadoop.ozone.recon.persistence;
+
+import static org.hadoop.ozone.recon.schema.UtilizationSchemaDefinition.CLUSTER_GROWTH_DAILY_TABLE_NAME;
+import static org.hadoop.ozone.recon.schema.tables.ClusterGrowthDailyTable.CLUSTER_GROWTH_DAILY;
+
+import java.sql.Connection;
+import java.sql.DatabaseMetaData;
+import java.sql.ResultSet;
+import java.sql.Timestamp;
+import java.sql.Types;
+import java.util.ArrayList;
+import java.util.List;
+
+import javax.sql.DataSource;
+
+import org.apache.commons.lang3.tuple.ImmutablePair;
+import org.apache.commons.lang3.tuple.Pair;
+import org.hadoop.ozone.recon.schema.UtilizationSchemaDefinition;
+import org.hadoop.ozone.recon.schema.tables.daos.ClusterGrowthDailyDao;
+import org.hadoop.ozone.recon.schema.tables.pojos.ClusterGrowthDaily;
+import org.jooq.Configuration;
+import org.junit.Assert;
+import org.junit.Test;
+
+/**
+ * Test persistence module provides connection and transaction awareness.
+ */
+public class TestUtilizationSchemaDefinition extends AbstractSqlDatabaseTest {
+
+ @Test
+ public void testReconSchemaCreated() throws Exception {
+ UtilizationSchemaDefinition schemaDefinition = getInjector().getInstance(
+ UtilizationSchemaDefinition.class);
+
+ schemaDefinition.initializeSchema();
+
+ Connection connection =
+ getInjector().getInstance(DataSource.class).getConnection();
+ // Verify table definition
+ DatabaseMetaData metaData = connection.getMetaData();
+ ResultSet resultSet = metaData.getColumns(null, null,
+ CLUSTER_GROWTH_DAILY_TABLE_NAME, null);
+
+ List
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * End to end tests for persistence classes.
+ */
+package org.apache.hadoop.ozone.recon.persistence;
\ No newline at end of file
diff --git a/hadoop-ozone/pom.xml b/hadoop-ozone/pom.xml
index 11498944aa..7010878f62 100644
--- a/hadoop-ozone/pom.xml
+++ b/hadoop-ozone/pom.xml
@@ -49,6 +49,7 @@
commit() or
+ * rollback() the contextual transaction. This can be verified
+ * through {@link TransactionStatus#isNewTransaction()}, which returns
+ * true only for the outermost transactional method call.
+ *