[ATLAS-3812] Add schema for Apache Flink

• Type: New Feature
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: atlas-intg
• Assignee: Unassigned
• Reporter: Márton Balassi
• Created: 25/May/20 17:53
• Updated: 13/Dec/21 02:57

Description

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.

{
    "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": []
}

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

Issue Links

• links to: schema for flink entities