in flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserQBParseInfo.java [375:415]
public boolean isSimpleSelectQuery() {
if (joinExpr != null
|| !destToOrderby.isEmpty()
|| !destToSortby.isEmpty()
|| !destToGroupby.isEmpty()
|| !destToClusterby.isEmpty()
|| !destToDistributeby.isEmpty()
|| !destRollups.isEmpty()
|| !destCubes.isEmpty()
|| !destGroupingSets.isEmpty()
|| !destToHaving.isEmpty()) {
return false;
}
for (Map<String, HiveParserASTNode> entry : destToAggregationExprs.values()) {
if (entry != null && !entry.isEmpty()) {
return false;
}
}
for (Map<String, HiveParserASTNode> entry : destToWindowingExprs.values()) {
if (entry != null && !entry.isEmpty()) {
return false;
}
}
for (List<HiveParserASTNode> ct : destToDistinctFuncExprs.values()) {
if (!ct.isEmpty()) {
return false;
}
}
// exclude insert queries
for (HiveParserASTNode v : nameToDest.values()) {
if (!(v.getChild(0).getType() == HiveASTParser.TOK_TMP_FILE)) {
return false;
}
}
return true;
}