in dbeam-core/src/main/java/com/spotify/dbeam/options/JdbcExportArgsFactory.java [149:159]
private static QueryBuilderArgs createQueryBuilderArgs(final JdbcExportPipelineOptions options)
throws IOException {
checkArgument(
(options.getTable() != null) != (options.getSqlFile() != null),
"Either --table or --sqlFile must be present");
if (options.getSqlFile() != null) {
return QueryBuilderArgs.createFromQuery(BeamHelper.readFromFile(options.getSqlFile()));
} else {
return QueryBuilderArgs.create(options.getTable());
}
}