public static Referenceable createClusterEntity ( final org . apache . falcon . entity . v0 . cluster . Cluster cluster ) { LOG . info ( "Creating cluster Entity : {}" , cluster . getName ( ) ) ; Referenceable clusterRef = new Referenceable ( FalconDataTypes . FALCON_CLUSTER . getName ( ) ) ; clusterRef . set ( AtlasClient . NAME , cluster . getName ( ) ) ; clusterRef . set ( AtlasClient . DESCRIPTION , cluster . getDescription ( ) ) ; clusterRef . set ( AtlasClient . REFERENCEABLE_ATTRIBUTE_NAME , cluster . getName ( ) ) ; clusterRef . set ( FalconBridge . COLO , cluster . getColo ( ) ) ; if ( cluster . getACL ( ) != null ) { clusterRef . set ( AtlasClient . OWNER , cluster . getACL ( ) . getGroup ( ) ) ; } if ( StringUtils . isNotEmpty ( cluster . getTags ( ) ) ) { clusterRef . set ( FalconBridge . TAGS , EventUtil . convertKeyValueStringToMap ( cluster . getTags ( ) ) ) ; } return clusterRef ; }
Creates cluster entity