etl refactor

refactor.java

public class  PersonnelETL extends BaseCommand {
    @Override
    protected final int run(CommandLine line) throws Exception {
        return runETLProcess(
                line,
                ObjectGraph.create(
                    new PersonnelModule(
                            getConf(),
                            line.getOptionValue(OPTION_CLIENT),
                            line.getOptionValue(OPTION_POPULATION),
                            line.getOptionValue(OPTION_DATA_VERSION)
                    )
                )
        );
    }
    ...
}

public abstract class BaseCommand extends Command {
    ...

    protected int runETLProcess(CommandLine line, ObjectGraph daggerGraph) throws Exception {
        List<String> errors = validateUsage(line);
        if (!errors.isEmpty()) {
            throw new InvalidUsageException(Joiner.on('\n').join(errors));
        }

        try {
            daggerGraph.inject(this);

            return runInjected(line);
        } finally {
            IOUtils.closeQuietly(shutdown);
        }
    }
    
        @Override
    public Options getOptions() {
        return super
                .getOptions()
                .addOption(
                        "V",
                        OPTION_DATA_VERSION,
                        true,
                        "Specifies the version identifier to use for input and output")
                .addOption("p" , OPTION_POPULATION, true, "Population ID")
                .addOption("d", OPTION_DRY_RUN, false, "Don't load data into RDBMS.")
                .addOption("c", OPTION_CLIENT, true, "Client ID");
    }
    ...
}