@Test void shouldFailToInitializeWithMissingTable() { when(catalog.loadTable(any())).thenThrow(new RuntimeException()); IcebergWriterStage stage = new IcebergWriterStage(); assertThrows(RuntimeException.class, () -> stage.init(context)); }
@Override public void init(Context context) { transformer = newTransformer(context); }
IcebergWriterStage implements ScalarComputation<Record, DataFile> { @Override public void init(Context context) { transformer = newTransformer(context); } }
IcebergWriterStage implements ScalarComputation<Record, DataFile> { @Override public void init(Context context) { transformer = newTransformer(context); } IcebergWriterStage(); }
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); }
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);  }