Dear List,
I have a table with the following structure
my_table
-- Key: String
-- List_element: ARRAY>
I want to define a udf to extract information of the “list_element”. I do not
manage to access the information of the array in the udf. I try something like:
@udf(result_type=DataTypes.STRIN
Dear List,
I have trouble implementing a join between two streaming tables in Python Table
API.
The left table of my join should be enriched with the information with the last
value of the right_table. The right_table is updated only rarely (maybe after
15 minutes). When implementing the join
now. This seems to work for
me right now but could result in problems in the future.
Best
Torben
Von: Leonard Xu [mailto:xbjt...@gmail.com]
Gesendet: Samstag, 16. Januar 2021 15:05
An: Barth, Torben
Cc: user@flink.apache.org
Betreff: Re: Pyflink Join with versioned view / table
Hi, Torben
When
e my topic only has one partition the first option will also not work for
me. Following your comments I guess I need to reconsider the design of my
problem.
Best,
Torben
-Ursprüngliche Nachricht-
Von: Leonard Xu [mailto:xbjt...@gmail.com]
Gesendet: Dienstag, 19. Januar 2021 10:36
An: Bar
