如何在FlinkSQL中创建和管理临时表与永久表？

-- 示例1：创建Hive永久表（批流一体）
CREATE TABLE hive_orders (
  order_id STRING,
  amount DOUBLE,
  event_time TIMESTAMP(3),
  WATERMARK FOR event_time AS event_time - INTERVAL '5' SECOND
) PARTITIONED BY (dt STRING)
WITH (
  'connector' = 'hive',
  'uri' = 'thrift://hive-metastore:9083',
  'table-name' = 'orders'
);

DROP TABLE IF EXISTS hive_orders;

-- 示例1：从Kafka创建临时表（含事件时间与水印）
CREATE TEMPORARY TABLE kafka_orders (
  order_id STRING,
  amount DOUBLE,
  event_time TIMESTAMP(3),
  WATERMARK FOR event_time AS event_time - INTERVAL '5' SECOND
) WITH (
  'connector' = 'kafka',
  'topic' = 'orders_topic',
  'properties.bootstrap.servers' = 'localhost:9092',
  'format' = 'json'
);

DROP TEMPORARY TABLE IF EXISTS kafka_orders;