Apache Flink 漫谈系列(15) - DataStream Connectors之Kafka

Apache Flink 内部提供了如下3种内置的常用动静名目标Schemas：

• TypeInformationSerializationSchema (and TypeInformationKeyValueSerializationSchema) 它基于Flink的TypeInformation建设模式。 假如数据由Flink写入和读取，这将很是有效。
• JsonDeserializationSchema (and JSONKeyValueDeserializationSchema) 它将序列化的JSON转换为ObjectNode工具，可以行使objectNode.get(“field”)作为(Int / String / ...)()从中会见字段。 KeyValue objectNode包括“key”和“value”字段，个中包括全部字段以及可选的"metadata"字段，该字段果真此动静的偏移量/分区/主题。
• AvroDeserializationSchema 它行使静态提供的模式读取行使Avro名目序列化的数据。 它可以从Avro天生的类(AvroDeserializationSchema.forSpecific(...))揣度出模式，可能它可以与GenericRecords一路行使手动提供的模式(行使AvroDeserializationSchema.forGeneric(...))

（编辑：湖南网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!