Thanks for the answer, I'll try. Are there examples or tutorials somewhere on how to use FlinkML in real-life scenarios, such as streaming Kafka through a model?
________________________________ От: Xin Jiang <jiangxin...@gmail.com> Отправлено: 19 сентября 2023 г. 8:07:11 Кому: Evgeniy Lyutikov Копия: user@flink.apache.org Тема: Re: FlinkML 'DenseVector' object has no attribute 'get_fields_by_names' Hi Evgeniy, Yes, the reason of the exception is that you are returning an incorrect data type. Flink ML doesn’t have a data type for `DenseVector` but it provides a function called `pyflink.ml.functions.array_to_vector` which returns an `Expression`. So maybe you can modify your UDF to union multiple columns as one column of `DataTypes.ARRAY()`, and then call `pyflink.ml.functions.array_to_vector` on this column. Best, Xin ________________________________ “This message contains confidential information/commercial secret. If you are not the intended addressee of this message you may not copy, save, print or forward it to any third party and you are kindly requested to destroy this message and notify the sender thereof by email. Данное сообщение содержит конфиденциальную информацию/информацию, являющуюся коммерческой тайной. Если Вы не являетесь надлежащим адресатом данного сообщения, Вы не вправе копировать, сохранять, печатать или пересылать его каким либо иным лицам. Просьба уничтожить данное сообщение и уведомить об этом отправителя электронным письмом.”
