### Question:
IcebergStreamWriter extends AbstractStreamOperator<DataFile> implements OneInputStreamOperator<T, DataFile>, BoundedOneInput { @Override public void processElement(StreamRecord<T> element) throws Exception { writer.write(element.getValue()); } IcebergStreamWriter(String fullTableName, TaskWriterFactory<T> taskWriterFactory); @Override void open(); @Override void prepareSnapshotPreBarrier(long checkpointId); @Override void processElement(StreamRecord<T> element); @Override void dispose(); @Override void endInput(); @Override String toString();  }### Answer:
@Test public void testTableWithoutSnapshot() throws Exception { try (OneInputStreamOperatorTestHarness<RowData, DataFile> testHarness = createIcebergStreamWriter()) { Assert.assertEquals(0, testHarness.extractOutputValues().size()); } Assert.assertEquals(0, scanDataFiles().size()); try (OneInputStreamOperatorTestHarness<RowData, DataFile> testHarness = createIcebergStreamWriter()) { testHarness.processElement(SimpleDataUtil.createRowData(1, "hello"), 1); Assert.assertEquals(0, testHarness.extractOutputValues().size()); } Assert.assertEquals(1, scanDataFiles().size()); }