in odps-sqoop/src/java/org/apache/sqoop/tool/BaseSqoopTool.java [1422:1498]
protected void applyOdpsOptions(CommandLine in, SqoopOptions out) {
if (in.hasOption(ODPS_TABLE_ARG)) {
out.setOdpsTable(in.getOptionValue(ODPS_TABLE_ARG));
}
if (in.hasOption(ODPS_PROJECT_ARG)) {
out.setOdpsProject(in.getOptionValue(ODPS_PROJECT_ARG));
}
if (in.hasOption(ODPS_ACCESS_ID_ARG)) {
out.setOdpsAccessID(in.getOptionValue(ODPS_ACCESS_ID_ARG));
}
if (in.hasOption(ODPS_ACCESS_KEY_ARG)) {
out.setOdpsAccessKey(in.getOptionValue(ODPS_ACCESS_KEY_ARG));
}
if (in.hasOption(ODPS_ENDPOINT_ARG)) {
out.setOdpsEndPoint(in.getOptionValue(ODPS_ENDPOINT_ARG));
}
if (in.hasOption(ODPS_DATAHUB_ENDPOINT_ARG)) {
out.setOdpsDatahubEndPoint(in.getOptionValue(ODPS_DATAHUB_ENDPOINT_ARG));
}
if (in.hasOption(ODPS_TUNNEL_ENDPOINT_ARG)) {
out.setOdpsTunnelEndPoint(in.getOptionValue(ODPS_TUNNEL_ENDPOINT_ARG));
}
if (in.hasOption(ODPS_PARTITION_KEY_ARG)) {
out.setOdpsPartitionKey(in.getOptionValue(ODPS_PARTITION_KEY_ARG));
}
if (in.hasOption(ODPS_PARTITION_VALUE_ARG)) {
out.setOdpsPartitionValue(in.getOptionValue(ODPS_PARTITION_VALUE_ARG));
}
if (in.hasOption(ODPS_CREATE_TABLE_ARG)) {
out.setOdpsCreateTable(true);
}
if (in.hasOption(ODPS_DISABLE_DYNAMIC_PARTITIONS)) {
out.setOdpsDisableDynamicPartitions(true);
}
if (in.hasOption(HDFS_TO_ODPS)) {
out.setHdfsToOdps(true);
}
if (in.hasOption(ODPS_DATEFORMAT_ARG)) {
out.setOdpsInputDateFormat(in.getOptionValue(ODPS_DATEFORMAT_ARG));
}
if (in.hasOption(ODPS_SHARDNUM_ARG)) {
out.setOdpsShardNum(Integer.parseInt(in.getOptionValue(ODPS_SHARDNUM_ARG)));
}
if (in.hasOption(ODPS_SHARDTIMEOUT_ARG)) {
out.setOdpsShardTimeout(Integer.parseInt(in.getOptionValue(ODPS_SHARDTIMEOUT_ARG)));
}
if (in.hasOption(ODPS_RETRY_COUNT_ARG)) {
out.setOdpsRetryCount(Integer.parseInt(in.getOptionValue(ODPS_RETRY_COUNT_ARG)));
}
if (in.hasOption(ODPS_BATCH_SIZE_ARG)) {
out.setOdpsBatchSize(Integer.parseInt(in.getOptionValue(ODPS_BATCH_SIZE_ARG)));
}
if (in.hasOption(ODPS_HUBLIFECYCLE)) {
out.setOdpsHubLifeCycle(Integer.parseInt(in.getOptionValue(ODPS_HUBLIFECYCLE)));
}
if (in.hasOption(MAP_COLUMN_ODPS)) {
out.setMapColumnOdps(in.getOptionValue(MAP_COLUMN_ODPS));
}
if (in.hasOption(ODPS_PARTITION_SPEC_ARG)) {
out.setOdpsPartitionSpec(in.getOptionValue(ODPS_PARTITION_SPEC_ARG));
}
if (in.hasOption(ODPS_OVERWRITE_ARG)) {
out.setOverwriteOdpsTable(true);
}
if (in.hasOption(ODPS_USE_COMPRESS)) {
out.setOdpsUseCompressInUpload(true);
}
}