Re: Flink[Python] questions

2021-01-14 Thread Shuiqiang Chen
Hi Dc, Thank you for your feedback. 1. Currently, only built-in types are supported in Python DataStream API, however, you can apply a Row type to represent a custom Python class as a workaround that field names stand for the name of member variables and field types stand for the type of member

Flink[Python] questions

2021-01-13 Thread Dc Zhao (BLOOMBERG/ 120 PARK)
Hi Flink Community: We are using the pyflink to develop a POC for our project. We encountered some questions while using the flink. We are using the flink version 1.2, python3.7, data stream API 1. Do you have examples of providing a python customized class as a `result type`? Based on the docu