You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@atlas.apache.org by "ASF subversion and git services (Jira)" <ji...@apache.org> on 2021/06/04 09:30:00 UTC
[jira] [Commented] (ATLAS-3812) Add schema for Apache Flink
[ https://issues.apache.org/jira/browse/ATLAS-3812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17357211#comment-17357211 ]
ASF subversion and git services commented on ATLAS-3812:
--------------------------------------------------------
Commit 005d8674e09338504278440658af3159c8e5a967 in atlas's branch refs/heads/master from Josh Yeh
[ https://gitbox.apache.org/repos/asf?p=atlas.git;h=005d867 ]
ATLAS-3812: Apache Flink model for Atlas.
Signed-off-by: nixonrodrigues <ni...@apache.org>
> Add schema for Apache Flink
> ---------------------------
>
> Key: ATLAS-3812
> URL: https://issues.apache.org/jira/browse/ATLAS-3812
> Project: Atlas
> Issue Type: New Feature
> Components: atlas-intg
> Reporter: Márton Balassi
> Priority: Major
>
> Hi Apache Atlas team,
> I am an Apache Flink PMC member pursuing to add a Flink bridge to Atlas. As a first step of this I would like to contribute the following schema, ideally to the upcoming 2.1 release.
> {code}
> {
> "enumDefs": [],
> "structDefs": [],
> "classificationDefs": [],
> "entityDefs": [
> {
> "name": "flink_application",
> "superTypes": [
> "Process"
> ],
> "serviceType": "flink",
> "typeVersion": "1.0",
> "attributeDefs": [
> {
> "name": "id",
> "typeName": "string",
> "cardinality": "SINGLE",
> "isIndexable": true,
> "isOptional": false,
> "isUnique": true
> },
> {
> "name": "startTime",
> "typeName": "date",
> "cardinality": "SINGLE",
> "isIndexable": false,
> "isOptional": true,
> "isUnique": false
> },
> {
> "name": "endTime",
> "typeName": "date",
> "cardinality": "SINGLE",
> "isIndexable": false,
> "isOptional": true,
> "isUnique": false
> },
> {
> "name": "conf",
> "typeName": "map<string,string>",
> "cardinality": "SINGLE",
> "isIndexable": false,
> "isOptional": true,
> "isUnique": false
> },
> {
> "name": "inputs",
> "typeName": "array<string>",
> "cardinality": "LIST",
> "isIndexable": false,
> "isOptional": false,
> "isUnique": false
> },
> {
> "name": "outputs",
> "typeName": "array<string>",
> "cardinality": "LIST",
> "isIndexable": false,
> "isOptional": false,
> "isUnique": false
> }
> ]
> }
> ],
> "relationshipDefs": []
> }
> {code}
> Also please add an icon based on the white outline from the Flink material page similarly to the existing Kafka icon.
> https://flink.apache.org/material.html
--
This message was sent by Atlassian Jira
(v8.3.4#803005)