FlinkOutputFieldsDeclarer implements OutputFieldsDeclarer { @Override public void declareStream(final String streamId, final Fields fields) { this.declareStream(streamId, false, fields); }  @Override void declare(final Fields fields); @Override void declare(final boolean direct, final Fields fields); @Override void declareStream(final String streamId, final Fields fields); @Override void declareStream(final String streamId, final boolean direct, final Fields fields);  }
@Test(expected = UnsupportedOperationException.class) public void testDeclareDirect2() { new FlinkOutputFieldsDeclarer().declareStream(Utils.DEFAULT_STREAM_ID, true, null); }