You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/08/10 18:03:05 UTC
[jira] [Created] (FLINK-7420) Move all Avro code to flink-avro
Stephan Ewen created FLINK-7420:
-----------------------------------
Summary: Move all Avro code to flink-avro
Key: FLINK-7420
URL: https://issues.apache.org/jira/browse/FLINK-7420
Project: Flink
Issue Type: Improvement
Components: Build System
Reporter: Stephan Ewen
Fix For: 1.4.0
Currently, the {{flink-avro}} project is a shell with some tests and mostly duplicate and dead code. The classes that use Avro are distributed quite wildly through the code base, and introduce multiple direct dependencies on Avro in a messy way.
We should move all Avro related classes to {{flink-avro}}, and give {{flink-avro}} a dependency on {{flink-core}} and {{flink-streaming-java}}.
- {{AvroTypeInfo}}
- {{AvroSerializer}}
- {{AvroRowSerializationSchema}}
- {{AvroRowDeserializationSchema}}
To be able to move the the avro serialization code from {{flink-ore}} to {{flink-avro}}, we need to load the {{AvroTypeInformation}} reflectively, similar to how we load the {{WritableTypeInfo}} for Hadoop.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)