[
https://issues.apache.org/jira/browse/SQOOP-1929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14256496#comment-14256496
]
Hudson commented on SQOOP-1929:
-------------------------------
SUCCESS: Integrated in Sqoop2-hadoop200 #676 (See
[https://builds.apache.org/job/Sqoop2-hadoop200/676/])
SQOOP-1929: Sqoop2: Track number of records written in Loader (abe:
https://git-wip-us.apache.org/repos/asf?p=sqoop.git&a=commit&h=7f53eb22e348ef1b9171eedb45063e552ce0281d)
* execution/mapreduce/src/test/java/org/apache/sqoop/job/TestMapReduce.java
*
execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopOutputFormatLoadExecutor.java
*
connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/KafkaLoader.java
*
connector/connector-hdfs/src/main/java/org/apache/sqoop/connector/hdfs/HdfsLoader.java
*
connector/connector-hdfs/src/main/java/org/apache/sqoop/connector/hdfs/HdfsExtractor.java
*
connector/connector-kite/src/main/java/org/apache/sqoop/connector/kite/KiteLoader.java
* common/src/main/java/org/apache/sqoop/submission/counter/SqoopCounters.java
* spi/src/main/java/org/apache/sqoop/job/etl/Loader.java
*
execution/mapreduce/src/test/java/org/apache/sqoop/job/mr/TestSqoopOutputFormatLoadExecutor.java
* execution/mapreduce/pom.xml
*
connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcLoader.java
> Sqoop2: Track number of records written in Loader
> -------------------------------------------------
>
> Key: SQOOP-1929
> URL: https://issues.apache.org/jira/browse/SQOOP-1929
> Project: Sqoop
> Issue Type: Bug
> Reporter: Veena Basavaraj
> Assignee: Veena Basavaraj
> Fix For: 1.99.5
>
> Attachments: SQOOP-1929-v1.patch, SQOOP-1929-v3.patch
>
>
> Mirror the functionality in Extractor that has API for rows read. It will be
> a new counter.
> {code}
> /**
> * Return the number of rows read by the last call to
> * {@linkplain Extractor#extract(org.apache.sqoop.job.etl.ExtractorContext,
> java.lang.Object, java.lang.Object, Partition) }
> * method. This method returns only the number of rows read in the last
> call,
> * and not a cumulative total of the number of rows read by this Extractor
> * since its creation. If no calls were made to the run method, this
> method's
> * behavior is undefined.
> *
> * @return the number of rows read by the last call to
> * {@linkplain Extractor#extract(org.apache.sqoop.job.etl.ExtractorContext,
> java.lang.Object, java.lang.Object, Partition) }
> */
> public abstract long getRowsRead();
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
