Trenikhun
Cc: Dawid Wysakowicz ; Flink User Mail List
Subject: Re: Unit Test for KeyedProcessFunction with out-of-core state
The new backend would be for unit tests (instead of a RocksDB mock). It's kind
of the mock for out-of-core behavior that you initially requested.
To use rocksDB in an IT
---
> *From:* Arvid Heise
> *Sent:* Monday, September 14, 2020 4:26:47 AM
> *To:* Dawid Wysakowicz
> *Cc:* Alexey Trenikhun ; Flink User Mail List <
> user@flink.apache.org>
> *Subject:* Re: Unit Test for KeyedProcessFunction with out-of-core state
>
&
ut(myKey, v);
Thanks,
Alexey
From: Tzu-Li (Gordon) Tai <mailto:tzuli...@apache.org>
Sent: Friday, September 4, 2020 12:35:48 AM
To: Alexey Trenikhun <mailto:yen...@msn.com>
Cc: Flink User Mail List <mailto:user@flink.apache.org>
Subject: Re: Unit
gt; Thanks,
> Alexey
>
> --
> *From:* Tzu-Li (Gordon) Tai
> *Sent:* Friday, September 4, 2020 12:35:48 AM
> *To:* Alexey Trenikhun
> *Cc:* Flink User Mail List
> *Subject:* Re: Unit Test for KeyedProcessFunction with out-of-core state
>
>
--
> *From:* Tzu-Li (Gordon) Tai
> *Sent:* Friday, September 4, 2020 12:35:48 AM
> *To:* Alexey Trenikhun
> *Cc:* Flink User Mail List
> *Subject:* Re: Unit Test for KeyedProcessFunction with out-of-core state
>
> Hi Alexey,
>
> Is there a specific reason why you
, September 4, 2020 12:35:48 AM
To: Alexey Trenikhun
Cc: Flink User Mail List
Subject: Re: Unit Test for KeyedProcessFunction with out-of-core state
Hi Alexey,
Is there a specific reason why you want to test against RocksDB?
Otherwise, in Flink tests we use a `KeyedOneInputStreamOperatorTestHarness
Hi Alexey,
Is there a specific reason why you want to test against RocksDB?
Otherwise, in Flink tests we use a `KeyedOneInputStreamOperatorTestHarness`
[1] that allows you to wrap a user function and eliminate the need to worry
about setting up heavy runtime context / dependencies such as the sta
