JDBCOutputFormat extends RichOutputFormat<OUT> { public static JDBCOutputFormatBuilder buildJDBCOutputFormat() { return new JDBCOutputFormatBuilder(); } JDBCOutputFormat(); @Override void configure(Configuration parameters); @Override void open(int taskNumber, int numTasks); @Override void writeRecord(OUT tuple); @Override void close(); static JDBCOutputFormatBuilder buildJDBCOutputFormat();  }
@Test(expected = IllegalArgumentException.class) public void testIncompleteConfiguration() throws IOException { jdbcOutputFormat = JDBCOutputFormat.buildJDBCOutputFormat() .setDrivername("org.apache.derby.jdbc.EmbeddedDriver") .setQuery("insert into books (id, title, author, price, qty) values (?,?,?,?,?)") .finish(); }