本文主要记录电力行业客户的数据湖技术方案实践案例，方案概括为基于FlinkSQL+Hudi流式入湖、同步表元数据到Hive，基于Hive catalog统一元数据管理，然后基于Hive on Spark离线分析计算。该方案主要考虑与已有Hive数据仓库...
根据《用Java、Python来开发Hive应用》一文，建立了使用Java、来开发Hive应用的方法，产生的代码如下（做了修改）：
根据《用Java、Python来开发Hive应用》一文，建立了使用Python、来开发Hive应用的方法，产生的代码如下（做了修改）：
在hive配置文件：%HIVE_HOME%/conf/hive-site.xml添加
（2）UDAF（User-Defined Aggregation Function）
INNER JOIN内连接：只有进行连接的两个表中都存在与连接条件相匹配的数据才会被保留下来。
hive> SELECT [ALL | DISTINCT] SELECT_expr, SELECT_expr, ... FROM table_reference
然后挂了FAILED: SemanticException [Error 10081]: UDTF's are not supported outside the SELECT clause, nor nested in expressions
在Linux Shell 下可以一次性使用hive命令（假设demo.person表已经存在，后面介绍）
