From user-return-24571-archive-asf-public=cust-asf.ponee.io@flink.apache.org Tue Nov 27 09:45:06 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 C41B6180670 for ; Tue, 27 Nov 2018 09:45:05 +0100 (CET) Received: (qmail 47458 invoked by uid 500); 27 Nov 2018 08:44:59 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 47447 invoked by uid 99); 27 Nov 2018 08:44:59 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 27 Nov 2018 08:44:59 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 360A5C0795 for ; Tue, 27 Nov 2018 08:44:59 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.798 X-Spam-Level: * X-Spam-Status: No, score=1.798 tagged_above=-999 required=6.31 tests=[DKIMWL_WL_MED=-0.001, DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, DKIM_VALID_EF=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id 4cpEkWbeQKqe for ; Tue, 27 Nov 2018 08:44:57 +0000 (UTC) Received: from mail-vs1-f47.google.com (mail-vs1-f47.google.com [209.85.217.47]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 2997D5F27B for ; Tue, 27 Nov 2018 08:44:57 +0000 (UTC) Received: by mail-vs1-f47.google.com with SMTP id r14so13213152vsc.13 for ; Tue, 27 Nov 2018 00:44:57 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:from:date:message-id:subject:to; bh=w2DZoCW1Bjx4yxK8fVWSt4d30P/BtwLqDNVEaPYuc74=; b=bkxZUnX7DqFor+m7JkbFyfVgInHuwb3kpKfCCQzOgLhw6Ayjb1fwem8waiPLPfMp8q p2MX02ug62ajL+59WlL6SZ1C8ITqbUS5XPt8OBWCZzXzX+S/gEp8wS0nMCeUcvXwtLMg AweSs0YEWQw25PVnIq1CS5c5lIeBNvA9afGGeAdiCnmoPgJWMuucC9/fM8JX5DhCVaN5 XchWJzIuSiYJ8WVK80BnDANSaEFQO7TdiVU5HDfcMgURTovlcZhAzpjG+sOy9ExTyuK6 kpJcpkafH3cUZDXw93JXOmTvv512kWzHBP7QaL3ebDn4evuUqIwZ2hdnksEi9jrJnbQw rNOw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:from:date:message-id:subject:to; bh=w2DZoCW1Bjx4yxK8fVWSt4d30P/BtwLqDNVEaPYuc74=; b=LrnJYEh5eYocajNB3XA2Xscv2z/QpbNAa+w7u5i+movegdb/xfm0TyWSPJxKgKkJe2 0vyQ5lvaAtqR9wrzfN87ep0uT3+m550daZuW16EK1LSBQNfNxvYIEbwHso5Uy36FPnFH RfZo4jiZOJl36LWRCg0YOarKbIlmyVlFaupzk3p3YLkUnTpjWxZF2v9qXiadKWt+O2pM CvV7+Ln7KLUh4JSc5LHgHHbiRUxpKD5yX6IbqfJfFlIeapDKVy38t17U6HRws+4dr2tl EtiUIVgsj4AXkK9ga+Vo2UV0CJYd9sAb5rr6f0aVzV9pQYa/JVCvrpZwFyC1O7+mSyv0 SUcQ== X-Gm-Message-State: AGRZ1gKI1jXNfdIZPE2FrQm2RJCOhUru8JshrLflxpsyq2DHiVaCEb3P qbgvlHj4nv7CdqvqcvijZotfWVJyQ7T33SJmUqhbgAk= X-Google-Smtp-Source: AJdET5dFSGcQZv2XaqlBXzzspT7NzposzG2RNYZ7CeC+obsC6wXzRUse5JAXDzcrVGW5lBUGPhfQ51er8/uoc+3XNjk= X-Received: by 2002:a67:cf02:: with SMTP id y2mr13593112vsl.118.1543308296583; Tue, 27 Nov 2018 00:44:56 -0800 (PST) MIME-Version: 1.0 From: Henry Dai Date: Tue, 27 Nov 2018 16:44:45 +0800 Message-ID: Subject: To: user@flink.apache.org Content-Type: multipart/alternative; boundary="000000000000cbff36057ba176f9" --000000000000cbff36057ba176f9 Content-Type: text/plain; charset="UTF-8" Hi, Is there a way to get table's metadata in flink? if I emit a table to kafka, then how can I know the table columns when I subscribe the kafka topic and restore the table using *tableEnv.registerDataStream("t1", source, "field1, field2 ...") *in another flink program? Flink should provide something like Hive's metastore to keep metadata of tables. -- best wishes hengyu --000000000000cbff36057ba176f9 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Hi,
Is there a way to get table's metad= ata in flink?
if I emit a table to kafka, then how can I know the= table columns when I subscribe the kafka topic and restore the table using= =C2=A0tableEnv.registerDataStream("t1", source, "field1, = field2 ...")=C2=A0=C2=A0in another flink program?

Flink should provide something like Hive's metastore to keep m= etadata of tables.

--
best wish= es
hengyu
--000000000000cbff36057ba176f9--