It works!
Thank you Nicolaus.
On Tue, Nov 2, 2021 at 12:40 PM Nicolaus Weidner <
nicolaus.weid...@ververica.com> wrote:
> Hi Yuval,
>
> Can you try
> toDataStream[RowData](tableSchema.toPhysicalRowDataType.bridgedTo(classOf[RowData]))?
>
> Best regards,
> Nico
>
> On Thu, Oct 28, 2021 at 10:15
Hi Yuval,
Can you try
toDataStream[RowData](tableSchema.toPhysicalRowDataType.bridgedTo(classOf[RowData]))?
Best regards,
Nico
On Thu, Oct 28, 2021 at 10:15 PM Yuval Itzchakov wrote:
> Flink 1.14
> Scala 2.12.5
>
> Hi,
> I want to be able to convert a Table into a DataStream[RowData]. I need
Flink 1.14
Scala 2.12.5
Hi,
I want to be able to convert a Table into a DataStream[RowData]. I need to
do this since I already have specific infrastructure in place that knows
how to serialize RowData into a JSON format. Previously when using
toAppendStream[RowData], this worked fine.
However,
