用于在hadoop中转换表的Python代码

from pyhive import hive

# 连接到Hive服务器
conn = hive.Connection(host='your_hive_host', port=10000, username='your_username')

# 创建一个Hive表
create_table_query = '''
CREATE TABLE IF NOT EXISTS my_table (
    column1 INT,
    column2 STRING,
    column3 DOUBLE
)
ROW FORMAT DELIMITED
FIELDS TERMINATED BY ','
STORED AS TEXTFILE
'''
with conn.cursor() as cursor:
    cursor.execute(create_table_query)

# 导入数据到Hive表
load_data_query = '''
LOAD DATA INPATH 'hdfs://path_to_input_file' INTO TABLE my_table
'''
with conn.cursor() as cursor:
    cursor.execute(load_data_query)

# 查询Hive表
select_query = '''
SELECT * FROM my_table
'''
with conn.cursor() as cursor:
    cursor.execute(select_query)
    results = cursor.fetchall()
    for row in results:
        print(row)

# 关闭连接
conn.close()