@Test public void testRecordPayloadWriting() throws Exception { writer.writeRecords(new Batch<>(record)); assertThat(systemOut.getLog()).isEqualTo(PAYLOAD + LINE_SEPARATOR); }
@Override public void writeRecords(Batch<P> batch) { for (Record<P> record : batch) { System.out.println(record.getPayload().toString()); } }
StandardOutputRecordWriter implements RecordWriter<P> { @Override public void writeRecords(Batch<P> batch) { for (Record<P> record : batch) { System.out.println(record.getPayload().toString()); } } }
StandardOutputRecordWriter implements RecordWriter<P> { @Override public void writeRecords(Batch<P> batch) { for (Record<P> record : batch) { System.out.println(record.getPayload().toString()); } }  }
StandardOutputRecordWriter implements RecordWriter<P> { @Override public void writeRecords(Batch<P> batch) { for (Record<P> record : batch) { System.out.println(record.getPayload().toString()); } }  @Override void writeRecords(Batch<P> batch); }
StandardOutputRecordWriter implements RecordWriter<P> { @Override public void writeRecords(Batch<P> batch) { for (Record<P> record : batch) { System.out.println(record.getPayload().toString()); } }  @Override void writeRecords(Batch<P> batch);  }