| commit | f26df15fc91a9bb544dfc77f9a089d5952a5f76c | [log] [tgz] |
|---|---|---|
| author | Tzu-Li (Gordon) Tai <tzulitai@apache.org> | Mon Aug 31 15:48:39 2020 +0800 |
| committer | Tzu-Li (Gordon) Tai <tzulitai@apache.org> | Tue Sep 01 15:24:26 2020 +0800 |
| tree | d3b98b433e9c09198eeb5534ad61fa7aed651804 | |
| parent | 9a76143a10f7937abd2e166bf30c20f87f8d2029 [diff] |
[FLINK-19096] [sdk] Rework PersistedStateRegistry registration methods This reworks the `registerValue` / `registerTable` etc. methods on PersistedStateRegistry to directly accept a constructed PersistedValue / PersistedTable instance. This allows us to avoid having to synchronize those methods and the state class constructors.