Repository: incubator-gobblin Updated Branches: refs/heads/master 29d403aec -> 648c2a2ab
[GOBBLIN-585] Return expectedRecordCount of 1 for FileAwareInputStreamExtractor Closes #2451 from htran1/FileAwareInputStreamExtra ctor_expected_record_count Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/648c2a2a Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/648c2a2a Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/648c2a2a Branch: refs/heads/master Commit: 648c2a2abd6fa006552d3f354dedd17011480668 Parents: 29d403a Author: Hung Tran <[email protected]> Authored: Wed Sep 12 13:04:12 2018 -0700 Committer: Hung Tran <[email protected]> Committed: Wed Sep 12 13:04:12 2018 -0700 ---------------------------------------------------------------------- .../copy/extractor/FileAwareInputStreamExtractor.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/648c2a2a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/extractor/FileAwareInputStreamExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/extractor/FileAwareInputStreamExtractor.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/extractor/FileAwareInputStreamExtractor.java index 406c828..4b212bf 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/extractor/FileAwareInputStreamExtractor.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/extractor/FileAwareInputStreamExtractor.java @@ -90,9 +90,12 @@ public class FileAwareInputStreamExtractor implements Extractor<String, FileAwar return null; } + /** + * Each {@link FileAwareInputStreamExtractor} processes exactly one record. + */ @Override public long getExpectedRecordCount() { - return 0; + return 1; } @Override
