Sqoop 1.4.4 とその Java API を使用してインポート ジョブを実行していますが、インポートの完了後にジョブ カウンターにアクセスする方法がわかりません。ConfigurationHelper クラスに getNumMapOutputRecords などの適切なメソッドがありますが、それらにジョブを渡す方法がわかりません。
SqoopTool または Sqoop オブジェクトからジョブを取得する方法はありますか?
私のコードは次のようになります。
SqoopTool sqoopTool = new ImportTool();
SqoopOptions options = new SqoopOptions();
options.setConnectString(connectString);
options.setUsername(username);
options.setPassword(password);
options.setTableName(table);
options.setColumns(columns);
options.setWhereClause(whereClause);
options.setTargetDir(targetDir);
options.setNumMappers(1);
options.setFileLayout(FileLayout.TextFile);
options.setFieldsTerminatedBy(delimiter);
Configuration config = new Configuration();
config.set("oracle.sessionTimeZone", timezone.getID());
System.setProperty(Sqoop.SQOOP_RETHROW_PROPERTY, "1");
Sqoop sqoop = new Sqoop(sqoopTool, config, options);
String[] nullArgs = new String[0];
Sqoop.runSqoop(sqoop, nullArgs);