This is an automated email from the ASF dual-hosted git repository. nixon pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/atlas.git
commit a873395618e0c561c4ba9d4369b4f1ad8d05f2e9 Author: Josh Yeh <jj...@cloudera.com> AuthorDate: Thu Jun 3 21:41:34 2021 -0700 ATLAS-3812: Apache Flink model for Atlas. Signed-off-by: nixonrodrigues <ni...@apache.org> (cherry picked from commit 005d8674e09338504278440658af3159c8e5a967) --- addons/models/1000-Hadoop/1110-flink_model.json | 106 ++++++++++++++++++++++++ 1 file changed, 106 insertions(+) diff --git a/addons/models/1000-Hadoop/1110-flink_model.json b/addons/models/1000-Hadoop/1110-flink_model.json new file mode 100644 index 0000000..029600f --- /dev/null +++ b/addons/models/1000-Hadoop/1110-flink_model.json @@ -0,0 +1,106 @@ +{ + "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": "flink_process", + "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": "flink_application_processes", + "serviceType": "flink", + "typeVersion": "1.0", + "relationshipCategory": "AGGREGATION", + "endDef1": { + "type": "flink_application", + "name": "processes", + "cardinality": "SET", + "isContainer": true + }, + "endDef2": { + "type": "flink_process", + "name": "application", + "cardinality": "SINGLE" + }, + "propagateTags": "NONE" + } + ] +}' \ No newline at end of file