in dbeam-core/src/main/java/com/spotify/dbeam/jobs/JdbcAvroJob.java [60:75]
public JdbcAvroJob(
final PipelineOptions pipelineOptions,
final Pipeline pipeline,
final JdbcExportArgs jdbcExportArgs,
final String output,
final boolean dataOnly,
final long minRows) {
this.pipelineOptions = pipelineOptions;
this.pipeline = pipeline;
this.jdbcExportArgs = jdbcExportArgs;
this.output = output;
this.dataOnly = dataOnly;
this.minRows = minRows;
Preconditions.checkArgument(
this.output != null && this.output.length() > 0, "'output' must be defined");
}