search

datafibers-community / df_data_service

DataFibers Data Service
http://www.datafibers.com
Apache License 2.0
31 stars 30 forks source link

Flink auto generate output schema #155

Open datafibers opened 6 years ago

datafibers commented 6 years ago

For now, we need to specify the output schema for flink sql transform. We need to add a feature to automatically create a schema when not specified in terms of schema name or content.

We can leverate the result.printSchema() api in flink to do that. This also requires mapping the data type from flink table api to avro data type.

datafibers commented 6 years ago

@SchubertZhu test it since it is done