Repository: crunch Updated Branches: refs/heads/master d0fefe729 -> b559e0e58
CRUNCH-378: Fixed javadoc and added doc to another method. Project: http://git-wip-us.apache.org/repos/asf/crunch/repo Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/b559e0e5 Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/b559e0e5 Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/b559e0e5 Branch: refs/heads/master Commit: b559e0e5840ae7f17a831270ed9c9e711cf8bae7 Parents: d0fefe7 Author: Micah Whitacre <[email protected]> Authored: Tue Apr 15 15:09:14 2014 -0500 Committer: Micah Whitacre <[email protected]> Committed: Tue Apr 15 15:09:14 2014 -0500 ---------------------------------------------------------------------- crunch-core/src/main/java/org/apache/crunch/Target.java | 2 ++ .../org/apache/crunch/impl/dist/collect/PCollectionImpl.java | 7 ++++++- 2 files changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/crunch/blob/b559e0e5/crunch-core/src/main/java/org/apache/crunch/Target.java ---------------------------------------------------------------------- diff --git a/crunch-core/src/main/java/org/apache/crunch/Target.java b/crunch-core/src/main/java/org/apache/crunch/Target.java index 112c637..03b6eef 100644 --- a/crunch-core/src/main/java/org/apache/crunch/Target.java +++ b/crunch-core/src/main/java/org/apache/crunch/Target.java @@ -71,6 +71,8 @@ public interface Target { * Apply the given {@code WriteMode} to this {@code Target} instance. * * @param writeMode The strategy for handling existing outputs + * @param lastModifiedAt the time of the most recent modification to one of the source inputs for handling based + * on the provided {@code writeMode}. * @param conf The ever-useful {@code Configuration} instance * @return true if the target did exist */ http://git-wip-us.apache.org/repos/asf/crunch/blob/b559e0e5/crunch-core/src/main/java/org/apache/crunch/impl/dist/collect/PCollectionImpl.java ---------------------------------------------------------------------- diff --git a/crunch-core/src/main/java/org/apache/crunch/impl/dist/collect/PCollectionImpl.java b/crunch-core/src/main/java/org/apache/crunch/impl/dist/collect/PCollectionImpl.java index ee820f0..cb9c60c 100644 --- a/crunch-core/src/main/java/org/apache/crunch/impl/dist/collect/PCollectionImpl.java +++ b/crunch-core/src/main/java/org/apache/crunch/impl/dist/collect/PCollectionImpl.java @@ -318,7 +318,12 @@ public abstract class PCollectionImpl<S> implements PCollection<S> { } protected abstract long getSizeInternal(); - + + /** + * The time of the most recent modification to one of the input sources to the collection. If the time can + * not be determined then {@code -1} should be returned. + * @return time of the most recent modification to one of the input sources to the collection. + */ public abstract long getLastModifiedAt(); /**
