Review Board 1.7.22


SQOOP-971 Add dynamic reconfiguration ability to RepositoryManager, ConnectorManager and FrameworkManager

Review Request #11920 - Created June 17, 2013 and submitted

Mengwei Ding
SQOOP-971
Reviewers
Sqoop
abe, hshreedharan, jarcec
sqoop-sqoop2
commit 8f40d46cf416979271058a21d45c328710608624
Author: Jarek Jarcec Cecho <jarcec@apache.org>
Date:   Thu Jun 20 15:02:56 2013 -0700

    SQOOP-971 Add dynamic reconfiguration ability to RepositoryManager, ConnectorManager and FrameworkManager

:100644 100644 500189a... 0540f6b... M	core/src/main/java/org/apache/sqoop/connector/ConnectorManager.java
:100644 100644 f59d132... eb7c1dc... M	core/src/main/java/org/apache/sqoop/core/CoreError.java
:000000 100644 0000000... d25ce41... A	core/src/main/java/org/apache/sqoop/core/Reconfigurable.java
:100644 100644 deb24c9... 13bbfc2... M	core/src/main/java/org/apache/sqoop/core/SqoopConfiguration.java
:100644 100644 84896d6... 90bb327... M	core/src/main/java/org/apache/sqoop/core/SqoopServer.java
:100644 100644 145a2c1... a81306b... M	core/src/main/java/org/apache/sqoop/framework/FrameworkManager.java
:000000 100644 0000000... 9e90cac... A	core/src/main/java/org/apache/sqoop/framework/JobManager.java
:100644 100644 3339c59... e709975... M	core/src/main/java/org/apache/sqoop/repository/JdbcRepositoryProvider.java
:100644 100644 955306d... d35b080... M	core/src/main/java/org/apache/sqoop/repository/RepositoryManager.java
:100644 100644 4ea52e9... 1ec6bdf... M	core/src/main/java/org/apache/sqoop/repository/RepositoryProvider.java
:100644 100644 de9a24b... b61a6d6... M	server/src/main/java/org/apache/sqoop/handler/SubmissionRequestHandler.java

 
core/src/main/java/org/apache/sqoop/connector/ConnectorManager.java
Revision 500189a New Change
[20] 30 lines
[+20]
31

    
   
31

   
32
import org.apache.log4j.Logger;
32
import org.apache.log4j.Logger;
33
import org.apache.sqoop.common.SqoopException;
33
import org.apache.sqoop.common.SqoopException;
34
import org.apache.sqoop.connector.spi.SqoopConnector;
34
import org.apache.sqoop.connector.spi.SqoopConnector;
35
import org.apache.sqoop.core.ConfigurationConstants;
35
import org.apache.sqoop.core.ConfigurationConstants;

    
   
36
import org.apache.sqoop.core.ConfigurationListener;

    
   
37
import org.apache.sqoop.core.Reconfigurable;

    
   
38
import org.apache.sqoop.framework.FrameworkManager;
36
import org.apache.sqoop.repository.Repository;
39
import org.apache.sqoop.repository.Repository;
37
import org.apache.sqoop.repository.RepositoryManager;
40
import org.apache.sqoop.repository.RepositoryManager;
38
import org.apache.sqoop.repository.RepositoryTransaction;
41
import org.apache.sqoop.repository.RepositoryTransaction;
39
import org.apache.sqoop.model.MConnector;
42
import org.apache.sqoop.model.MConnector;
40

    
   
43

   
41
public class ConnectorManager {
44
public class ConnectorManager implements Reconfigurable {
42

    
   
45

   
43
  /**
46
  /**
44
   * Logger object.
47
   * Logger object.
45
   */
48
   */
46
  private static final Logger LOG = Logger.getLogger(ConnectorManager.class);
49
  private static final Logger LOG = Logger.getLogger(ConnectorManager.class);
[+20] [20] 182 lines
[+20] [+] private synchronized void registerConnectors() {
229

    
   
232

   
230
  public synchronized void destroy() {
233
  public synchronized void destroy() {
231
      handlerMap = null;
234
      handlerMap = null;
232
      nameMap = null;
235
      nameMap = null;
233
  }
236
  }

    
   
237

   

    
   
238
  @Override

    
   
239
  public synchronized void refreshConfiguration() {

    
   
240
    LOG.info("Begin connector manager reconfiguring");

    
   
241
    // If there are configuration options for ConnectorManager,

    
   
242
    // implement the reconfiguration procedure right here.

    
   
243
    LOG.info("Connector manager reconfigured");

    
   
244
  }

    
   
245

   
234
}
246
}
core/src/main/java/org/apache/sqoop/core/CoreError.java
Revision f59d132 New Change
 
core/src/main/java/org/apache/sqoop/core/Reconfigurable.java
New File
 
core/src/main/java/org/apache/sqoop/core/SqoopConfiguration.java
Revision deb24c9 New Change
 
core/src/main/java/org/apache/sqoop/framework/FrameworkManager.java
Revision 145a2c1 New Change
 
core/src/main/java/org/apache/sqoop/repository/JdbcRepositoryProvider.java
Revision 3339c59 New Change
 
core/src/main/java/org/apache/sqoop/repository/RepositoryManager.java
Revision 955306d New Change
 
core/src/main/java/org/apache/sqoop/repository/RepositoryProvider.java
Revision 4ea52e9 New Change
 
server/src/main/java/org/apache/sqoop/handler/SubmissionRequestHandler.java
Revision de9a24b New Change
 
  1. core/src/main/java/org/apache/sqoop/connector/ConnectorManager.java: Loading...
  2. core/src/main/java/org/apache/sqoop/core/CoreError.java: Loading...
  3. core/src/main/java/org/apache/sqoop/core/Reconfigurable.java: Loading...
  4. core/src/main/java/org/apache/sqoop/core/SqoopConfiguration.java: Loading...
  5. core/src/main/java/org/apache/sqoop/framework/FrameworkManager.java: Loading...
  6. core/src/main/java/org/apache/sqoop/repository/JdbcRepositoryProvider.java: Loading...
  7. core/src/main/java/org/apache/sqoop/repository/RepositoryManager.java: Loading...
  8. core/src/main/java/org/apache/sqoop/repository/RepositoryProvider.java: Loading...
  9. server/src/main/java/org/apache/sqoop/handler/SubmissionRequestHandler.java: Loading...