This is an automated email from the ASF dual-hosted git repository.
nixon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/atlas.git
commit 005d8674e09338504278440658af3159c8e5a967
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>
---
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
