<s> from sahara . conductor import resource as res <EOL> from sahara . plugins . cdh import plugin_utils as pu <EOL> from sahara . plugins . cdh . v5_3_0 import config_helper <EOL> from sahara . plugins . cdh . v5_3_0 import db_helper <EOL> from sahara . plugins import utils as u <EOL> class PluginUtilsV530 ( pu . AbstractPluginUtils ) : <EOL> def __init__ ( self ) : <EOL> self . c_helper = config_helper . ConfigHelperV530 ( ) <EOL> self . db_helper = db_helper <EOL> def get_role_name ( self , instance , service ) : <EOL> shortcuts = { <EOL> '<STR_LIT>' : '<STR_LIT:A>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT:M>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT:S>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : '<STR_LIT>' <EOL> } <EOL> return '<STR_LIT>' % ( shortcuts . get ( service , service ) , <EOL> instance . hostname ( ) . replace ( '<STR_LIT:->' , '<STR_LIT:_>' ) ) <EOL> def get_sentry ( self , cluster ) : <EOL> return u . get_instance ( cluster , '<STR_LIT>' ) <EOL> def get_flumes ( self , cluster ) : <EOL> return u . get_instances ( cluster , '<STR_LIT>' ) <EOL> def get_solrs ( self , cluster ) : <EOL> return u . get_instances ( cluster , '<STR_LIT>' ) <EOL> def get_sqoop ( self , cluster ) : <EOL> return u . get_instance ( cluster , '<STR_LIT>' ) <EOL> def get_hbase_indexers ( self , cluster ) : <EOL> return u . get_instances ( cluster , '<STR_LIT>' ) <EOL> def get_catalogserver ( self , cluster ) : <EOL> return u . get_instance ( cluster , '<STR_LIT>' ) <EOL> def get_statestore ( self , cluster ) : <EOL> return u . get_instance ( cluster , '<STR_LIT>' ) <EOL> def get_impalads ( self , cluster ) : <EOL> return u . get_instances ( cluster , '<STR_LIT>' ) <EOL> def convert_process_configs ( self , configs ) : <EOL> p_dict = { <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> "<STR_LIT>" : [ '<STR_LIT>' ] , <EOL> '<STR_LIT>' : [ '<STR_LIT>' ] , <EOL> '<STR_LIT>' : [ '<STR_LIT>' ] <EOL> } <EOL> if isinstance ( configs , res . Resource ) : <EOL> configs = configs . to_dict ( ) <EOL> for k in configs . keys ( ) : <EOL> if k in p_dict . keys ( ) : <EOL> item = configs [ k ] <EOL> del configs [ k ] <EOL> newkey = p_dict [ k ] [ <NUM_LIT:0> ] <EOL> configs [ newkey ] = item <EOL> return res . Resource ( configs ) <EOL> def configure_sentry ( self , cluster ) : <EOL> manager = self . get_manager ( cluster ) <EOL> with manager . remote ( ) as r : <EOL> self . db_helper . create_sentry_database ( cluster , r ) </s>
