There is no params to set ParquetWriterConfig when create new ParquetSink instance.
I couldn't set it after created.
Because some variables which for it were defined as val. And almost components were in closure.
How can I do that? Or, when you change this?
There is no params to set ParquetWriterConfig when create new ParquetSink instance.
I couldn't set it after created.
Because some variables which for it were defined as val. And almost components were in closure.
How can I do that? Or, when you change this?