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