Repository: incubator-datafu
Updated Branches:
refs/heads/master ecb03180b -> e7835c11f
DATAFU-74: Remove author tags.
https://issues.apache.org/jira/browse/DATAFU-7
Signed-off-by: Matt Hayes <mhayes@linkedin.com>
Project: http://git-wip-us.apache.org/repos/asf/incubator-datafu/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-datafu/commit/966da2f3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-datafu/tree/966da2f3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-datafu/diff/966da2f3
Branch: refs/heads/master
Commit: 966da2f3821dc7459eb8455293031cfa367c8ba3
Parents: ecb0318
Author: Jakob Homan <jghoman@gmail.com>
Authored: Mon Nov 24 13:39:33 2014 -0800
Committer: Matt Hayes <mhayes@linkedin.com>
Committed: Mon Nov 24 13:54:45 2014 -0800
----------------------------------------------------------------------
.../java/datafu/hourglass/avro/AvroDateRangeMetadata.java | 2 --
.../datafu/hourglass/avro/AvroMultipleInputsUtil.java | 2 --
.../datafu/hourglass/avro/CombinedAvroKeyInputFormat.java | 2 --
.../src/main/java/datafu/hourglass/fs/DatePath.java | 2 --
.../src/main/java/datafu/hourglass/fs/DateRange.java | 2 --
.../src/main/java/datafu/hourglass/fs/PathUtils.java | 2 --
.../src/main/java/datafu/hourglass/jobs/AbstractJob.java | 2 --
.../datafu/hourglass/jobs/AbstractNonIncrementalJob.java | 10 ----------
.../jobs/AbstractPartitionCollapsingIncrementalJob.java | 4 ----
.../jobs/AbstractPartitionPreservingIncrementalJob.java | 4 ----
.../java/datafu/hourglass/jobs/DateRangeConfigurable.java | 2 --
.../main/java/datafu/hourglass/jobs/DateRangePlanner.java | 2 --
.../main/java/datafu/hourglass/jobs/ExecutionPlanner.java | 2 --
.../src/main/java/datafu/hourglass/jobs/FileCleaner.java | 2 --
.../main/java/datafu/hourglass/jobs/IncrementalJob.java | 2 --
.../jobs/PartitionCollapsingExecutionPlanner.java | 4 ----
.../hourglass/jobs/PartitionCollapsingIncrementalJob.java | 2 --
.../jobs/PartitionPreservingExecutionPlanner.java | 2 --
.../hourglass/jobs/PartitionPreservingIncrementalJob.java | 2 --
.../main/java/datafu/hourglass/jobs/ReduceEstimator.java | 2 --
.../src/main/java/datafu/hourglass/jobs/Setup.java | 2 --
.../src/main/java/datafu/hourglass/jobs/TimeBasedJob.java | 2 --
.../main/java/datafu/hourglass/jobs/TimePartitioner.java | 2 --
.../hourglass/mapreduce/AvroKeyValueIdentityMapper.java | 2 --
.../datafu/hourglass/mapreduce/CollapsingCombiner.java | 2 --
.../java/datafu/hourglass/mapreduce/CollapsingMapper.java | 6 ------
.../datafu/hourglass/mapreduce/CollapsingReducer.java | 2 --
.../datafu/hourglass/mapreduce/DelegatingCombiner.java | 2 --
.../java/datafu/hourglass/mapreduce/DelegatingMapper.java | 2 --
.../datafu/hourglass/mapreduce/DelegatingReducer.java | 2 --
.../hourglass/mapreduce/DistributedCacheHelper.java | 2 --
.../java/datafu/hourglass/mapreduce/ObjectMapper.java | 2 --
.../java/datafu/hourglass/mapreduce/ObjectProcessor.java | 2 --
.../java/datafu/hourglass/mapreduce/ObjectReducer.java | 2 --
.../main/java/datafu/hourglass/mapreduce/Parameters.java | 2 --
.../datafu/hourglass/mapreduce/PartitioningCombiner.java | 2 --
.../datafu/hourglass/mapreduce/PartitioningMapper.java | 4 ----
.../datafu/hourglass/mapreduce/PartitioningReducer.java | 2 --
.../src/main/java/datafu/hourglass/model/Accumulator.java | 2 --
.../java/datafu/hourglass/model/KeyValueCollector.java | 2 --
.../src/main/java/datafu/hourglass/model/Mapper.java | 2 --
.../src/main/java/datafu/hourglass/model/Merger.java | 2 --
.../hourglass/schemas/PartitionCollapsingSchemas.java | 2 --
.../hourglass/schemas/PartitionPreservingSchemas.java | 2 --
.../main/java/datafu/hourglass/schemas/TaskSchemas.java | 2 --
.../src/test/java/datafu/hourglass/demo/CountById.java | 2 --
.../java/datafu/hourglass/demo/EstimateCardinality.java | 2 --
.../src/test/java/datafu/hourglass/demo/GenerateIds.java | 2 --
datafu-pig/src/main/java/datafu/pig/bags/BagConcat.java | 2 --
datafu-pig/src/main/java/datafu/pig/bags/BagGroup.java | 2 --
datafu-pig/src/main/java/datafu/pig/bags/BagJoin.java | 2 --
.../src/main/java/datafu/pig/bags/BagLeftOuterJoin.java | 2 --
.../src/main/java/datafu/pig/hash/lsh/LSHFamily.java | 2 --
datafu-pig/src/main/java/datafu/pig/hash/lsh/LSHFunc.java | 2 --
.../src/main/java/datafu/pig/hash/lsh/RepeatingLSH.java | 2 --
.../src/main/java/datafu/pig/hash/lsh/interfaces/LSH.java | 2 --
.../java/datafu/pig/hash/lsh/interfaces/LSHCreator.java | 2 --
.../main/java/datafu/pig/hash/lsh/interfaces/Sampler.java | 2 --
.../src/main/java/datafu/pig/hash/lsh/metric/Cosine.java | 2 --
.../src/main/java/datafu/pig/hash/lsh/metric/L1.java | 2 --
.../src/main/java/datafu/pig/hash/lsh/metric/L2.java | 2 --
.../main/java/datafu/pig/hash/lsh/metric/MetricUDF.java | 2 --
.../lsh/p_stable/AbstractStableDistributionFunction.java | 2 --
.../src/main/java/datafu/pig/hash/lsh/p_stable/L1LSH.java | 2 --
.../src/main/java/datafu/pig/hash/lsh/p_stable/L2LSH.java | 2 --
.../main/java/datafu/pig/hash/lsh/util/DataTypeUtil.java | 2 --
.../main/java/datafu/pig/sampling/ReservoirSample.java | 2 --
.../src/main/java/datafu/pig/sampling/SampleByKey.java | 2 --
.../main/java/datafu/pig/sampling/SimpleRandomSample.java | 2 --
.../sampling/SimpleRandomSampleWithReplacementElect.java | 2 --
.../sampling/SimpleRandomSampleWithReplacementVote.java | 2 --
.../java/datafu/pig/sampling/WeightedReservoirSample.java | 2 --
.../src/main/java/datafu/pig/sets/SetDifference.java | 2 --
.../main/java/datafu/pig/stats/HyperLogLogPlusPlus.java | 2 --
.../src/main/java/datafu/pig/util/AliasableEvalFunc.java | 2 --
.../src/main/java/datafu/pig/util/FieldNotFound.java | 2 --
datafu-pig/src/main/java/datafu/pig/util/InUDF.java | 2 --
.../datafu/test/pig/sampling/SimpleRandomSampleTest.java | 2 --
.../test/pig/sampling/SimpleRandomSampleTestOld.java | 2 --
.../sampling/SimpleRandomSampleWithReplacementTest.java | 2 --
.../test/pig/sampling/WeightedReservoirSamplingTests.java | 2 --
81 files changed, 182 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/avro/AvroDateRangeMetadata.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/avro/AvroDateRangeMetadata.java b/datafu-hourglass/src/main/java/datafu/hourglass/avro/AvroDateRangeMetadata.java
index 6f38fbe..4e6f976 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/avro/AvroDateRangeMetadata.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/avro/AvroDateRangeMetadata.java
@@ -39,8 +39,6 @@ import datafu.hourglass.fs.PathUtils;
* This is used by {@link datafu.hourglass.jobs.AbstractPartitionCollapsingIncrementalJob} so that when reusing previous
* output it can determine the date range the data corresponds to.
*
- * @author "Matthew Hayes"
- *
*/
public class AvroDateRangeMetadata
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/avro/AvroMultipleInputsUtil.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/avro/AvroMultipleInputsUtil.java b/datafu-hourglass/src/main/java/datafu/hourglass/avro/AvroMultipleInputsUtil.java
index 8afe192..bf6071e 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/avro/AvroMultipleInputsUtil.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/avro/AvroMultipleInputsUtil.java
@@ -33,8 +33,6 @@ import org.json.JSONObject;
* that maps each input path to its corresponding schema. Methods in this class help with loading and
* storing these schema mappings.
*
- * @author "Matthew Hayes"
- *
*/
public class AvroMultipleInputsUtil
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/avro/CombinedAvroKeyInputFormat.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/avro/CombinedAvroKeyInputFormat.java b/datafu-hourglass/src/main/java/datafu/hourglass/avro/CombinedAvroKeyInputFormat.java
index e6beae2..a89d9c3 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/avro/CombinedAvroKeyInputFormat.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/avro/CombinedAvroKeyInputFormat.java
@@ -40,8 +40,6 @@ import datafu.hourglass.jobs.AbstractPartitionPreservingIncrementalJob;
/**
* A combined input format for reading Avro data.
*
- * @author "Matthew Hayes"
- *
* @param <T> Type of data to be read
*/
public class CombinedAvroKeyInputFormat<T> extends CombineFileInputFormat<AvroKey<T>, NullWritable>
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/fs/DatePath.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/fs/DatePath.java b/datafu-hourglass/src/main/java/datafu/hourglass/fs/DatePath.java
index 8229574..215ddbd 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/fs/DatePath.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/fs/DatePath.java
@@ -28,8 +28,6 @@ import org.apache.hadoop.fs.Path;
/**
* Represents a path and the corresponding date that is associated with it.
*
- * @author "Matthew Hayes"
- *
*/
public class DatePath implements Comparable<DatePath>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/fs/DateRange.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/fs/DateRange.java b/datafu-hourglass/src/main/java/datafu/hourglass/fs/DateRange.java
index 3cac627..b6d471e 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/fs/DateRange.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/fs/DateRange.java
@@ -24,8 +24,6 @@ import java.util.Date;
/**
* A date range, consisting of a start and end date.
*
- * @author "Matthew Hayes"
- *
*/
public class DateRange
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/fs/PathUtils.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/fs/PathUtils.java b/datafu-hourglass/src/main/java/datafu/hourglass/fs/PathUtils.java
index 951eec6..c270c7b 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/fs/PathUtils.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/fs/PathUtils.java
@@ -48,8 +48,6 @@ import org.apache.log4j.Logger;
/**
* A collection of utility methods for dealing with files and paths.
*
- * @author "Matthew Hayes"
- *
*/
public class PathUtils
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractJob.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractJob.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractJob.java
index 651c80b..16679f3 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractJob.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractJob.java
@@ -82,8 +82,6 @@ import org.apache.hadoop.fs.Path;
* <em>hadoop-conf.mapred.min.split.size</em> to the desired value.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public abstract class AbstractJob extends Configured
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractNonIncrementalJob.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractNonIncrementalJob.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractNonIncrementalJob.java
index 787d6d6..8a6deb4 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractNonIncrementalJob.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractNonIncrementalJob.java
@@ -84,8 +84,6 @@ import datafu.hourglass.fs.PathUtils;
* and then rounded up.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public abstract class AbstractNonIncrementalJob extends TimeBasedJob
{
@@ -333,8 +331,6 @@ public abstract class AbstractNonIncrementalJob extends TimeBasedJob
/**
* Mapper base class for {@link AbstractNonIncrementalJob}.
*
- * @author "Matthew Hayes"
- *
*/
public static abstract class BaseMapper extends Mapper<AvroKey<GenericRecord>, NullWritable, AvroKey<GenericRecord>, AvroValue<GenericRecord>>
{
@@ -343,8 +339,6 @@ public abstract class AbstractNonIncrementalJob extends TimeBasedJob
/**
* Combiner base class for {@link AbstractNonIncrementalJob}.
*
- * @author "Matthew Hayes"
- *
*/
public static abstract class BaseCombiner extends Reducer<AvroKey<GenericRecord>, AvroValue<GenericRecord>, AvroKey<GenericRecord>, AvroValue<GenericRecord>>
{
@@ -353,8 +347,6 @@ public abstract class AbstractNonIncrementalJob extends TimeBasedJob
/**
* Reducer base class for {@link AbstractNonIncrementalJob}.
*
- * @author "Matthew Hayes"
- *
*/
public static abstract class BaseReducer extends Reducer<AvroKey<GenericRecord>, AvroValue<GenericRecord>, AvroKey<GenericRecord>, NullWritable>
{
@@ -363,8 +355,6 @@ public abstract class AbstractNonIncrementalJob extends TimeBasedJob
/**
* Reports files created and processed for an iteration of the job.
*
- * @author "Matthew Hayes"
- *
*/
public static class Report
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractPartitionCollapsingIncrementalJob.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractPartitionCollapsingIncrementalJob.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractPartitionCollapsingIncrementalJob.java
index e1daa3a..25425b6 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractPartitionCollapsingIncrementalJob.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractPartitionCollapsingIncrementalJob.java
@@ -183,8 +183,6 @@ import datafu.hourglass.schemas.PartitionCollapsingSchemas;
* <em>hadoop-conf.mapred.min.split.size</em> to the desired value.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public abstract class AbstractPartitionCollapsingIncrementalJob extends IncrementalJob
{
@@ -626,8 +624,6 @@ public abstract class AbstractPartitionCollapsingIncrementalJob extends Incremen
/**
* Reports files created and processed for an iteration of the job.
*
- * @author "Matthew Hayes"
- *
*/
public static class Report
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractPartitionPreservingIncrementalJob.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractPartitionPreservingIncrementalJob.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractPartitionPreservingIncrementalJob.java
index 1d695e8..1a0be14 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractPartitionPreservingIncrementalJob.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/AbstractPartitionPreservingIncrementalJob.java
@@ -159,8 +159,6 @@ import datafu.hourglass.schemas.PartitionPreservingSchemas;
* <em>hadoop-conf.mapred.min.split.size</em> to the desired value.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public abstract class AbstractPartitionPreservingIncrementalJob extends IncrementalJob
{
@@ -640,8 +638,6 @@ public abstract class AbstractPartitionPreservingIncrementalJob extends Incremen
/**
* Reports files created and processed for an iteration of the job.
*
- * @author "Matthew Hayes"
- *
*/
public static class Report
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/DateRangeConfigurable.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/DateRangeConfigurable.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/DateRangeConfigurable.java
index b4927b0..09e11fe 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/DateRangeConfigurable.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/DateRangeConfigurable.java
@@ -24,8 +24,6 @@ import datafu.hourglass.fs.DateRange;
/**
* An interface for an object with a configurable output date range.
*
- * @author "Matthew Hayes"
- *
*/
public interface DateRangeConfigurable
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/DateRangePlanner.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/DateRangePlanner.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/DateRangePlanner.java
index 62ba36e..57d680e 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/DateRangePlanner.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/DateRangePlanner.java
@@ -33,8 +33,6 @@ import datafu.hourglass.fs.PathUtils;
/**
* Determines the date range of inputs which should be processed.
*
- * @author "Matthew Hayes"
- *
*/
public class DateRangePlanner
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/ExecutionPlanner.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/ExecutionPlanner.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/ExecutionPlanner.java
index 2a7095b..8be6108 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/ExecutionPlanner.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/ExecutionPlanner.java
@@ -42,8 +42,6 @@ import datafu.hourglass.fs.PathUtils;
* Base class for execution planners. An execution planner determines which files should be processed
* for a particular run.
*
- * @author "Matthew Hayes"
- *
*/
public abstract class ExecutionPlanner
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/FileCleaner.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/FileCleaner.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/FileCleaner.java
index 267195e..594c5c0 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/FileCleaner.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/FileCleaner.java
@@ -33,8 +33,6 @@ import org.apache.log4j.Logger;
/**
* Used to remove files from the file system when they are no longer needed.
*
- * @author "Matthew Hayes"
- *
*/
public class FileCleaner
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/IncrementalJob.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/IncrementalJob.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/IncrementalJob.java
index 86880b9..5218df3 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/IncrementalJob.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/IncrementalJob.java
@@ -45,8 +45,6 @@ import datafu.hourglass.schemas.TaskSchemas;
* <li><em>fail.on.missing</em> - whether the job should fail if input data within the desired range is missing</li>
* </ul>
*
- * @author "Matthew Hayes"
- *
*/
public abstract class IncrementalJob extends TimeBasedJob
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionCollapsingExecutionPlanner.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionCollapsingExecutionPlanner.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionCollapsingExecutionPlanner.java
index a8dfa54..a229a92 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionCollapsingExecutionPlanner.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionCollapsingExecutionPlanner.java
@@ -71,8 +71,6 @@ import datafu.hourglass.fs.PathUtils;
* Check {@link ReduceEstimator} for more details on how the properties are used.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public class PartitionCollapsingExecutionPlanner extends ExecutionPlanner
{
@@ -87,8 +85,6 @@ public class PartitionCollapsingExecutionPlanner extends ExecutionPlanner
/**
* An execution plan. Encapsulates what inputs will be processed.
*
- * @author mhayes
- *
*/
private class Plan
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionCollapsingIncrementalJob.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionCollapsingIncrementalJob.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionCollapsingIncrementalJob.java
index c653d96..3eeb58b 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionCollapsingIncrementalJob.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionCollapsingIncrementalJob.java
@@ -36,8 +36,6 @@ import datafu.hourglass.model.Merger;
* Instead of extending this class and implementing the abstract methods, this concrete version
* can be used instead. Getters and setters have been provided for the abstract methods.
*
- * @author "Matthew Hayes"
- *
*/
public class PartitionCollapsingIncrementalJob extends AbstractPartitionCollapsingIncrementalJob
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionPreservingExecutionPlanner.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionPreservingExecutionPlanner.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionPreservingExecutionPlanner.java
index 2ccbaf5..5e1b506 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionPreservingExecutionPlanner.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionPreservingExecutionPlanner.java
@@ -61,8 +61,6 @@ import datafu.hourglass.fs.PathUtils;
* Check {@link ReduceEstimator} for more details on how the properties are used.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public class PartitionPreservingExecutionPlanner extends ExecutionPlanner
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionPreservingIncrementalJob.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionPreservingIncrementalJob.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionPreservingIncrementalJob.java
index 69d4dcd..0d862be 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionPreservingIncrementalJob.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionPreservingIncrementalJob.java
@@ -35,8 +35,6 @@ import datafu.hourglass.model.Mapper;
* Instead of extending this class and implementing the abstract methods, this concrete version
* can be used instead. Getters and setters have been provided for the abstract methods.
*
- * @author "Matthew Hayes"
- *
*/
public class PartitionPreservingIncrementalJob extends AbstractPartitionPreservingIncrementalJob
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/ReduceEstimator.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/ReduceEstimator.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/ReduceEstimator.java
index 6931f7b..07034ab 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/ReduceEstimator.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/ReduceEstimator.java
@@ -61,8 +61,6 @@ import datafu.hourglass.fs.PathUtils;
* <em>num.reducers.mydata.bytes.per.reducer</em>.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public class ReduceEstimator
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/Setup.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/Setup.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/Setup.java
index 2e26900..366d023 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/Setup.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/Setup.java
@@ -25,8 +25,6 @@ import org.apache.hadoop.conf.Configuration;
* Used as a callback by {@link PartitionCollapsingIncrementalJob} and {@link PartitionPreservingIncrementalJob}
* to provide configuration settings for the Hadoop job.
*
- * @author "Matthew Hayes"
- *
*/
public interface Setup
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/TimeBasedJob.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/TimeBasedJob.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/TimeBasedJob.java
index 81112da..a612c0c 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/TimeBasedJob.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/TimeBasedJob.java
@@ -44,8 +44,6 @@ import datafu.hourglass.fs.PathUtils;
* Methods are available as well for setting these configuration parameters.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public abstract class TimeBasedJob extends AbstractJob
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/jobs/TimePartitioner.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/TimePartitioner.java b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/TimePartitioner.java
index 17c460d..f2244ca 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/jobs/TimePartitioner.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/jobs/TimePartitioner.java
@@ -48,8 +48,6 @@ import org.apache.hadoop.mapreduce.Partitioner;
* which should be set in the Hadoop configuration. Input days are assigned to reducers in a round-robin fashion.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public class TimePartitioner extends Partitioner<AvroKey<GenericRecord>,AvroValue<GenericRecord>> implements Configurable
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/AvroKeyValueIdentityMapper.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/AvroKeyValueIdentityMapper.java b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/AvroKeyValueIdentityMapper.java
index ff317ca..4bb6da0 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/AvroKeyValueIdentityMapper.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/AvroKeyValueIdentityMapper.java
@@ -30,8 +30,6 @@ import org.apache.hadoop.mapreduce.Mapper;
* It assumes the input is an Avro record having "key" and "value" fields.
* The output is these exact same fields.
*
- * @author "Matthew Hayes"
- *
*/
public class AvroKeyValueIdentityMapper extends Mapper<Object, Object, Object, Object>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/CollapsingCombiner.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/CollapsingCombiner.java b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/CollapsingCombiner.java
index e51c53b..43301ec 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/CollapsingCombiner.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/CollapsingCombiner.java
@@ -46,8 +46,6 @@ import datafu.hourglass.schemas.PartitionCollapsingSchemas;
* intermediate value.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public class CollapsingCombiner extends ObjectReducer implements DateRangeConfigurable, Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/CollapsingMapper.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/CollapsingMapper.java b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/CollapsingMapper.java
index 5dec8fc..2ad4e00 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/CollapsingMapper.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/CollapsingMapper.java
@@ -50,8 +50,6 @@ import datafu.hourglass.schemas.PartitionCollapsingSchemas;
* map operation, which produces key and intermediate value pairs from the input.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public class CollapsingMapper extends ObjectMapper implements Serializable
{
@@ -224,8 +222,6 @@ public class CollapsingMapper extends ObjectMapper implements Serializable
* A {@see KeyValueCollector} that outputs key-value pairs to {@link MapContext}
* and tags each mapped value with the time for the partition it was derived from.
*
- * @author "Matthew Hayes"
- *
*/
private class TimeMapCollector extends MapCollector
{
@@ -299,8 +295,6 @@ public class CollapsingMapper extends ObjectMapper implements Serializable
/**
* A {@see KeyValueCollector} that outputs key-value pairs to {@link MapContext} as-is.
*
- * @author "Matthew Hayes"
- *
*/
private class IdentityMapCollector extends MapCollector
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/CollapsingReducer.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/CollapsingReducer.java b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/CollapsingReducer.java
index bcff7ae..fa614d5 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/CollapsingReducer.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/CollapsingReducer.java
@@ -48,8 +48,6 @@ import datafu.hourglass.schemas.PartitionCollapsingSchemas;
* output value.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public class CollapsingReducer extends ObjectReducer implements DateRangeConfigurable, Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DelegatingCombiner.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DelegatingCombiner.java b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DelegatingCombiner.java
index 8b7d574..36ffa75 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DelegatingCombiner.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DelegatingCombiner.java
@@ -28,8 +28,6 @@ import org.apache.hadoop.mapreduce.Reducer;
/**
* A Hadoop combiner which delegates to an implementation read from the distributed cache.
*
- * @author "Matthew Hayes"
- *
*/
public class DelegatingCombiner extends Reducer<Object, Object, Object, Object>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DelegatingMapper.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DelegatingMapper.java b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DelegatingMapper.java
index ea7a8ae..414913c 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DelegatingMapper.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DelegatingMapper.java
@@ -28,8 +28,6 @@ import org.apache.hadoop.mapreduce.Mapper;
/**
* A Hadoop mapper which delegates to an implementation read from the distributed cache.
*
- * @author "Matthew Hayes"
- *
*/
public class DelegatingMapper extends Mapper<Object, Object, Object, Object>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DelegatingReducer.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DelegatingReducer.java b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DelegatingReducer.java
index 6596a5f..be1afb5 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DelegatingReducer.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DelegatingReducer.java
@@ -28,8 +28,6 @@ import org.apache.hadoop.mapreduce.Reducer;
/**
* A Hadoop reducer which delegates to an implementation read from the distributed cache.
*
- * @author "Matthew Hayes"
- *
*/
public class DelegatingReducer extends Reducer<Object, Object, Object, Object>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DistributedCacheHelper.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DistributedCacheHelper.java b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DistributedCacheHelper.java
index 3e34c3c..62975d1 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DistributedCacheHelper.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/DistributedCacheHelper.java
@@ -34,8 +34,6 @@ import org.apache.hadoop.fs.Path;
/**
* Methods for working with the Hadoop distributed cache.
*
- * @author "Matthew Hayes"
- *
*/
public class DistributedCacheHelper
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/ObjectMapper.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/ObjectMapper.java b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/ObjectMapper.java
index 9723b32..0ff10b1 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/ObjectMapper.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/ObjectMapper.java
@@ -26,8 +26,6 @@ import org.apache.hadoop.mapreduce.MapContext;
/**
* Defines the interface for a mapper implementation that {@link DelegatingMapper} delegates to.
*
- * @author "Matthew Hayes"
- *
*/
public abstract class ObjectMapper extends ObjectProcessor {
public abstract void map(Object input,
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/ObjectProcessor.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/ObjectProcessor.java b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/ObjectProcessor.java
index b4383c7..c001854 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/ObjectProcessor.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/ObjectProcessor.java
@@ -26,8 +26,6 @@ import org.apache.hadoop.mapreduce.TaskInputOutputContext;
/**
* Base class for {@link ObjectMapper} and {@link ObjectReducer}.
*
- * @author "Matthew Hayes"
- *
*/
public abstract class ObjectProcessor
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/ObjectReducer.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/ObjectReducer.java b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/ObjectReducer.java
index 786ca31..f9b8cdc 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/ObjectReducer.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/ObjectReducer.java
@@ -27,8 +27,6 @@ import org.apache.hadoop.mapreduce.ReduceContext;
* Defines the interface for combiner and reducer implementations that {@link DelegatingCombiner} and
* {@link DelegatingReducer} delegate to.
*
- * @author "Matthew Hayes"
- *
*/
public abstract class ObjectReducer extends ObjectProcessor {
public abstract void reduce(Object key,
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/Parameters.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/Parameters.java b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/Parameters.java
index 2fc690e..5cbabb7 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/Parameters.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/Parameters.java
@@ -23,8 +23,6 @@ package datafu.hourglass.mapreduce;
* Parameters used by the jobs to pass configuration settings
* to the mappers, combiners, and reducers.
*
- * @author "Matthew Hayes"
- *
*/
public class Parameters
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/PartitioningCombiner.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/PartitioningCombiner.java b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/PartitioningCombiner.java
index 574575f..2fccb8f 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/PartitioningCombiner.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/PartitioningCombiner.java
@@ -37,8 +37,6 @@ import datafu.hourglass.model.Accumulator;
* intermediate value.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public class PartitioningCombiner extends ObjectReducer implements Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/PartitioningMapper.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/PartitioningMapper.java b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/PartitioningMapper.java
index f1df195..e7b2c05 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/PartitioningMapper.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/PartitioningMapper.java
@@ -48,8 +48,6 @@ import datafu.hourglass.schemas.PartitionPreservingSchemas;
* that the input came from. This enables the combiner and reducer to preserve the partitions.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public class PartitioningMapper extends ObjectMapper implements Serializable
{
@@ -159,8 +157,6 @@ public class PartitioningMapper extends ObjectMapper implements Serializable
* A {@see KeyValueCollector} that writes to {@see MapContext} and tags each mapped key with the time for the partition
* it was derived from. This keeps the data partitioned so that the reducer may process each partition independently.
*
- * @author "Matthew Hayes"
- *
*/
private class MapCollector implements KeyValueCollector<GenericRecord,GenericRecord>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/PartitioningReducer.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/PartitioningReducer.java b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/PartitioningReducer.java
index a78610d..3195458 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/PartitioningReducer.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/mapreduce/PartitioningReducer.java
@@ -54,8 +54,6 @@ import datafu.hourglass.schemas.PartitionPreservingSchemas;
* where the named outputs have the form yyyyMMdd derived from the time.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public class PartitioningReducer extends ObjectReducer implements Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/model/Accumulator.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/model/Accumulator.java b/datafu-hourglass/src/main/java/datafu/hourglass/model/Accumulator.java
index 795e4e6..7ee11e6 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/model/Accumulator.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/model/Accumulator.java
@@ -24,8 +24,6 @@ import java.io.Serializable;
/**
* Collects a sequence of values and produces one value as a result.
*
- * @author "Matthew Hayes"
- *
* @param <In> Input value type
* @param <Out> Output value type
*/
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/model/KeyValueCollector.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/model/KeyValueCollector.java b/datafu-hourglass/src/main/java/datafu/hourglass/model/KeyValueCollector.java
index 6351e83..037ef4f 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/model/KeyValueCollector.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/model/KeyValueCollector.java
@@ -24,8 +24,6 @@ import java.io.IOException;
/**
* Provided to an instance of {@link Mapper} to collect key-value pairs.
*
- * @author "Matthew Hayes"
- *
* @param <K> Key type
* @param <V> Value type
*/
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/model/Mapper.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/model/Mapper.java b/datafu-hourglass/src/main/java/datafu/hourglass/model/Mapper.java
index 447e495..07feefc 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/model/Mapper.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/model/Mapper.java
@@ -25,8 +25,6 @@ import java.io.Serializable;
/**
* Maps an input record to one or more key-value pairs.
*
- * @author "Matthew Hayes"
- *
* @param <In> Input type
* @param <OutKey> Output key type
* @param <OutVal> Output value type
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/model/Merger.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/model/Merger.java b/datafu-hourglass/src/main/java/datafu/hourglass/model/Merger.java
index c61b47b..147abfc 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/model/Merger.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/model/Merger.java
@@ -24,8 +24,6 @@ import java.io.Serializable;
/**
* Merges two values together.
*
- * @author "Matthew Hayes"
- *
* @param <T> Value type
*/
public interface Merger<T> extends Serializable
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/schemas/PartitionCollapsingSchemas.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/schemas/PartitionCollapsingSchemas.java b/datafu-hourglass/src/main/java/datafu/hourglass/schemas/PartitionCollapsingSchemas.java
index a6b9a48..3c032b2 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/schemas/PartitionCollapsingSchemas.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/schemas/PartitionCollapsingSchemas.java
@@ -37,8 +37,6 @@ import org.apache.commons.lang.NullArgumentException;
/**
* Generates the Avro schemas used by {@link datafu.hourglass.jobs.AbstractPartitionCollapsingIncrementalJob} and its derivations.
*
- * @author "Matthew Hayes"
- *
*/
public class PartitionCollapsingSchemas implements Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/schemas/PartitionPreservingSchemas.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/schemas/PartitionPreservingSchemas.java b/datafu-hourglass/src/main/java/datafu/hourglass/schemas/PartitionPreservingSchemas.java
index 7bc93e7..f713a66 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/schemas/PartitionPreservingSchemas.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/schemas/PartitionPreservingSchemas.java
@@ -34,8 +34,6 @@ import org.apache.avro.mapred.Pair;
/**
* Generates the Avro schemas used by {@link datafu.hourglass.jobs.AbstractPartitionPreservingIncrementalJob} and its derivations.
*
- * @author "Matthew Hayes"
- *
*/
public class PartitionPreservingSchemas implements Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/main/java/datafu/hourglass/schemas/TaskSchemas.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/main/java/datafu/hourglass/schemas/TaskSchemas.java b/datafu-hourglass/src/main/java/datafu/hourglass/schemas/TaskSchemas.java
index 98f78a5..6788d76 100644
--- a/datafu-hourglass/src/main/java/datafu/hourglass/schemas/TaskSchemas.java
+++ b/datafu-hourglass/src/main/java/datafu/hourglass/schemas/TaskSchemas.java
@@ -30,8 +30,6 @@ import org.apache.avro.Schema;
* The reducer outputs key-value pairs conforming to the key and output value schemas.
* </p>
*
- * @author "Matthew Hayes"
- *
*/
public class TaskSchemas
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/test/java/datafu/hourglass/demo/CountById.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/test/java/datafu/hourglass/demo/CountById.java b/datafu-hourglass/src/test/java/datafu/hourglass/demo/CountById.java
index 8d025c4..8b07560 100644
--- a/datafu-hourglass/src/test/java/datafu/hourglass/demo/CountById.java
+++ b/datafu-hourglass/src/test/java/datafu/hourglass/demo/CountById.java
@@ -43,8 +43,6 @@ import datafu.hourglass.model.Mapper;
* incrementally counts the number of events, grouped by each distinct value.
* New days will be merged with the previous output.
*
- * @author "Matthew Hayes"
- *
*/
public class CountById extends Configured implements NamedTool, Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/test/java/datafu/hourglass/demo/EstimateCardinality.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/test/java/datafu/hourglass/demo/EstimateCardinality.java b/datafu-hourglass/src/test/java/datafu/hourglass/demo/EstimateCardinality.java
index 3e0767f..b8aa422 100644
--- a/datafu-hourglass/src/test/java/datafu/hourglass/demo/EstimateCardinality.java
+++ b/datafu-hourglass/src/test/java/datafu/hourglass/demo/EstimateCardinality.java
@@ -46,8 +46,6 @@ import datafu.hourglass.model.Mapper;
* Given an input event with field "id" stored in daily directories according to yyyy/MM/dd,
* estimates the cardinality of the values over the past 30 days.
*
- * @author "Matthew Hayes"
- *
*/
public class EstimateCardinality extends Configured implements NamedTool, Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-hourglass/src/test/java/datafu/hourglass/demo/GenerateIds.java
----------------------------------------------------------------------
diff --git a/datafu-hourglass/src/test/java/datafu/hourglass/demo/GenerateIds.java b/datafu-hourglass/src/test/java/datafu/hourglass/demo/GenerateIds.java
index 1a3609c..2fac0e3 100644
--- a/datafu-hourglass/src/test/java/datafu/hourglass/demo/GenerateIds.java
+++ b/datafu-hourglass/src/test/java/datafu/hourglass/demo/GenerateIds.java
@@ -45,8 +45,6 @@ import datafu.hourglass.test.Schemas;
* Generate random test data in yyyy/MM/dd paths for
* a given date range.
*
- * @author "Matthew Hayes"
- *
*/
public class GenerateIds extends Configured implements NamedTool
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/bags/BagConcat.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/bags/BagConcat.java b/datafu-pig/src/main/java/datafu/pig/bags/BagConcat.java
index 290f44b..48d2334 100644
--- a/datafu-pig/src/main/java/datafu/pig/bags/BagConcat.java
+++ b/datafu-pig/src/main/java/datafu/pig/bags/BagConcat.java
@@ -75,8 +75,6 @@ import org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema;
* }
* </pre>
*
- * @author wvaughan
- *
*/
public class BagConcat extends EvalFunc<DataBag>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/bags/BagGroup.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/bags/BagGroup.java b/datafu-pig/src/main/java/datafu/pig/bags/BagGroup.java
index 386def3..2a5b44d 100644
--- a/datafu-pig/src/main/java/datafu/pig/bags/BagGroup.java
+++ b/datafu-pig/src/main/java/datafu/pig/bags/BagGroup.java
@@ -78,8 +78,6 @@ import datafu.pig.util.AliasableEvalFunc;
* }
* </pre>
*
- * @author wvaughan
- *
*/
public class BagGroup extends AliasableEvalFunc<DataBag>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/bags/BagJoin.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/bags/BagJoin.java b/datafu-pig/src/main/java/datafu/pig/bags/BagJoin.java
index 2214dd4..a076c17 100644
--- a/datafu-pig/src/main/java/datafu/pig/bags/BagJoin.java
+++ b/datafu-pig/src/main/java/datafu/pig/bags/BagJoin.java
@@ -56,8 +56,6 @@ import java.util.*;
* </code>
* </p>
*
- * @author wvaughan
- *
*/
public class BagJoin extends AliasableEvalFunc<DataBag>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/bags/BagLeftOuterJoin.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/bags/BagLeftOuterJoin.java b/datafu-pig/src/main/java/datafu/pig/bags/BagLeftOuterJoin.java
index 501af56..893e284 100644
--- a/datafu-pig/src/main/java/datafu/pig/bags/BagLeftOuterJoin.java
+++ b/datafu-pig/src/main/java/datafu/pig/bags/BagLeftOuterJoin.java
@@ -64,8 +64,6 @@ import datafu.pig.util.AliasableEvalFunc;
* </code>
* </p>
*
- * @author wvaughan
- *
*/
public class BagLeftOuterJoin extends BagJoin
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/hash/lsh/LSHFamily.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/hash/lsh/LSHFamily.java b/datafu-pig/src/main/java/datafu/pig/hash/lsh/LSHFamily.java
index a12dc45..e070306 100644
--- a/datafu-pig/src/main/java/datafu/pig/hash/lsh/LSHFamily.java
+++ b/datafu-pig/src/main/java/datafu/pig/hash/lsh/LSHFamily.java
@@ -30,8 +30,6 @@ import datafu.pig.hash.lsh.interfaces.LSH;
/**
* A family of k locality sensitive hashes. For a given point, k hashes will be computed.
- * @author cstella
- *
*/
public class LSHFamily {
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/hash/lsh/LSHFunc.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/hash/lsh/LSHFunc.java b/datafu-pig/src/main/java/datafu/pig/hash/lsh/LSHFunc.java
index a7ab070..f9663b1 100644
--- a/datafu-pig/src/main/java/datafu/pig/hash/lsh/LSHFunc.java
+++ b/datafu-pig/src/main/java/datafu/pig/hash/lsh/LSHFunc.java
@@ -41,8 +41,6 @@ import datafu.pig.hash.lsh.util.DataTypeUtil;
/**
* The base UDF for locality sensitive hashing.
- * @author cstella
- *
*/
public abstract class LSHFunc extends EvalFunc<DataBag>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/hash/lsh/RepeatingLSH.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/hash/lsh/RepeatingLSH.java b/datafu-pig/src/main/java/datafu/pig/hash/lsh/RepeatingLSH.java
index 7f59e83..adcd694 100644
--- a/datafu-pig/src/main/java/datafu/pig/hash/lsh/RepeatingLSH.java
+++ b/datafu-pig/src/main/java/datafu/pig/hash/lsh/RepeatingLSH.java
@@ -36,8 +36,6 @@ import datafu.pig.hash.lsh.interfaces.LSH;
* range for the hash.
*
*
- * @author cstella
- *
*/
public class RepeatingLSH extends LSH
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/hash/lsh/interfaces/LSH.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/hash/lsh/interfaces/LSH.java b/datafu-pig/src/main/java/datafu/pig/hash/lsh/interfaces/LSH.java
index d7ed82e..1f627bf 100644
--- a/datafu-pig/src/main/java/datafu/pig/hash/lsh/interfaces/LSH.java
+++ b/datafu-pig/src/main/java/datafu/pig/hash/lsh/interfaces/LSH.java
@@ -30,8 +30,6 @@ import org.apache.commons.math.random.RandomGenerator;
* The basic idea is to hash the input items so that similar items are mapped to the same buckets with high probability
* (the number of buckets being much smaller than the universe of possible input items).
* </p>
- * @author cstella
- *
*/
public abstract class LSH
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/hash/lsh/interfaces/LSHCreator.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/hash/lsh/interfaces/LSHCreator.java b/datafu-pig/src/main/java/datafu/pig/hash/lsh/interfaces/LSHCreator.java
index 679f4ef..6cfbbb0 100644
--- a/datafu-pig/src/main/java/datafu/pig/hash/lsh/interfaces/LSHCreator.java
+++ b/datafu-pig/src/main/java/datafu/pig/hash/lsh/interfaces/LSHCreator.java
@@ -32,8 +32,6 @@ import datafu.pig.hash.lsh.RepeatingLSH;
/**
* Create a Locality sensitive hash.
*
- * @author cstella
- *
*/
public abstract class LSHCreator
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/hash/lsh/interfaces/Sampler.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/hash/lsh/interfaces/Sampler.java b/datafu-pig/src/main/java/datafu/pig/hash/lsh/interfaces/Sampler.java
index 1ccb623..0f2534d 100644
--- a/datafu-pig/src/main/java/datafu/pig/hash/lsh/interfaces/Sampler.java
+++ b/datafu-pig/src/main/java/datafu/pig/hash/lsh/interfaces/Sampler.java
@@ -24,8 +24,6 @@ import org.apache.commons.math.random.RandomDataImpl;
/**
* A helper interface to sample from a distribution specified by a RandomDataImpl
- * @author cstella
- *
*/
public interface Sampler {
/**
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/Cosine.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/Cosine.java b/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/Cosine.java
index 565b9f4..07a527d 100644
--- a/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/Cosine.java
+++ b/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/Cosine.java
@@ -30,8 +30,6 @@ import org.apache.commons.math.linear.RealVector;
* which technically does not form a metric, but I'm stretching the definition here.
*
* @see datafu.pig.hash.lsh.CosineDistanceHash CosineDistanceHash for an example
- * @author cstella
- *
*/
public class Cosine extends MetricUDF {
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/L1.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/L1.java b/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/L1.java
index 8c93150..dc310fa 100644
--- a/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/L1.java
+++ b/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/L1.java
@@ -32,8 +32,6 @@ import org.apache.commons.math.linear.RealVector;
* </p>
*
* @see datafu.pig.hash.lsh.L1PStableHash L1PStableHash for an example
- * @author cstella
- *
*/
public class L1 extends MetricUDF {
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/L2.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/L2.java b/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/L2.java
index f7caafd..53b6c2d 100644
--- a/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/L2.java
+++ b/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/L2.java
@@ -31,8 +31,6 @@ import org.apache.commons.math.linear.RealVector;
* </p>
*
* @see datafu.pig.hash.lsh.L2PStableHash L2PStableHash for an example
- * @author cstella
- *
*/
public class L2 extends MetricUDF {
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/MetricUDF.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/MetricUDF.java b/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/MetricUDF.java
index cb6efbb..fc2ee45 100644
--- a/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/MetricUDF.java
+++ b/datafu-pig/src/main/java/datafu/pig/hash/lsh/metric/MetricUDF.java
@@ -41,8 +41,6 @@ import datafu.pig.hash.lsh.util.DataTypeUtil;
* </p>
*
* @see datafu.pig.hash.lsh.CosineDistanceHash
- * @author cstella
- *
*/
public abstract class MetricUDF extends EvalFunc<Tuple>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/hash/lsh/p_stable/AbstractStableDistributionFunction.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/hash/lsh/p_stable/AbstractStableDistributionFunction.java b/datafu-pig/src/main/java/datafu/pig/hash/lsh/p_stable/AbstractStableDistributionFunction.java
index 21b7306..0f5fff2 100644
--- a/datafu-pig/src/main/java/datafu/pig/hash/lsh/p_stable/AbstractStableDistributionFunction.java
+++ b/datafu-pig/src/main/java/datafu/pig/hash/lsh/p_stable/AbstractStableDistributionFunction.java
@@ -57,8 +57,6 @@ import datafu.pig.hash.lsh.interfaces.Sampler;
* Proceedings of the Symposium on Computational Geometry.
* </p>
*
- * @author cstella
- *
*/
public abstract class AbstractStableDistributionFunction extends LSH
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/hash/lsh/p_stable/L1LSH.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/hash/lsh/p_stable/L1LSH.java b/datafu-pig/src/main/java/datafu/pig/hash/lsh/p_stable/L1LSH.java
index 5ac2bfc..5646738 100644
--- a/datafu-pig/src/main/java/datafu/pig/hash/lsh/p_stable/L1LSH.java
+++ b/datafu-pig/src/main/java/datafu/pig/hash/lsh/p_stable/L1LSH.java
@@ -29,8 +29,6 @@ import datafu.pig.hash.lsh.interfaces.Sampler;
* A locality sensitive hash associated with the L1 metric. This uses a 1-stable distribution
* to construct the hash.
*
- * @author cstella
- *
*/
public class L1LSH extends AbstractStableDistributionFunction implements Sampler
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/hash/lsh/p_stable/L2LSH.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/hash/lsh/p_stable/L2LSH.java b/datafu-pig/src/main/java/datafu/pig/hash/lsh/p_stable/L2LSH.java
index 95a487a..a1aa1c7 100644
--- a/datafu-pig/src/main/java/datafu/pig/hash/lsh/p_stable/L2LSH.java
+++ b/datafu-pig/src/main/java/datafu/pig/hash/lsh/p_stable/L2LSH.java
@@ -29,8 +29,6 @@ import datafu.pig.hash.lsh.interfaces.Sampler;
* A locality sensitive hash associated with the L2 metric. This uses a 2-stable distribution
* to construct the hash.
*
- * @author cstella
- */
public class L2LSH extends AbstractStableDistributionFunction implements Sampler {
/**
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/hash/lsh/util/DataTypeUtil.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/hash/lsh/util/DataTypeUtil.java b/datafu-pig/src/main/java/datafu/pig/hash/lsh/util/DataTypeUtil.java
index 6f09941..5f21ba0 100644
--- a/datafu-pig/src/main/java/datafu/pig/hash/lsh/util/DataTypeUtil.java
+++ b/datafu-pig/src/main/java/datafu/pig/hash/lsh/util/DataTypeUtil.java
@@ -32,8 +32,6 @@ import org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema;
/**
* A utility function to translate between pig types and vectors.
- * @author cstella
- *
*/
public enum DataTypeUtil {
INSTANCE;
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/sampling/ReservoirSample.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/sampling/ReservoirSample.java b/datafu-pig/src/main/java/datafu/pig/sampling/ReservoirSample.java
index 48deaad..891cc13 100644
--- a/datafu-pig/src/main/java/datafu/pig/sampling/ReservoirSample.java
+++ b/datafu-pig/src/main/java/datafu/pig/sampling/ReservoirSample.java
@@ -50,8 +50,6 @@ import org.apache.pig.impl.logicalLayer.schema.Schema;
* to compensate for skew.
* </p>
*
- * @author wvaughan
- *
*/
@Nondeterministic
public class ReservoirSample extends AccumulatorEvalFunc<DataBag> implements Algebraic
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/sampling/SampleByKey.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/sampling/SampleByKey.java b/datafu-pig/src/main/java/datafu/pig/sampling/SampleByKey.java
index 9c8cfd7..3ce933e 100644
--- a/datafu-pig/src/main/java/datafu/pig/sampling/SampleByKey.java
+++ b/datafu-pig/src/main/java/datafu/pig/sampling/SampleByKey.java
@@ -61,8 +61,6 @@ import org.apache.pig.data.Tuple;
* }
* </pre>
*
- * @author evion
- */
public class SampleByKey extends FilterFunc
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/sampling/SimpleRandomSample.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/sampling/SimpleRandomSample.java b/datafu-pig/src/main/java/datafu/pig/sampling/SimpleRandomSample.java
index ee2e796..1a17a4a 100644
--- a/datafu-pig/src/main/java/datafu/pig/sampling/SimpleRandomSample.java
+++ b/datafu-pig/src/main/java/datafu/pig/sampling/SimpleRandomSample.java
@@ -96,8 +96,6 @@ import org.apache.pig.impl.logicalLayer.schema.Schema;
* method is deprecated now and will be removed in the next release.
* </p>
*
- * @author ximeng
- *
*/
public class SimpleRandomSample extends AlgebraicEvalFunc<DataBag>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/sampling/SimpleRandomSampleWithReplacementElect.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/sampling/SimpleRandomSampleWithReplacementElect.java b/datafu-pig/src/main/java/datafu/pig/sampling/SimpleRandomSampleWithReplacementElect.java
index a59816a..6ee2b39 100644
--- a/datafu-pig/src/main/java/datafu/pig/sampling/SimpleRandomSampleWithReplacementElect.java
+++ b/datafu-pig/src/main/java/datafu/pig/sampling/SimpleRandomSampleWithReplacementElect.java
@@ -39,8 +39,6 @@ import org.apache.pig.impl.logicalLayer.schema.Schema;
*
* @see SimpleRandomSampleWithReplacementVote
*
- * @author ximeng
- *
*/
public class SimpleRandomSampleWithReplacementElect extends AlgebraicEvalFunc<DataBag>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/sampling/SimpleRandomSampleWithReplacementVote.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/sampling/SimpleRandomSampleWithReplacementVote.java b/datafu-pig/src/main/java/datafu/pig/sampling/SimpleRandomSampleWithReplacementVote.java
index 0ae5950..73990a1 100644
--- a/datafu-pig/src/main/java/datafu/pig/sampling/SimpleRandomSampleWithReplacementVote.java
+++ b/datafu-pig/src/main/java/datafu/pig/sampling/SimpleRandomSampleWithReplacementVote.java
@@ -160,8 +160,6 @@ import com.google.common.primitives.Ints;
* @see SimpleRandomSampleWithReplacementElect
* @see <a href="http://en.wikipedia.org/wiki/Bootstrapping_(statistics)" target="_blank">Boostrapping (Wikipedia)</a>
*
- * @author ximeng
- *
*/
public class SimpleRandomSampleWithReplacementVote extends EvalFunc<DataBag>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/sampling/WeightedReservoirSample.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/sampling/WeightedReservoirSample.java b/datafu-pig/src/main/java/datafu/pig/sampling/WeightedReservoirSample.java
index a5d265c..d169277 100644
--- a/datafu-pig/src/main/java/datafu/pig/sampling/WeightedReservoirSample.java
+++ b/datafu-pig/src/main/java/datafu/pig/sampling/WeightedReservoirSample.java
@@ -59,8 +59,6 @@ import org.apache.pig.backend.executionengine.ExecException;
* sampled = FOREACH input_g GENERATE WeightedSample(input);
* }
* </pre>
- * @author wjian
- */
@Nondeterministic
public class WeightedReservoirSample extends ReservoirSample {
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/sets/SetDifference.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/sets/SetDifference.java b/datafu-pig/src/main/java/datafu/pig/sets/SetDifference.java
index afd3913..34eebe5 100644
--- a/datafu-pig/src/main/java/datafu/pig/sets/SetDifference.java
+++ b/datafu-pig/src/main/java/datafu/pig/sets/SetDifference.java
@@ -196,8 +196,6 @@ public class SetDifference extends SetOperationsBase
* This is compared first on the data, then on the index the bag came from
* in the input tuple.
* </p>
- * @author mhayes
- *
*/
private static class Pair implements Comparable<Pair>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/stats/HyperLogLogPlusPlus.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/stats/HyperLogLogPlusPlus.java b/datafu-pig/src/main/java/datafu/pig/stats/HyperLogLogPlusPlus.java
index 0ebd94f..95c5b0e 100644
--- a/datafu-pig/src/main/java/datafu/pig/stats/HyperLogLogPlusPlus.java
+++ b/datafu-pig/src/main/java/datafu/pig/stats/HyperLogLogPlusPlus.java
@@ -41,8 +41,6 @@ import org.apache.pig.impl.logicalLayer.schema.Schema;
* This is a streaming implementation, and therefore the input data does not need to be sorted.
* </p>
*
- * @author mhayes
- *
*/
public class HyperLogLogPlusPlus extends AccumulatorEvalFunc<Long>
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/util/AliasableEvalFunc.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/util/AliasableEvalFunc.java b/datafu-pig/src/main/java/datafu/pig/util/AliasableEvalFunc.java
index 3dd4829..c14df2c 100644
--- a/datafu-pig/src/main/java/datafu/pig/util/AliasableEvalFunc.java
+++ b/datafu-pig/src/main/java/datafu/pig/util/AliasableEvalFunc.java
@@ -73,8 +73,6 @@ import org.apache.pig.impl.logicalLayer.schema.Schema;
* }
* </pre>
*
- * @author wvaughan
- *
* @param <T> type that the eval func returns
*/
public abstract class AliasableEvalFunc<T> extends ContextualEvalFunc<T>
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/util/FieldNotFound.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/util/FieldNotFound.java b/datafu-pig/src/main/java/datafu/pig/util/FieldNotFound.java
index d624007..74f8d35 100644
--- a/datafu-pig/src/main/java/datafu/pig/util/FieldNotFound.java
+++ b/datafu-pig/src/main/java/datafu/pig/util/FieldNotFound.java
@@ -24,8 +24,6 @@ import org.apache.pig.backend.executionengine.ExecException;
/**
* Thrown by {see AliasableEvalFunc} when attempting to access an unknown field by name.
*
- * @author wvaughan
- *
*/
public class FieldNotFound extends ExecException
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/main/java/datafu/pig/util/InUDF.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/main/java/datafu/pig/util/InUDF.java b/datafu-pig/src/main/java/datafu/pig/util/InUDF.java
index 08d81af..ad5423c 100644
--- a/datafu-pig/src/main/java/datafu/pig/util/InUDF.java
+++ b/datafu-pig/src/main/java/datafu/pig/util/InUDF.java
@@ -42,8 +42,6 @@ import org.apache.pig.data.Tuple;
* }
* </pre>
*
- * @author wvaughan
- */
public class InUDF extends FilterFunc
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/test/java/datafu/test/pig/sampling/SimpleRandomSampleTest.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/test/java/datafu/test/pig/sampling/SimpleRandomSampleTest.java b/datafu-pig/src/test/java/datafu/test/pig/sampling/SimpleRandomSampleTest.java
index 41d9c02..d53b031 100644
--- a/datafu-pig/src/test/java/datafu/test/pig/sampling/SimpleRandomSampleTest.java
+++ b/datafu-pig/src/test/java/datafu/test/pig/sampling/SimpleRandomSampleTest.java
@@ -29,8 +29,6 @@ import datafu.test.pig.PigTests;
/**
* Tests for {@link SimpleRandomSample}.
*
- * @author ximeng
- *
*/
public class SimpleRandomSampleTest extends PigTests
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/test/java/datafu/test/pig/sampling/SimpleRandomSampleTestOld.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/test/java/datafu/test/pig/sampling/SimpleRandomSampleTestOld.java b/datafu-pig/src/test/java/datafu/test/pig/sampling/SimpleRandomSampleTestOld.java
index 20f5984..ebeace6 100644
--- a/datafu-pig/src/test/java/datafu/test/pig/sampling/SimpleRandomSampleTestOld.java
+++ b/datafu-pig/src/test/java/datafu/test/pig/sampling/SimpleRandomSampleTestOld.java
@@ -31,8 +31,6 @@ import datafu.test.pig.PigTests;
*
* @deprecated This tests the deprecated functionality of SimpleRandomSample
* where the probability can be specified in the constructor.
- * @author ximeng
- *
*/
public class SimpleRandomSampleTestOld extends PigTests
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/test/java/datafu/test/pig/sampling/SimpleRandomSampleWithReplacementTest.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/test/java/datafu/test/pig/sampling/SimpleRandomSampleWithReplacementTest.java b/datafu-pig/src/test/java/datafu/test/pig/sampling/SimpleRandomSampleWithReplacementTest.java
index 4132203..889fdc8 100644
--- a/datafu-pig/src/test/java/datafu/test/pig/sampling/SimpleRandomSampleWithReplacementTest.java
+++ b/datafu-pig/src/test/java/datafu/test/pig/sampling/SimpleRandomSampleWithReplacementTest.java
@@ -31,8 +31,6 @@ import datafu.test.pig.PigTests;
* Tests for {@link SimpleRandomSampleWithReplacementVote} and
* {@link SimpleRandomSampleWithReplacementElect}.
*
- * @author ximeng
- *
*/
public class SimpleRandomSampleWithReplacementTest extends PigTests
{
http://git-wip-us.apache.org/repos/asf/incubator-datafu/blob/966da2f3/datafu-pig/src/test/java/datafu/test/pig/sampling/WeightedReservoirSamplingTests.java
----------------------------------------------------------------------
diff --git a/datafu-pig/src/test/java/datafu/test/pig/sampling/WeightedReservoirSamplingTests.java b/datafu-pig/src/test/java/datafu/test/pig/sampling/WeightedReservoirSamplingTests.java
index 7511324..e0b3aac 100644
--- a/datafu-pig/src/test/java/datafu/test/pig/sampling/WeightedReservoirSamplingTests.java
+++ b/datafu-pig/src/test/java/datafu/test/pig/sampling/WeightedReservoirSamplingTests.java
@@ -39,8 +39,6 @@ import datafu.test.pig.PigTests;
/**
* Tests for {@link WeightedReservoirSample}.
*
- * @author wjian
- *
*/
public class WeightedReservoirSamplingTests extends PigTests
{
|