import com.cloudera.sqoop.SqoopOptions.UpdateMode; //导入依赖的package包/类
private void exportTable(SqoopOptions options, String tableName)
    throws ExportException, IOException {
  String jarFile = null;

  // Generate the ORM code for the tables.
  jarFile = codeGenerator.generateORM(options, tableName);

  ExportJobContext context = new ExportJobContext(tableName, jarFile,
      options);
  if (options.getUpdateKeyCol() != null) {
    if (options.getUpdateMode() == UpdateMode.UpdateOnly) {
      // UPDATE-based export.
      manager.updateTable(context);
    } else {
      // Mixed update/insert export
      manager.upsertTable(context);
    }
  } else if (options.getCall() != null) {
    // Stored procedure-based export.
      manager.callTable(context);
  } else {
    // INSERT-based export.
    manager.exportTable(context);
  }
}
 

import com.cloudera.sqoop.SqoopOptions.UpdateMode; //导入依赖的package包/类
private void exportTable(SqoopOptions options, String tableName)
    throws ExportException, IOException {
  String jarFile = null;

  // Generate the ORM code for the tables.
  jarFile = codeGenerator.generateORM(options, tableName);

  ExportJobContext context = new ExportJobContext(tableName, jarFile,
      options);
  if (options.getUpdateKeyCol() != null) {
    if (options.getUpdateMode() == UpdateMode.UpdateOnly) {
      // UPDATE-based export.
      manager.updateTable(context);
    } else {
      // Mixed update/insert export
      manager.upsertTable(context);
    }
  } else {
    // INSERT-based export.
    manager.exportTable(context);
  }
}
 

import com.cloudera.sqoop.SqoopOptions.UpdateMode; //导入依赖的package包/类
private void applyNewUpdateOptions(CommandLine in, SqoopOptions out)
    throws InvalidOptionsException {
  if (in.hasOption(UPDATE_MODE_ARG)) {
    String updateTypeStr = in.getOptionValue(UPDATE_MODE_ARG);
    if ("updateonly".equals(updateTypeStr)) {
      out.setUpdateMode(UpdateMode.UpdateOnly);
    } else if ("allowinsert".equals(updateTypeStr)) {
      out.setUpdateMode(UpdateMode.AllowInsert);
    } else {
      throw new InvalidOptionsException("Unknown new update mode: "
          + updateTypeStr + ". Use 'updateonly' or 'allowinsert'."
          + HELP_STR);
    }
  }
}
 

import com.cloudera.sqoop.SqoopOptions.UpdateMode; //导入依赖的package包/类
/**
 * @return how to handle new rows found in update export.
 */
public UpdateMode getUpdateMode() {
  return updateMode;
}
 

import com.cloudera.sqoop.SqoopOptions.UpdateMode; //导入依赖的package包/类
private void initDefaults(Configuration baseConfiguration) {
	// first, set the true defaults if nothing else happens.
	// default action is to run the full pipeline.
	this.hadoopMapRedHome = System.getenv("HADOOP_MAPRED_HOME");

	this.hiveHome = getHiveHomeDefault();
	this.hCatHome = getHCatHomeDefault();

	this.inputDelimiters = new DelimiterSet(
			DelimiterSet.NULL_CHAR, DelimiterSet.NULL_CHAR,
			DelimiterSet.NULL_CHAR, DelimiterSet.NULL_CHAR, false);
	this.outputDelimiters = new DelimiterSet();

	// Set this to cwd, but -Dsqoop.src.dir can override.
	this.codeOutputDir = System.getProperty("sqoop.src.dir", ".");

	String myTmpDir = System.getProperty("test.build.data", "/tmp/");
	if (!myTmpDir.endsWith(File.separator)) {
		myTmpDir = myTmpDir + File.separator;
	}

	this.tmpDir = myTmpDir;
	String localUsername = System.getProperty("user.name", "unknown");
	this.jarOutputDir = getNonceJarDir(tmpDir + "sqoop-" + localUsername
			+ "/compile");
	this.jarDirIsAuto = true;
	this.layout = FileLayout.TextFile;

	this.areOutputDelimsManuallySet = false;
	this.areInputDelimsManuallySet = false;

	this.numMappers = DEFAULT_NUM_MAPPERS;
	this.useCompression = false;
	this.compressionCodec = null;
	this.directSplitSize = 0;

	this.maxInlineLobSize = LargeObjectLoader.DEFAULT_MAX_LOB_LENGTH;

	// Don't set a default value for fetchsize. This allows a JDBCManager to
	// provide a database-specific default, if no value is provided by the
	// user.
	this.fetchSize = null;

	if (null == baseConfiguration) {
		this.conf = new Configuration();
	} else {
		this.conf = baseConfiguration;
	}

	this.extraArgs = null;

	this.dbOutColumns = null;

	this.incrementalMode = IncrementalMode.None;

	this.updateMode = UpdateMode.UpdateOnly;

	// Creating instances for user specific mapping
	this.mapColumnHive = new Properties();
	this.mapColumnJava = new Properties();

	// We do not want to be verbose too much if not explicitly needed
	this.verbose = false;
	this.isValidationEnabled = false; // validation is disabled by default
	this.validatorClass = RowCountValidator.class;
	this.validationThresholdClass = AbsoluteValidationThreshold.class;
	this.validationFailureHandlerClass = AbortOnFailureHandler.class;
}
 

