atlas-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Márton Balassi (Jira) <j...@apache.org>
Subject [jira] [Created] (ATLAS-3812) Add schema for Apache Flink
Date Mon, 25 May 2020 17:54:00 GMT
Márton Balassi created ATLAS-3812:
-------------------------------------

             Summary: 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


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)

Mime
View raw message