FlinkOutputFieldsDeclarer implements OutputFieldsDeclarer { @Override public void declare(final Fields fields) { this.declareStream(Utils.DEFAULT_STREAM_ID, 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 public void testDeclare() { for (int i = 0; i < 2; ++i) { for (int j = 1; j < 2; ++j) { for (int k = 0; k <= 24; ++k) { this.runDeclareTest(i, j, k); } } } }
@Test(expected = UnsupportedOperationException.class) public void testDeclareDirect() { new FlinkOutputFieldsDeclarer().declare(true, null); }