stevenzwu edited a comment on issue #1643: URL: https://github.com/apache/iceberg/issues/1643#issuecomment-714891057
> the current problem is : how to reuse it ? regarding how to create and clone instance, we can extend the new [DataIteratorFactory](https://github.com/stevenzwu/iceberg/blob/flip27IcebergSource/flink/src/main/java/org/apache/iceberg/flink/source/reader/DataIteratorFactory.java) interface in the flip-27 source poc code. So that is doable ``` public class RowDataIteratorFactory implements DataIteratorFactory<RowData> { @Override public DataIterator<RowData> createIterator( IcebergSourceSplit split, TableInfo tableInfo, ScanContext scanContext) { return new RowDataIterator(...); } @Override public RowData create() { ... } @Override public void clone(RowData from, RowData to) { ... } ``` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
