Hi Puneet,
I'm very sure that this feature will be included in upcoming releases.
However, such an interface has to be carefully designed because built-in
operators assume that only records that have been emitted previously are
retracted. Maybe it will be part of Flink 1.6 but 1.7 should definitely
be possible.
As a workaround you could implement a custom rule that translates parts
of your plan into a custom DataStream operator. This might require some
investigation how the translation is done internally because this is not
documented. I don't know if it would be worth the effort. You might take
a look at TableEnvironment.getConfig().setCalciteConfig() where you can
add additional rules. You can use the available rules in
org.apache.flink.table.plan.rules.FlinkRuleSets as a reference.
I hope that helps.
Regards,
Timo
Am 1/26/18 um 4:08 PM schrieb Puneet Kinra:
Hi
I know currently Ingesting a table from a retraction stream is not
supported yet.
is there any plan to include in upcoming releases.
--
*Cheers *
*
*
*Puneet Kinra*
*
*
*Mobile:+918800167808 | Skype : puneet.ki...@customercentria.com
<mailto:puneet.ki...@customercentria.com>*
*e-mail :puneet.ki...@customercentria.com
<mailto:puneet.ki...@customercentria.com>*
