Hello Fabian and Stephan, Thank you guys for your reply
@Fabian: Could you please be kind enough to write a dummy example using SerializedOutputFormat and SerializedInputFormat, I tried with below instruction: dataset.write(new SerializedOutputFormat[MyClass], dataPath) but it doesn't work and throws error because type arguments [...] do not conform to class SerializedOutputFormat's type parameter bounds. I tried with Stephan's advice to use TypeSerielizerOutputFormat, it seems to work but I do not know how to read the output back in @Stephan: output using dataset.write(new TypeSerializerOutputFormat[MyClass], outputDataPath) works for me. but when I tried the same instruction to read back: val readback = env.readFile[MyClass](new TypeSerializerInputFormat[MyClass], dataPath) this gives error of unspecified value parameter x$1 when I tried to add TypeSerializer as IntelliJ suggests: val readback = env.readFile[MyClass](new TypeSerializerInputFormat[MyClass](TypeSerializer[MyClass]), dataPath) it says that TypeSerializer is not a value. I couldn't figure out any solution from the debug log. Is there any working example for using those in Scala ?? -- View this message in context: http://apache-flink-incubator-user-mailing-list-archive.2336050.n4.nabble.com/CSV-input-with-unknown-of-fields-and-Custom-output-format-tp670p673.html Sent from the Apache Flink (Incubator) User Mailing List archive. mailing list archive at Nabble.com.
