You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by hu...@apache.org on 2018/09/12 20:04:17 UTC
incubator-gobblin git commit: [GOBBLIN-585] Return
expectedRecordCount of 1 for FileAwareInputStreamExtractor
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 <hu...@linkedin.com>
Authored: Wed Sep 12 13:04:12 2018 -0700
Committer: Hung Tran <hu...@linkedin.com>
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