ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [32/50] incubator-ignite git commit: # ignite-330 Fixed javadoc.
Date Mon, 23 Mar 2015 11:23:37 GMT
# ignite-330 Fixed javadoc.


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d7880d07
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d7880d07
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d7880d07

Branch: refs/heads/ignite-497-stick
Commit: d7880d07df06164c41eced75db9f86d79254441d
Parents: 3a65ec3
Author: anovikov <anovikov@gridgain.com>
Authored: Mon Mar 23 13:48:37 2015 +0700
Committer: anovikov <anovikov@gridgain.com>
Committed: Mon Mar 23 13:48:37 2015 +0700

----------------------------------------------------------------------
 .../cache/store/jdbc/CacheAbstractJdbcStore.java | 19 ++++++++++++-------
 .../cache/store/jdbc/CacheJdbcPojoStore.java     |  2 ++
 2 files changed, 14 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d7880d07/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
index 7ae6d85..0e76206 100644
--- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
+++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
@@ -60,7 +60,7 @@ import static java.sql.Statement.*;
  *     <li>Data source (see {@link #setDataSource(DataSource)}</li>
  *     <li>Dialect (see {@link #setDialect(JdbcDialect)}</li>
  *     <li>Maximum batch size for writeAll and deleteAll operations. (see {@link #setBatchSize(int)})</li>
- *     <li>Max workers thread count. These threads are responsible for load cache.
(see {@link #setMaxPoolSize(int)})</li>
+ *     <li>Max workers thread count. These threads are responsible for load cache.
(see {@link #setMaximumPoolSize(int)})</li>
  *     <li>Parallel load cache minimum threshold. (see {@link #setParallelLoadCacheMinimumThreshold(int)})</li>
  * </ul>
  * <h2 class="header">Java Example</h2>
@@ -155,6 +155,7 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K,
V>,
      * @param loadColIdxs Select query columns index.
      * @param rs ResultSet.
      * @return Constructed object.
+     * @throws CacheLoaderException If failed to construct cache object.
      */
     protected abstract <R> R buildObject(@Nullable String cacheName, String typeName,
         Collection<CacheTypeFieldMetadata> fields, Map<String, Integer> loadColIdxs,
ResultSet rs)
@@ -165,6 +166,7 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K,
V>,
      *
      * @param key Key object.
      * @return Key type id.
+     * @throws CacheException If failed to get type key id from object.
      */
     protected abstract Object keyTypeId(Object key) throws CacheException;
 
@@ -173,6 +175,7 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K,
V>,
      *
      * @param type String description of key type.
      * @return Key type id.
+     * @throws CacheException If failed to get type key id from object.
      */
     protected abstract Object keyTypeId(String type) throws CacheException;
 
@@ -180,7 +183,7 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K,
V>,
      * Prepare internal store specific builders for provided types metadata.
      *
      * @param types Collection of types.
-     * @throws CacheException If failed to prepare.
+     * @throws CacheException If failed to prepare internal builders for types.
      */
     protected abstract void prepareBuilders(@Nullable String cacheName, Collection<CacheTypeMetadata>
types)
         throws CacheException;
@@ -501,7 +504,7 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K,
V>,
     /**
      * @param clsName Class name.
      * @param fields Fields descriptors.
-     * @throws CacheException If failed.
+     * @throws CacheException If failed to check type metadata.
      */
     private static void checkMapping(@Nullable String cacheName, String clsName,
         Collection<CacheTypeFieldMetadata> fields) throws CacheException {
@@ -543,7 +546,7 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K,
V>,
 
     /**
      * @return Type mappings for specified cache name.
-     * @throws CacheException If failed to initialize.
+     * @throws CacheException If failed to initialize cache mappings.
      */
     private Map<Object, EntryMapping> cacheMappings(@Nullable String cacheName) throws
CacheException {
         Map<Object, EntryMapping> entryMappings = cacheMappings.get(cacheName);
@@ -598,7 +601,7 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K,
V>,
      * @param keyTypeId Key type id.
      * @param key Key object.
      * @return Entry mapping.
-     * @throws CacheException if mapping for key was not found.
+     * @throws CacheException If mapping for key was not found.
      */
     private EntryMapping entryMapping(String cacheName, Object keyTypeId, Object key) throws
CacheException {
         EntryMapping em = cacheMappings(cacheName).get(keyTypeId);
@@ -787,6 +790,7 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K,
V>,
      * @param updStmt Update statement.
      * @param em Entry mapping.
      * @param entry Cache entry.
+     * @throws CacheWriterException If failed to update record in database.
      */
     private void writeUpsert(PreparedStatement insStmt, PreparedStatement updStmt,
         EntryMapping em, Cache.Entry<? extends K, ? extends V> entry) throws CacheWriterException
{
@@ -1074,6 +1078,7 @@ public abstract class CacheAbstractJdbcStore<K, V> implements
CacheStore<K, V>,
      * @param fromIdx Objects in batch start from index.
      * @param prepared Expected objects in batch.
      * @param lazyObjs All objects used in batch statement as array.
+     * @throws SQLException If failed to execute batch statement.
      */
     private void executeBatch(EntryMapping em, Statement stmt, String desc, int fromIdx,
int prepared,
         LazyValue<Object[]> lazyObjs) throws SQLException {
@@ -1306,7 +1311,7 @@ public abstract class CacheAbstractJdbcStore<K, V> implements
CacheStore<K, V>,
      *
      * @return Max workers thread count.
      */
-    public int getMaxPoolSize() {
+    public int getMaximumPoolSize() {
         return maxPoolSz;
     }
 
@@ -1315,7 +1320,7 @@ public abstract class CacheAbstractJdbcStore<K, V> implements
CacheStore<K, V>,
      *
      * @param maxPoolSz Max workers thread count.
      */
-    public void setMaxPoolSize(int maxPoolSz) {
+    public void setMaximumPoolSize(int maxPoolSz) {
         this.maxPoolSz = maxPoolSz;
     }
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d7880d07/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStore.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStore.java
b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStore.java
index 4bd337b..682f018 100644
--- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStore.java
+++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStore.java
@@ -62,6 +62,8 @@ public class CacheJdbcPojoStore<K, V> extends CacheAbstractJdbcStore<K,
V> {
          *
          * @param clsName Class name.
          * @param fields Fields.
+         *
+         * @throws CacheException If failed to construct type cache.
          */
         public PojoMethodsCache(String clsName, Collection<CacheTypeFieldMetadata>
fields) throws CacheException {
             try {


Mime
View raw message