[FLINK-3933] [streaming API] Add AbstractDeserializationSchema #2010
Conversation
…andles produced type extraction. The AbstractDeserializationSchema creates the produced type information automatically from the generic parameters.
| If you experience any issues with the Kafka consumer on the client side, the client log might contain information about failed requests, etc. | ||
|
|
||
| ##### The `DeserializationSchema` | ||
| ##### **The `DeserializationSchema`** |
There was a problem hiding this comment.
Why did you add the **? The other section headings don't have it.
There was a problem hiding this comment.
The whole doc uses pretty low weight formatting. It is hard to recognize a heading as such. I overlooked the section initially.
There was a problem hiding this comment.
kafka.md uses very low level headings. The batch and streaming guides use level 2 headings for top-level headings while kafka.md uses level 4. I think the solution is to reduce heading level by 2 on all levels in this document, which would yield
### The `DeserializationSchema`
|
LGTM except for a minor comment in the doc |
|
Good addition that simplifies user's lives, I just saw someone on stack overflow who was struggling with how to get the |
…andles produced type extraction. The AbstractDeserializationSchema creates the produced type information automatically from the generic parameters. This closes apache#2010
3 participants
This PR adds an
AbstractDeserializationSchemathat handles the produced type extraction automatically from the generic types via the TypeExtractor (reflection)Also adds test and documentation, references the new
AbstractDeserializationSchemain the docs of theDeserializationSchema.