Jingsong Lee created FLINK-31397: ------------------------------------ Summary: 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 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)