fluo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ktur...@apache.org
Subject [09/10] incubator-fluo-recipes git commit: Added '@since 1.0.0' annotations
Date Fri, 15 Jul 2016 22:07:57 GMT
Added '@since 1.0.0' annotations

* Also made minor whitespace changes


Project: http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/commit/083e4afb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/tree/083e4afb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/diff/083e4afb

Branch: refs/heads/master
Commit: 083e4afb1d6528c6cb8443ef24565f11187299a6
Parents: 594997a
Author: Mike Walch <mwalch@gmail.com>
Authored: Fri Jul 15 12:26:07 2016 -0400
Committer: Mike Walch <mwalch@gmail.com>
Committed: Fri Jul 15 12:38:05 2016 -0400

----------------------------------------------------------------------
 .../apache/fluo/recipes/accumulo/cmds/CompactTransient.java | 9 +++------
 .../apache/fluo/recipes/accumulo/cmds/OptimizeTable.java    | 4 +++-
 .../apache/fluo/recipes/accumulo/export/AccumuloExport.java | 1 +
 .../fluo/recipes/accumulo/export/AccumuloExporter.java      | 1 +
 .../fluo/recipes/accumulo/export/DifferenceExport.java      | 1 +
 .../fluo/recipes/accumulo/export/ReplicationExport.java     | 1 +
 .../org/apache/fluo/recipes/accumulo/export/TableInfo.java  | 3 +++
 .../apache/fluo/recipes/accumulo/ops/TableOperations.java   | 3 ++-
 .../java/org/apache/fluo/recipes/core/common/Pirtos.java    | 3 ++-
 .../java/org/apache/fluo/recipes/core/common/RowRange.java  | 3 +++
 .../apache/fluo/recipes/core/common/TransientRegistry.java  | 3 ++-
 .../java/org/apache/fluo/recipes/core/data/RowHasher.java   | 2 ++
 .../java/org/apache/fluo/recipes/core/export/Export.java    | 3 +++
 .../org/apache/fluo/recipes/core/export/ExportObserver.java | 3 +++
 .../org/apache/fluo/recipes/core/export/ExportQueue.java    | 3 +++
 .../java/org/apache/fluo/recipes/core/export/Exporter.java  | 3 +++
 .../apache/fluo/recipes/core/export/SequencedExport.java    | 3 +++
 .../org/apache/fluo/recipes/core/map/CollisionFreeMap.java  | 4 ++--
 .../fluo/recipes/core/map/CollisionFreeMapObserver.java     | 3 ++-
 .../java/org/apache/fluo/recipes/core/map/Combiner.java     | 5 ++++-
 .../main/java/org/apache/fluo/recipes/core/map/Update.java  | 3 +++
 .../org/apache/fluo/recipes/core/map/UpdateObserver.java    | 3 ++-
 .../fluo/recipes/core/serialization/SimpleSerializer.java   | 3 +++
 .../org/apache/fluo/recipes/core/transaction/LogEntry.java  | 2 ++
 .../fluo/recipes/core/transaction/RecordingTransaction.java | 2 ++
 .../recipes/core/transaction/RecordingTransactionBase.java  | 2 ++
 .../org/apache/fluo/recipes/core/transaction/TxLog.java     | 2 ++
 .../org/apache/fluo/recipes/kryo/KryoSimplerSerializer.java | 3 +++
 .../apache/fluo/recipes/spark/AccumuloRangePartitioner.java | 3 +++
 .../java/org/apache/fluo/recipes/spark/FluoSparkHelper.java | 2 ++
 .../org/apache/fluo/recipes/spark/FluoSparkTestUtil.java    | 2 ++
 .../org/apache/fluo/recipes/test/AccumuloExportITBase.java  | 2 ++
 .../java/org/apache/fluo/recipes/test/FluoITHelper.java     | 2 ++
 33 files changed, 77 insertions(+), 15 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/cmds/CompactTransient.java
