You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluo.apache.org by kt...@apache.org on 2016/07/15 22:07:57 UTC
[09/10] incubator-fluo-recipes git commit: Added '@since 1.0.0'
annotations
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 <mw...@gmail.com>
Authored: Fri Jul 15 12:26:07 2016 -0400
Committer: Mike Walch <mw...@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 {