JingsongLi opened a new pull request, #593:
URL: https://github.com/apache/flink-table-store/pull/593
Introduce interface for lookup changelog producer:
```
/**
* A key-value store for lookup, key-value store should be single binary
file written once and ready
* to be used. This factory provide two interfaces:
*
* <ul>
* <li>Writer: written once to prepare binary file.
* <li>Reader: lookup value by key bytes.
* </ul>
*/
public interface LookupStoreFactory {
LookupStoreWriter createWriter(File file) throws IOException;
LookupStoreReader createReader(File file) throws IOException;
}
```
We can convert remote columnar data to local lookup store, and ready to be
used to lookup.
--
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.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