----------------------------------------------------------------------
diff --git a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/cmds/CompactTransient.java
b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/cmds/CompactTransient.java
index 54e05bc..3ec97c2 100644
--- a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/cmds/CompactTransient.java
+++ b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/cmds/CompactTransient.java
@@ -32,13 +32,15 @@ import org.apache.fluo.recipes.core.common.TransientRegistry;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+/**
+ * @since 1.0.0
+ */
 public class CompactTransient {
 
   // when run with fluo exec command, the applications fluo config will be injected
   @Inject
   private static FluoConfiguration fluoConfig;
 
-
   private static ScheduledExecutorService schedExecutor;
 
   private static Logger log = LoggerFactory.getLogger(CompactTransient.class);
@@ -77,12 +79,7 @@ public class CompactTransient {
       } else {
         log.info("Compacted {} in {}ms", transientRange, t2 - t1);
       }
-
-
     }
-
-
-
   }
 
   public static void main(String[] args) throws Exception {

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/cmds/OptimizeTable.java
----------------------------------------------------------------------
diff --git a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/cmds/OptimizeTable.java
b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/cmds/OptimizeTable.java
index bf17cfd..2a56cfb 100644
--- a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/cmds/OptimizeTable.java
+++ b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/cmds/OptimizeTable.java
@@ -21,6 +21,9 @@ import org.apache.fluo.api.config.FluoConfiguration;
 import org.apache.fluo.recipes.accumulo.ops.TableOperations;
 import org.apache.fluo.recipes.core.common.Pirtos;
 
+/**
+ * @since 1.0.0
+ */
 public class OptimizeTable {
 
   // when run with fluo exec command, the applications fluo config will be injected
@@ -33,7 +36,6 @@ public class OptimizeTable {
       System.exit(-1);
     }
 
-
     TableOperations.optimizeTable(fluoConfig, Pirtos.getConfiguredOptimizations(fluoConfig));
     System.out.println("Finished optimizing table");
   }

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/AccumuloExport.java
----------------------------------------------------------------------
diff --git a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/AccumuloExport.java
b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/AccumuloExport.java
index f6d7a51..9b31b7c 100644
--- a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/AccumuloExport.java
+++ b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/AccumuloExport.java
@@ -23,6 +23,7 @@ import org.apache.accumulo.core.data.Mutation;
  * Implemented by users to export data to Accumulo.
  * 
  * @param <K> Export queue key type
+ * @since 1.0.0
  */
 public interface AccumuloExport<K> {
 

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/AccumuloExporter.java
----------------------------------------------------------------------
diff --git a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/AccumuloExporter.java
b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/AccumuloExporter.java
index 1788403..7e48d12 100644
--- a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/AccumuloExporter.java
+++ b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/AccumuloExporter.java
@@ -29,6 +29,7 @@ import org.apache.fluo.recipes.core.export.SequencedExport;
  * An {@link Exporter} that takes {@link AccumuloExport} objects and writes mutations to
Accumulo
  *
  * @param <K> Export queue key type
+ * @since 1.0.0
  */
 public class AccumuloExporter<K> extends Exporter<K, AccumuloExport<K>>
{
 

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/DifferenceExport.java
----------------------------------------------------------------------
diff --git a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/DifferenceExport.java
b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/DifferenceExport.java
index 015cc98..d6fefa7 100644
--- a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/DifferenceExport.java
+++ b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/DifferenceExport.java
@@ -44,6 +44,7 @@ import org.apache.fluo.api.data.RowColumn;
  *
  * @param <K> Export queue key type
  * @param <V> Type of export value object used to generate data
+ * @since 1.0.0
  */
 public abstract class DifferenceExport<K, V> implements AccumuloExport<K> {
 

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/ReplicationExport.java
----------------------------------------------------------------------
diff --git a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/ReplicationExport.java
b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/ReplicationExport.java
index 9a3b196..9276c6d 100644
--- a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/ReplicationExport.java
+++ b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/ReplicationExport.java
@@ -33,6 +33,7 @@ import org.apache.fluo.recipes.core.transaction.TxLog;
  * TxLog
  *
  * @param <K> Type of export queue key
+ * @since 1.0.0
  */
 public class ReplicationExport<K> implements AccumuloExport<K> {
 

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/TableInfo.java
----------------------------------------------------------------------
diff --git a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/TableInfo.java
b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/TableInfo.java
index 04f7c05..9da6773 100644
--- a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/TableInfo.java
+++ b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/TableInfo.java
@@ -15,6 +15,9 @@
 
 package org.apache.fluo.recipes.accumulo.export;
 
+/**
+ * @since 1.0.0
+ */
 public class TableInfo {
   String instanceName;
   String zookeepers;

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/ops/TableOperations.java
----------------------------------------------------------------------
diff --git a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/ops/TableOperations.java
b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/ops/TableOperations.java
index 62abd7e..3cc418c 100644
--- a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/ops/TableOperations.java
+++ b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/ops/TableOperations.java
@@ -37,8 +37,9 @@ import org.slf4j.LoggerFactory;
 
 /**
  * Utility methods for operating on the Fluo table used by recipes.
+ *
+ * @since 1.0.0
  */
-
 public class TableOperations {
 
   private static final String RGB_CLASS =

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/common/Pirtos.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/common/Pirtos.java b/modules/core/src/main/java/org/apache/fluo/recipes/core/common/Pirtos.java
index 5488e29..8b36472 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/common/Pirtos.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/common/Pirtos.java
@@ -30,8 +30,9 @@ import org.apache.fluo.recipes.core.map.CollisionFreeMap;
 
 /**
  * Post initialization recommended table optimizations.
+ *
+ * @since 1.0.0
  */
-
 public class Pirtos {
   private List<Bytes> splits = new ArrayList<>();
   private String tabletGroupingRegex = "";

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/common/RowRange.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/common/RowRange.java
b/modules/core/src/main/java/org/apache/fluo/recipes/core/common/RowRange.java
index 913357b..361dd6e 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/common/RowRange.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/common/RowRange.java
@@ -19,6 +19,9 @@ import java.util.Objects;
 
 import org.apache.fluo.api.data.Bytes;
 
+/**
+ * @since 1.0.0
+ */
 public class RowRange {
   private final Bytes start;
   private final Bytes end;

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/common/TransientRegistry.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/common/TransientRegistry.java
b/modules/core/src/main/java/org/apache/fluo/recipes/core/common/TransientRegistry.java
index 9533a7a..dc3922f 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/common/TransientRegistry.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/common/TransientRegistry.java
@@ -29,8 +29,9 @@ import org.apache.fluo.api.data.Bytes;
 /**
  * This class offers a standard way to register transient ranges. The project level documentation
  * provides a comprehensive overview.
+ *
+ * @since 1.0.0
  */
-
 public class TransientRegistry {
 
   private SimpleConfiguration appConfig;

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/data/RowHasher.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/data/RowHasher.java b/modules/core/src/main/java/org/apache/fluo/recipes/core/data/RowHasher.java
index e09bed5..ace7e7e 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/data/RowHasher.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/data/RowHasher.java
@@ -39,6 +39,8 @@ import org.apache.fluo.recipes.core.common.Pirtos;
  * 
  * <p>
  * The project documentation has more information.
+ *
+ * @since 1.0.0
  */
 public class RowHasher {
 

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/export/Export.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/export/Export.java b/modules/core/src/main/java/org/apache/fluo/recipes/core/export/Export.java
index 4f14f65..5325d43 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/export/Export.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/export/Export.java
@@ -17,6 +17,9 @@ package org.apache.fluo.recipes.core.export;
 
 import java.util.Objects;
 
+/**
+ * @since 1.0.0
+ */
 public class Export<K, V> {
   private final K key;
   private final V value;

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportObserver.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportObserver.java
b/modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportObserver.java
index 940575b..e09a376 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportObserver.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportObserver.java
@@ -25,6 +25,9 @@ import org.apache.fluo.api.data.Column;
 import org.apache.fluo.api.observer.AbstractObserver;
 import org.apache.fluo.recipes.core.serialization.SimpleSerializer;
 
+/**
+ * @since 1.0.0
+ */
 public class ExportObserver<K, V> extends AbstractObserver {
 
   private static class MemLimitIterator implements Iterator<ExportEntry> {

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportQueue.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportQueue.java
b/modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportQueue.java
index f013872..ac04f80 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportQueue.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportQueue.java
@@ -35,6 +35,9 @@ import org.apache.fluo.recipes.core.common.RowRange;
 import org.apache.fluo.recipes.core.common.TransientRegistry;
 import org.apache.fluo.recipes.core.serialization.SimpleSerializer;
 
+/**
+ * @since 1.0.0
+ */
 public class ExportQueue<K, V> {
 
   private static final String RANGE_BEGIN = "#";

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/export/Exporter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/export/Exporter.java
b/modules/core/src/main/java/org/apache/fluo/recipes/core/export/Exporter.java
index 529d5f3..f00cfb0 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/export/Exporter.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/export/Exporter.java
@@ -19,6 +19,9 @@ import java.util.Iterator;
 
 import org.apache.fluo.api.observer.Observer.Context;
 
+/**
+ * @since 1.0.0
+ */
 public abstract class Exporter<K, V> {
 
   public void init(String queueId, Context observerContext) throws Exception {}

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/export/SequencedExport.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/export/SequencedExport.java
b/modules/core/src/main/java/org/apache/fluo/recipes/core/export/SequencedExport.java
index ef1cfe2..e944092 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/export/SequencedExport.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/export/SequencedExport.java
@@ -15,6 +15,9 @@
 
 package org.apache.fluo.recipes.core.export;
 
+/**
+ * @since 1.0.0
+ */
 public class SequencedExport<K, V> extends Export<K, V> {
   private final long seq;
 

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/map/CollisionFreeMap.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/map/CollisionFreeMap.java
b/modules/core/src/main/java/org/apache/fluo/recipes/core/map/CollisionFreeMap.java
index 61fec47..6cbc658 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/map/CollisionFreeMap.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/map/CollisionFreeMap.java
@@ -55,6 +55,8 @@ import org.apache.fluo.recipes.core.serialization.SimpleSerializer;
 
 /**
  * See the project level documentation for information about this recipe.
+ *
+ * @since 1.0.0
  */
 public class CollisionFreeMap<K, V> {
 
@@ -374,7 +376,6 @@ public class CollisionFreeMap<K, V> {
     }
   }
 
-
   public static <K2, V2> CollisionFreeMap<K2, V2> getInstance(String mapId,
       SimpleConfiguration appConf) {
     Options opts = new Options(mapId, appConf);
@@ -398,7 +399,6 @@ public class CollisionFreeMap<K, V> {
     return new Initializer<>(mapId, numBuckets, serializer);
   }
 
-
   /**
    * @see CollisionFreeMap#getInitializer(String, int, SimpleSerializer)
    */

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/map/CollisionFreeMapObserver.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/map/CollisionFreeMapObserver.java
b/modules/core/src/main/java/org/apache/fluo/recipes/core/map/CollisionFreeMapObserver.java
index 96890af..581bb10 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/map/CollisionFreeMapObserver.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/map/CollisionFreeMapObserver.java
@@ -23,8 +23,9 @@ import org.apache.fluo.api.observer.AbstractObserver;
 /**
  * This class is configured for use by CollisionFreeMap.configure(FluoConfiguration,
  * CollisionFreeMap.Options) . This class should never have to be used directly.
+ *
+ * @since 1.0.0
  */
-
 public class CollisionFreeMapObserver extends AbstractObserver {
 
   @SuppressWarnings("rawtypes")

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/map/Combiner.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/map/Combiner.java b/modules/core/src/main/java/org/apache/fluo/recipes/core/map/Combiner.java
index c9d468b..4d3ee77 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/map/Combiner.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/map/Combiner.java
@@ -18,7 +18,11 @@ package org.apache.fluo.recipes.core.map;
 import java.util.Iterator;
 import java.util.Optional;
 
+/**
+ * @since 1.0.0
+ */
 public interface Combiner<K, V> {
+
   /**
    * This function is called to combine the current value of a key with updates that were
queued for
    * the key. See the collision free map project level documentation for more information.
@@ -26,6 +30,5 @@ public interface Combiner<K, V> {
    * @return Then new value for the key. Returning Optional.absent() will cause the key to
be
    *         deleted.
    */
-
   Optional<V> combine(K key, Iterator<V> updates);
 }

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/map/Update.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/map/Update.java b/modules/core/src/main/java/org/apache/fluo/recipes/core/map/Update.java
index 10e718e..1965111 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/map/Update.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/map/Update.java
@@ -17,6 +17,9 @@ package org.apache.fluo.recipes.core.map;
 
 import java.util.Optional;
 
+/**
+ * @since 1.0.0
+ */
 public class Update<K, V> {
 
   private final K key;

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/map/UpdateObserver.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/map/UpdateObserver.java
b/modules/core/src/main/java/org/apache/fluo/recipes/core/map/UpdateObserver.java
index 2e48451..b00e1b3 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/map/UpdateObserver.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/map/UpdateObserver.java
@@ -23,8 +23,9 @@ import org.apache.fluo.api.observer.Observer.Context;
 /**
  * A {@link CollisionFreeMap} calls this to allow additional processing to be done when key
values
  * are updated. See the project level documentation for more information.
+ *
+ * @since 1.0.0
  */
-
 public abstract class UpdateObserver<K, V> {
   public void init(String mapId, Context observerContext) throws Exception {}
 

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/serialization/SimpleSerializer.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/serialization/SimpleSerializer.java
b/modules/core/src/main/java/org/apache/fluo/recipes/core/serialization/SimpleSerializer.java
index 589b9cc..4efed5f 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/serialization/SimpleSerializer.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/serialization/SimpleSerializer.java
@@ -18,6 +18,9 @@ package org.apache.fluo.recipes.core.serialization;
 import org.apache.fluo.api.config.FluoConfiguration;
 import org.apache.fluo.api.config.SimpleConfiguration;
 
+/**
+ * @since 1.0.0
+ */
 public interface SimpleSerializer {
 
   /**

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/LogEntry.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/LogEntry.java
b/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/LogEntry.java
index fa25b63..6023e4a 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/LogEntry.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/LogEntry.java
@@ -23,6 +23,8 @@ import org.apache.fluo.api.data.Column;
 /**
  * Logs an operation (i.e GET, SET, or DELETE) in a Transaction. Multiple LogEntry objects
make up a
  * {@link TxLog}.
+ *
+ * @since 1.0.0
  */
 public class LogEntry {
 

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/RecordingTransaction.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/RecordingTransaction.java
b/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/RecordingTransaction.java
index 8fb98d3..06a1e74 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/RecordingTransaction.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/RecordingTransaction.java
@@ -23,6 +23,8 @@ import org.apache.fluo.api.exceptions.CommitException;
 /**
  * An implementation of {@link Transaction} that logs all transactions operations (GET, SET,
or
  * DELETE) in a {@link TxLog} that can be used for exports
+ *
+ * @since 1.0.0
  */
 public class RecordingTransaction extends RecordingTransactionBase implements Transaction
{
 

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/RecordingTransactionBase.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/RecordingTransactionBase.java
b/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/RecordingTransactionBase.java
index 6303122..a29cf88 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/RecordingTransactionBase.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/RecordingTransactionBase.java
@@ -33,6 +33,8 @@ import org.apache.fluo.api.iterator.RowIterator;
 /**
  * An implementation of {@link TransactionBase} that logs all transactions operations (GET,
SET, or
  * DELETE) in a {@link TxLog} that can be used for exports
+ *
+ * @since 1.0.0
  */
 public class RecordingTransactionBase implements TransactionBase {
 

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/TxLog.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/TxLog.java
b/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/TxLog.java
index caa3c4d..70bd706 100644
--- a/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/TxLog.java
+++ b/modules/core/src/main/java/org/apache/fluo/recipes/core/transaction/TxLog.java
@@ -27,6 +27,8 @@ import org.apache.fluo.api.data.RowColumn;
 
 /**
  * Contains list of operations (GET, SET, DELETE) performed during a {@link RecordingTransaction}
+ *
+ * @since 1.0.0
  */
 public class TxLog {
 

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/kryo/src/main/java/org/apache/fluo/recipes/kryo/KryoSimplerSerializer.java
----------------------------------------------------------------------
diff --git a/modules/kryo/src/main/java/org/apache/fluo/recipes/kryo/KryoSimplerSerializer.java
b/modules/kryo/src/main/java/org/apache/fluo/recipes/kryo/KryoSimplerSerializer.java
index 851f045..5c10d85 100644
--- a/modules/kryo/src/main/java/org/apache/fluo/recipes/kryo/KryoSimplerSerializer.java
+++ b/modules/kryo/src/main/java/org/apache/fluo/recipes/kryo/KryoSimplerSerializer.java
@@ -32,6 +32,9 @@ import org.apache.fluo.api.config.FluoConfiguration;
 import org.apache.fluo.api.config.SimpleConfiguration;
 import org.apache.fluo.recipes.core.serialization.SimpleSerializer;
 
+/***
+ * @since 1.0.0
+ */
 public class KryoSimplerSerializer implements SimpleSerializer, Serializable {
 
   private static final long serialVersionUID = 1L;

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/spark/src/main/java/org/apache/fluo/recipes/spark/AccumuloRangePartitioner.java
----------------------------------------------------------------------
diff --git a/modules/spark/src/main/java/org/apache/fluo/recipes/spark/AccumuloRangePartitioner.java
b/modules/spark/src/main/java/org/apache/fluo/recipes/spark/AccumuloRangePartitioner.java
index 7c715de..9e662e3 100644
--- a/modules/spark/src/main/java/org/apache/fluo/recipes/spark/AccumuloRangePartitioner.java
+++ b/modules/spark/src/main/java/org/apache/fluo/recipes/spark/AccumuloRangePartitioner.java
@@ -25,6 +25,9 @@ import org.apache.fluo.api.data.RowColumn;
 import org.apache.hadoop.io.Text;
 import org.apache.spark.Partitioner;
 
+/**
+ * @since 1.0.0
+ */
 public class AccumuloRangePartitioner extends Partitioner {
 
   private static final long serialVersionUID = 1L;

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/spark/src/main/java/org/apache/fluo/recipes/spark/FluoSparkHelper.java
----------------------------------------------------------------------
diff --git a/modules/spark/src/main/java/org/apache/fluo/recipes/spark/FluoSparkHelper.java
b/modules/spark/src/main/java/org/apache/fluo/recipes/spark/FluoSparkHelper.java
index 029ff71..e865888 100644
--- a/modules/spark/src/main/java/org/apache/fluo/recipes/spark/FluoSparkHelper.java
+++ b/modules/spark/src/main/java/org/apache/fluo/recipes/spark/FluoSparkHelper.java
@@ -54,6 +54,8 @@ import scala.Tuple2;
 
 /**
  * Helper methods for using Fluo with Spark
+ *
+ * @since 1.0.0
  */
 public class FluoSparkHelper {
 

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/spark/src/main/java/org/apache/fluo/recipes/spark/FluoSparkTestUtil.java
----------------------------------------------------------------------
diff --git a/modules/spark/src/main/java/org/apache/fluo/recipes/spark/FluoSparkTestUtil.java
b/modules/spark/src/main/java/org/apache/fluo/recipes/spark/FluoSparkTestUtil.java
index 10d3818..163bb8f 100644
--- a/modules/spark/src/main/java/org/apache/fluo/recipes/spark/FluoSparkTestUtil.java
+++ b/modules/spark/src/main/java/org/apache/fluo/recipes/spark/FluoSparkTestUtil.java
@@ -21,6 +21,8 @@ import org.apache.spark.api.java.JavaSparkContext;
 
 /**
  * Utility code for Fluo/Spark testing
+ *
+ * @since 1.0.0
  */
 public class FluoSparkTestUtil {
 

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/test/src/main/java/org/apache/fluo/recipes/test/AccumuloExportITBase.java
----------------------------------------------------------------------
diff --git a/modules/test/src/main/java/org/apache/fluo/recipes/test/AccumuloExportITBase.java
b/modules/test/src/main/java/org/apache/fluo/recipes/test/AccumuloExportITBase.java
index 2d1bbb4..c1adc3b 100644
--- a/modules/test/src/main/java/org/apache/fluo/recipes/test/AccumuloExportITBase.java
+++ b/modules/test/src/main/java/org/apache/fluo/recipes/test/AccumuloExportITBase.java
@@ -90,6 +90,8 @@ import org.junit.BeforeClass;
  *    }
  * </code>
  * </pre>
+ *
+ * @since 1.0.0
  */
 public class AccumuloExportITBase {
 

http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/083e4afb/modules/test/src/main/java/org/apache/fluo/recipes/test/FluoITHelper.java
----------------------------------------------------------------------
diff --git a/modules/test/src/main/java/org/apache/fluo/recipes/test/FluoITHelper.java b/modules/test/src/main/java/org/apache/fluo/recipes/test/FluoITHelper.java
index 229d562..92d7eaf 100644
--- a/modules/test/src/main/java/org/apache/fluo/recipes/test/FluoITHelper.java
+++ b/modules/test/src/main/java/org/apache/fluo/recipes/test/FluoITHelper.java
@@ -45,6 +45,8 @@ import org.slf4j.LoggerFactory;
 
 /**
  * Helper for creating integration tests that connect to a MiniFluo/MiniAccumuloCluster instance.
+ *
+ * @since 1.0.0
  */
 public class FluoITHelper {
 


Mime
View raw message