def createHdfsResources()

in ambari-server/src/main/resources/scripts/Ambaripreupload.py [0:0]

• 228 lines of code
• 1 McCabe index (conditional complexity)

  def createHdfsResources():
    Logger.info("Creating hdfs directories...")
    params.HdfsResource(
      format("{hdfs_path_prefix}/atshistory"),
      user="hdfs",
      change_permissions_for_parents=True,
      owner="yarn",
      group="hadoop",
      type="directory",
      action=["create_on_execute"],
      mode=0o755,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/user/hcat"),
      owner="hcat",
      type="directory",
      action=["create_on_execute"],
      mode=0o755,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/hive/warehouse"),
      owner="hive",
      type="directory",
      action=["create_on_execute"],
      mode=0o777,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/warehouse/tablespace/external/hive"),
      owner="hive",
      type="directory",
      action=["create_on_execute"],
      mode=0o1777,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/user/hive"),
      owner="hive",
      type="directory",
      action=["create_on_execute"],
      mode=0o755,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/user/hive/.yarn/package/LLAP"),
      owner="hive",
      type="directory",
      action=["create_on_execute"],
      mode=0o755,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/tmp"),
      mode=0o777,
      action=["create_on_execute"],
      type="directory",
      owner="hdfs",
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/user/ambari-qa"),
      type="directory",
      action=["create_on_execute"],
      mode=0o770,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/user/oozie"),
      owner="oozie",
      type="directory",
      action=["create_on_execute"],
      mode=0o775,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/app-logs"),
      recursive_chmod=True,
      owner="yarn",
      group="hadoop",
      type="directory",
      action=["create_on_execute"],
      mode=0o777,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/tmp/entity-file-history/active"),
      owner="yarn",
      group="hadoop",
      type="directory",
      action=["create_on_execute"],
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/mapred"),
      owner="mapred",
      type="directory",
      action=["create_on_execute"],
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/mapred/system"),
      owner="hdfs",
      type="directory",
      action=["create_on_execute"],
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/mr-history/done"),
      change_permissions_for_parents=True,
      owner="mapred",
      group="hadoop",
      type="directory",
      action=["create_on_execute"],
      mode=0o777,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/user/yarn-ats"),
      owner="yarn-ats",
      type="directory",
      action=["create_on_execute"],
      mode=0o755,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/atshistory/done"),
      owner="yarn",
      group="hadoop",
      type="directory",
      action=["create_on_execute"],
      mode=0o700,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/atshistory/active"),
      owner="yarn",
      group="hadoop",
      type="directory",
      action=["create_on_execute"],
      mode=0o1777,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/ams/hbase"),
      owner="ams",
      type="directory",
      action=["create_on_execute"],
      mode=0o775,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/amshbase/staging"),
      owner="ams",
      type="directory",
      action=["create_on_execute"],
      mode=0o711,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/user/ams/hbase"),
      owner="ams",
      type="directory",
      action=["create_on_execute"],
      mode=0o775,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/hdp"),
      owner="hdfs",
      type="directory",
      action=["create_on_execute"],
      mode=0o755,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/user/spark"),
      owner="spark",
      group="hadoop",
      type="directory",
      action=["create_on_execute"],
      mode=0o775,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/user/livy"),
      owner="livy",
      group="hadoop",
      type="directory",
      action=["create_on_execute"],
      mode=0o775,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/hdp/spark-events"),
      owner="spark",
      group="hadoop",
      type="directory",
      action=["create_on_execute"],
      mode=0o777,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/hdp/spark2-events"),
      owner="spark",
      group="hadoop",
      type="directory",
      action=["create_on_execute"],
      mode=0o777,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/hbase"),
      owner="hbase",
      type="directory",
      action=["create_on_execute"],
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/apps/hbase/staging"),
      owner="hbase",
      type="directory",
      action=["create_on_execute"],
      mode=0o711,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/user/hbase"),
      owner="hbase",
      type="directory",
      action=["create_on_execute"],
      mode=0o755,
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/apps/zeppelin"),
      owner="zeppelin",
      group="hadoop",
      type="directory",
      action=["create_on_execute"],
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/user/zeppelin"),
      owner="zeppelin",
      group="hadoop",
      type="directory",
      action=["create_on_execute"],
    )
    params.HdfsResource(
      format("{hdfs_path_prefix}/user/zeppelin/test"),
      owner="zeppelin",
      group="hadoop",
      type="directory",
      action=["create_on_execute"],
    )