Thanks Xingbo! The workaround will probably work for now, at least it
avoids having to refer to index values in the rest of the function.
Cheers,
Sumeet
On Wed, May 19, 2021 at 3:02 PM Xingbo Huang wrote:
> Hi Sumeet,
>
> Due to the limitation of the original PyFlink serializers design, there
Hi Sumeet,
Due to the limitation of the original PyFlink serializers design, there is
no way to pass attribute names to Row in row-based operations. In
release-1.14, I am reconstructing the implementations of serializers[1].
After completion, accessing attribute names of `Row` in row-based
Hi,
According to the documentation for PyFlink Table row based operations [1],
typical usage is as follows:
@udtf(result_types=[DataTypes.INT(), DataTypes.STRING()])
def split(x: Row) -> Row:
for s in x[1].split(","):
yield x[0], s
table.flat_map(split)
Is there any way that row
