in c3r-cli/src/main/java/com/amazonaws/c3r/cli/DecryptMode.java [195:226]
public Integer call() {
try {
validate();
final DecryptConfig cfg = getConfig();
if (!optionalArgs.dryRun) {
log.info("Decrypting data from {}.", cfg.getSourceFile());
switch (cfg.getFileFormat()) {
case CSV:
final RowUnmarshaller<CsvValue> csvValueRowUnmarshaller = CsvRowUnmarshaller.newInstance(cfg);
csvValueRowUnmarshaller.unmarshal();
csvValueRowUnmarshaller.close();
break;
case PARQUET:
final RowUnmarshaller<ParquetValue> parquetRowUnmarshaller = ParquetRowUnmarshaller.newInstance(cfg);
parquetRowUnmarshaller.unmarshal();
parquetRowUnmarshaller.close();
break;
default:
throw new C3rIllegalArgumentException("Unrecognized file format: " + cfg.getFileFormat());
}
log.info("Decrypted data saved in {}.", cfg.getTargetFile());
} else {
log.info("Dry run: No data will be decrypted from {}.", cfg.getSourceFile());
}
} catch (Exception e) {
Main.handleException(e, optionalArgs.enableStackTraces);
return Main.FAILURE;
}
return Main.SUCCESS;
}