### Question:
JdbcAvroJob { public static JdbcAvroJob create(final PipelineOptions pipelineOptions, final String output) throws IOException, ClassNotFoundException { pipelineOptions.as(DirectOptions.class).setBlockOnRun(false); return new JdbcAvroJob( pipelineOptions, Pipeline.create(pipelineOptions), JdbcExportArgsFactory.fromPipelineOptions(pipelineOptions), output); } JdbcAvroJob(
      final PipelineOptions pipelineOptions,
      final Pipeline pipeline,
      final JdbcExportArgs jdbcExportArgs,
      final String output); static JdbcAvroJob create(final PipelineOptions pipelineOptions, final String output); static JdbcAvroJob create(final PipelineOptions pipelineOptions); static JdbcAvroJob create(final String[] cmdLineArgs); static PipelineOptions buildPipelineOptions(final String[] cmdLineArgs); void prepareExport(); Pipeline getPipeline(); JdbcExportArgs getJdbcExportArgs(); String getOutput(); PipelineOptions getPipelineOptions(); PipelineResult runAndWait(); PipelineResult runExport(); static void main(String[] cmdLineArgs);  }### Answer:
@Test(expected = IllegalArgumentException.class) public void shouldFailOnMissingInput() throws IOException, ClassNotFoundException { JdbcAvroJob.create(PipelineOptionsFactory.create()); }
@Test(expected = IllegalArgumentException.class) public void shouldFailOnEmptyInput() throws IOException, ClassNotFoundException { PipelineOptions pipelineOptions = PipelineOptionsFactory.create(); pipelineOptions.as(OutputOptions.class).setOutput(""); JdbcAvroJob.create(PipelineOptionsFactory.create()); }