Hi Jingsong,
Thanks a lot, I think I can live with TableEnvironment.createTemporaryView
in Flink 1.10 (which I am expecting to be released this month) but are
these views persisted somewhere? for example across sessions? or say I stop
my application and start again will it work as expected?
Thanks!
On Mon, Jan 20, 2020 at 1:12 AM Jingsong Li <jingsongl...@gmail.com> wrote:
> Hi Kant,
>
> Sorry, 1.10 not support "CREATE VIEW" in raw SQL too. Workaround is:
> - Using TableEnvironment.createTemporaryView...
> - Or using "create view" and "drop view" in the sql-client.
> - Or using hive catalog, in 1.10, we support query catalog views.
>
> FLIP-71 will be finished in 1.11 soon.
>
> Best,
> Jingsong Lee
>
> On Sun, Jan 19, 2020 at 4:10 PM kant kodali <kanth...@gmail.com> wrote:
>
>> I tried the following.
>>
>> bsTableEnv.sqlUpdate("CREATE VIEW my_view AS SELECT * FROM sample1 FULL
>> OUTER JOIN sample2 on sample1.f0=sample2.f0");
>>
>> Table result = bsTableEnv.sqlQuery("select * from my_view");
>>
>> It looks like
>> https://cwiki.apache.org/confluence/display/FLINK/FLIP-71+-+E2E+View+support+in+FLINK+SQL
>> Views
>> are not supported. Can I expect them to be supported in Flink 1.10?
>>
>> Currently, with Spark SQL when the query gets big I break it down into
>> views and this is one of the most important features my application relies
>> on. is there any workaround for this at the moment?
>>
>> Thanks!
>>
>> On Sat, Jan 18, 2020 at 6:24 PM kant kodali <kanth...@gmail.com> wrote:
>>
>>> Hi All,
>>>
>>> Does Flink 1.9 support create or replace views syntax in raw SQL? like
>>> spark streaming does?
>>>
>>> Thanks!
>>>
>>
>
> --
> Best, Jingsong Lee
>