import com.cloudera.sqoop.SqoopOptions.UpdateMode; //导入依赖的package包/类
/**
 * @return how to handle new rows found in update export.
 */
public UpdateMode getUpdateMode() {
	return updateMode;
}
 

import com.cloudera.sqoop.SqoopOptions.UpdateMode; //导入依赖的package包/类
private void initDefaults(Configuration baseConfiguration) {
  // first, set the true defaults if nothing else happens.
  // default action is to run the full pipeline.
  this.hadoopHome = System.getenv("HADOOP_HOME");

  // Set this with $HIVE_HOME, but -Dhive.home can override.
  this.hiveHome = System.getenv("HIVE_HOME");
  this.hiveHome = System.getProperty("hive.home", this.hiveHome);

  this.inputDelimiters = new DelimiterSet(
      DelimiterSet.NULL_CHAR, DelimiterSet.NULL_CHAR,
      DelimiterSet.NULL_CHAR, DelimiterSet.NULL_CHAR, false);
  this.outputDelimiters = new DelimiterSet();

  // Set this to cwd, but -Dsqoop.src.dir can override.
  this.codeOutputDir = System.getProperty("sqoop.src.dir", ".");

  String myTmpDir = System.getProperty("test.build.data", "/tmp/");
  if (!myTmpDir.endsWith(File.separator)) {
    myTmpDir = myTmpDir + File.separator;
  }

  this.tmpDir = myTmpDir;
  String localUsername = System.getProperty("user.name", "unknown");
  this.jarOutputDir = getNonceJarDir(tmpDir + "sqoop-" + localUsername
      + "/compile");
  this.jarDirIsAuto = true;
  this.layout = FileLayout.TextFile;

  this.areDelimsManuallySet = false;

  this.numMappers = DEFAULT_NUM_MAPPERS;
  this.useCompression = false;
  this.compressionCodec = null;
  this.directSplitSize = 0;

  this.maxInlineLobSize = LargeObjectLoader.DEFAULT_MAX_LOB_LENGTH;

  // Don't set a default value for fetchsize. This allows a JDBCManager to
  // provide a database-specific default, if no value is provided by the
  // user.
  this.fetchSize = null;

  if (null == baseConfiguration) {
    this.conf = new Configuration();
  } else {
    this.conf = baseConfiguration;
  }

  this.extraArgs = null;

  this.dbOutColumns = null;

  this.incrementalMode = IncrementalMode.None;

  this.updateMode = UpdateMode.UpdateOnly;

  // Creating instances for user specific mapping
  this.mapColumnHive = new Properties();
  this.mapColumnJava = new Properties();

  // We do not want to be verbose too much if not explicitly needed
  this.verbose = false;
}
 

import com.cloudera.sqoop.SqoopOptions.UpdateMode; //导入依赖的package包/类
/**
 * Set "UpdateOnly" to silently ignore new rows during update export.
 * Set "AllowInsert" to insert new rows during update export.
 */
public void setUpdateMode(UpdateMode mode) {
  this.updateMode = mode;
}
 

import com.cloudera.sqoop.SqoopOptions.UpdateMode; //导入依赖的package包/类
/**
 * Set "UpdateOnly" to silently ignore new rows during update export.
 * Set "AllowInsert" to insert new rows during update export.
 */
public void setUpdateMode(UpdateMode mode) {
	this.updateMode = mode;
}