@Test void shouldInitializeWithExistingTable() { IcebergWriterStage stage = new IcebergWriterStage(); assertDoesNotThrow(() -> 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);  }