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] [Commented] (ATLAS-3812) Add schema for Apache Flink
Date Thu, 28 May 2020 10:09:00 GMT

    [ https://issues.apache.org/jira/browse/ATLAS-3812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118521#comment-17118521
] 

Márton Balassi commented on ATLAS-3812:
---------------------------------------

Thanks [~madhan] for the detailed information. Will consider the issue you have mentioned
with the supertype.

I am planning to post a bridge/hook implementation soon, in fact already have a prototype
implementation - however it is dependent on pending changes in Apache Flink, and I would like
to add the schema itself sooner if possible

> 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)

Mime
View raw message