Hello, Flink team!
1) Is it possible to save a python list to table from datastream?
2) and then save the accumulated data to avro file?
For example, my data stream has the type.
Types.ROW_NAMED(['id', 'items'], [Types.STRING, Types.LIST(items_row)] )
items_row = Types.ROW_NAMED(field_names=['start', 'end'], field_types=[Types.LONG(), Types.LONG()])
How do I create a schema table for the current data type?
I tried like this
schema = Schema.new_builder() \
.column('id', DataTypes.STRING()) \
.column('items', DataTypes.ARRAY(
DataTypes.ROW([
DataTypes.FIELD("start", DataTypes.BIGINT()),
DataTypes.FIELD("end", DataTypes.BIGINT())]))).build()
And it doesn't work.
