### Question:
IcebergWriterStage implements ScalarComputation<Record, DataFile> { @Override public void init(Context context) { transformer = newTransformer(context); } IcebergWriterStage(); static ScalarToScalar.Config<Record, DataFile> config(); static List<ParameterDefinition<?>> parameters(); static Transformer newTransformer(Context context); @Override void init(Context context); @Override Observable<DataFile> call(Context context, Observable<Record> recordObservable);  }### Answer:
@Test void shouldInitializeWithExistingTable() { IcebergWriterStage stage = new IcebergWriterStage(); assertDoesNotThrow(() -> stage.init(context)); }
@Test void shouldFailToInitializeWithMissingTable() { when(catalog.loadTable(any())).thenThrow(new RuntimeException()); IcebergWriterStage stage = new IcebergWriterStage(); assertThrows(RuntimeException.class, () -> stage.init(context)); }