You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
There was problems with the previous row conversion. For example, array type should be T[] instead List.
According to discussion from #1215 , We can try to only work with RowData, and have conversions between RowData and Row.
There was problems with the previous row conversion. For example, array type should be
T[]insteadList.According to discussion from #1215 , We can try to only work with
RowData, and have conversions betweenRowDataandRow.The works can be:
ValueReaders.decimalBytesReaderfor reusing code. avro: Extract ValueReaders.decimalBytesReader #1233DecoderResolverto provide cachedResolvingDecoderfor resolving avro decoder. avro: Extract DecoderResolver to provide cached ResolvingDecoder for resolving avro decoder #1234AvroWithPartnerSchemaVisitorto extract specific avro logical fromAvroSchemaWithTypeVisitorandAvroWithSparkSchemaVisitor. avro: Abstract AvroWithPartnerSchemaVisitor #1235FlinkValueReadersandFlinkValueWritersand refactorFlinkAvroReaderandFlinkAvroWriter. Flink: Using RowData to avro reader and writer #1232