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)
