From issues-return-180985-archive-asf-public=cust-asf.ponee.io@flink.apache.org Mon Jul 30 12:04:04 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 19DFF180630 for ; Mon, 30 Jul 2018 12:04:03 +0200 (CEST) Received: (qmail 19078 invoked by uid 500); 30 Jul 2018 10:04:03 -0000 Mailing-List: contact issues-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list issues@flink.apache.org Received: (qmail 19069 invoked by uid 99); 30 Jul 2018 10:04:03 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 30 Jul 2018 10:04:03 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 999BACBCC1 for ; Mon, 30 Jul 2018 10:04:02 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -109.501 X-Spam-Level: X-Spam-Status: No, score=-109.501 tagged_above=-999 required=6.31 tests=[ENV_AND_HDR_SPF_MATCH=-0.5, KAM_ASCII_DIVIDERS=0.8, RCVD_IN_DNSWL_MED=-2.3, SPF_PASS=-0.001, USER_IN_DEF_SPF_WL=-7.5, USER_IN_WHITELIST=-100] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id aIx4esVcoOen for ; Mon, 30 Jul 2018 10:04:02 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id C30115F30C for ; Mon, 30 Jul 2018 10:04:01 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 2FDFAE2600 for ; Mon, 30 Jul 2018 10:04:01 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 8FDA327766 for ; Mon, 30 Jul 2018 10:04:00 +0000 (UTC) Date: Mon, 30 Jul 2018 10:04:00 +0000 (UTC) From: "ASF GitHub Bot (JIRA)" To: issues@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (FLINK-9438) Add documentation for (Registry)AvroDeserializationSchema MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/FLINK-9438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16561725#comment-16561725 ] ASF GitHub Bot commented on FLINK-9438: --------------------------------------- tzulitai commented on a change in pull request #6078: [FLINK-9438] Add documentation for AvroDeserializationSchema URL: https://github.com/apache/flink/pull/6078#discussion_r206076706 ########## File path: docs/dev/connectors/kafka.md ########## @@ -166,6 +166,39 @@ For convenience, Flink provides the following schemas: The KeyValue objectNode contains a "key" and "value" field which contain all fields, as well as an optional "metadata" field that exposes the offset/partition/topic for this message. +3. `AvroDeserializationSchema` which reads data serialized with Avro format using statically provided schema. It can + infer the schema from avro generated classes (`AvroDeserializationSchema.forSpecific(...)`) or it can work with `GenericRecords` + with manually provided schema (with `AvroDeserializationSchema.forGeneric(...)`). This deserialization schema expects that + the serialized records DO NOT contain embedded schema. + + - There is also version of this schema available that can lookup writers schema (schema which was used to write the record) in Review comment: also "a" version ... ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: users@infra.apache.org > Add documentation for (Registry)AvroDeserializationSchema > --------------------------------------------------------- > > Key: FLINK-9438 > URL: https://issues.apache.org/jira/browse/FLINK-9438 > Project: Flink > Issue Type: Improvement > Components: Documentation > Affects Versions: 1.6.0 > Reporter: Dawid Wysakowicz > Assignee: Dawid Wysakowicz > Priority: Critical > Labels: pull-request-available > -- This message was sent by Atlassian JIRA (v7.6.3#76005)