[ https://issues.apache.org/jira/browse/FLINK-31397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jingsong Lee closed FLINK-31397. -------------------------------- Resolution: Fixed master: 0f5744a92bc52f52bc0f6644dc063dcb60fe326c > Introduce write-once hash lookup store > -------------------------------------- > > Key: FLINK-31397 > URL: https://issues.apache.org/jira/browse/FLINK-31397 > Project: Flink > Issue Type: Sub-task > Components: Table Store > Reporter: Jingsong Lee > Assignee: Jingsong Lee > Priority: Major > Labels: pull-request-available > Fix For: table-store-0.4.0 > > > Introduce interface for lookup changelog producer: > {code:java} > /** > * 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; > } > {code} > We can convert remote columnar data to local lookup store, and ready to be > used to lookup. -- This message was sent by Atlassian Jira (v8.20.10#820010)