Review Board 1.7.22


SQOOP-671. Mapreduce counters are not used in generated mapreduce jobs

Review Request #7978 - Created Nov. 8, 2012 and submitted

Hari Shreedharan
sqoop2
SQOOP-671
Reviewers
Sqoop
sqoop-sqoop2
Added MR counters support for bytes written and for rows read.

 
common/src/main/java/org/apache/sqoop/submission/counter/SqoopCounters.java
New File

    
   
1
/*

    
   
2
 * Licensed to the Apache Software Foundation (ASF) under one

    
   
3
 * or more contributor license agreements.  See the NOTICE file

    
   
4
 * distributed with this work for additional information

    
   
5
 * regarding copyright ownership.  The ASF licenses this file

    
   
6
 * to you under the Apache License, Version 2.0 (the

    
   
7
 * "License"); you may not use this file except in compliance

    
   
8
 * with the License.  You may obtain a copy of the License at

    
   
9
 *

    
   
10
 *     http://www.apache.org/licenses/LICENSE-2.0

    
   
11
 *

    
   
12
 * Unless required by applicable law or agreed to in writing, software

    
   
13
 * distributed under the License is distributed on an "AS IS" BASIS,

    
   
14
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

    
   
15
 * See the License for the specific language governing permissions and

    
   
16
 * limitations under the License.

    
   
17
 */

    
   
18
package org.apache.sqoop.submission.counter;

    
   
19

   

    
   
20
/**

    
   
21
 *

    
   
22
 */

    
   
23
public enum SqoopCounters {

    
   
24
  ROWS_READ;

    
   
25
}
connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportExtractor.java
Revision 1b3fcff New Change
 
execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopMapper.java
Revision 1c0f3aa New Change
 
execution/mapreduce/src/test/java/org/apache/sqoop/job/TestHdfsLoad.java
Revision 875a123 New Change
 
execution/mapreduce/src/test/java/org/apache/sqoop/job/TestMapReduce.java
Revision 6e49cc2 New Change
 
spi/src/main/java/org/apache/sqoop/job/etl/Extractor.java
Revision ba04be9 New Change
 
  1. common/src/main/java/org/apache/sqoop/submission/counter/SqoopCounters.java: Loading...
  2. connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportExtractor.java: Loading...
  3. execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopMapper.java: Loading...
  4. execution/mapreduce/src/test/java/org/apache/sqoop/job/TestHdfsLoad.java: Loading...
  5. execution/mapreduce/src/test/java/org/apache/sqoop/job/TestMapReduce.java: Loading...
  6. spi/src/main/java/org/apache/sqoop/job/etl/Extractor.java: Loading...