????????????
     
??????????????kylin????????????????????????kylin.source.hive.keep-flat-table??????????????true??????????????hive????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????
????????????????????????????????????cube????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????


??????????
 private String cleanUpIntermediateFlatTable(KylinConfig config) throws 
IOException {
            StringBuffer output = new StringBuffer();
            final HiveCmdBuilder hiveCmdBuilder = new HiveCmdBuilder();
            final List<String> hiveTables = this.getIntermediateTables();
            for (String hiveTable : hiveTables) {
                if (config.isHiveKeepFlatTable() == false && 
StringUtils.isNotEmpty(hiveTable)) {
                    hiveCmdBuilder.addStatement("USE " + 
config.getHiveDatabaseForIntermediateTable() + ";");
                    hiveCmdBuilder.addStatement("DROP TABLE IF EXISTS  " + 
hiveTable + ";");


                    output.append("Hive table " + hiveTable + " is dropped. 
\n");
                }
            }
            config.getCliCommandExecutor().execute(hiveCmdBuilder.build());
            rmdirOnHDFS(getExternalDataPaths());
            output.append("Path " + getExternalDataPaths() + " is deleted. \n");


            return output.toString();
        }

Reply via email to