Hi Shivam,
Flink 1.5 provides full Row-JSON-Row conversions. You can take a look at
the `flink-json` module. A table schema can be converted into a
TypeInformation (Types.ROW(schema.getColumns(), schema.getTypes()))
which can be used to configure
JsonRowSerialization/DeserializationSchemas. If you are looking for a
string output. We might need to refactor those classes a little bit to
also use the conversion functionality for non-binary output.
Regards,
Timo
Am 12.07.18 um 03:38 schrieb Hequn Cheng:
Hi shivam,
It seems there is no such a function but you can write one by
yourself, maybe use the com.fasterxml.jackson.databind.ObjectMapper.
Best, Hequn
On Thu, Jul 12, 2018 at 1:56 AM, Shivam Sharma
<28shivamsha...@gmail.com <mailto:28shivamsha...@gmail.com>> wrote:
Hi All,
I have TableSchema
<https://ci.apache.org/projects/flink/flink-docs-release-1.3/api/java/org/apache/flink/table/api/TableSchema.html>
object and a Flink Row object(or list). Do we have any
straightforward way to convert Row object into JSON by using Schema?
For Example:-
TableSchema-
- columnNames: [name, count]
- columnTypes: [String, Integer]
Row - ("shivam", 2)
JSON - {"name": "shivam", count: 2}
Thanks
--
Shivam Sharma
Data Engineer @ Goibibo
Indian Institute Of Information Technology, Design and
Manufacturing Jabalpur
Mobile No- (+91) 8882114744
Email:- 28shivamsha...@gmail.com <mailto:28shivamsha...@gmail.com>
LinkedIn:-_https://www.linkedin.com/in/28shivamsharma
<https://www.linkedin.com/in/28shivamsharma>_
