zoukankan      html  css  js  c++  java
  • hive的动态分区

    hive >

    set hive.exec.dynamic.partition.mode=nonstrict;--设置hive执行器的动态分区(dynamic partition)模式为非严格模式(nonstrict)

    set hive.input.format=org.apache.hadoop.hive.ql.io.HiveInputFormat;

    insert overwrite table dwd_fact_order_info partition(dt)

    select

        

      `id` string COMMENT '订单编号',

        `order_status` string COMMENT '订单状态',

        `user_id` string COMMENT '用户id',

        `out_trade_no` string COMMENT '支付流水号',

        `create_time` string COMMENT '创建时间(未支付状态)',

        `payment_time` string COMMENT '支付时间(已支付状态)',

        `cancel_time` string COMMENT '取消时间(已取消状态)',

        `finish_time` string COMMENT '完成时间(已完成状态)',

        `refund_time` string COMMENT '退款时间(退款中状态)',

        `refund_finish_time` string COMMENT '退款完成时间(退款完成状态)',

        `province_id` string COMMENT '省份ID',

        `activity_id` string COMMENT '活动ID',

        `original_total_amount` decimal(16,2) COMMENT '原价金额',

        `benefit_reduce_amount` decimal(16,2) COMMENT '优惠金额',

        `feight_fee` decimal(16,2) COMMENT '运费',

        `final_total_amount` decimal(16,2) COMMENT '订单金额'

        date_format(if(new.tms['1001'] is null,old.create_time,new.tms['1001']),'yyyy-MM-dd')---这个字段时读出来的字段,自动作为动态分区的字段。

    from

      table_fact

     

  • 相关阅读:
    elasticsearch之聚合函数
    elasticsearch之高亮查询
    elasticsearch之查询结果过滤
    elasticsearch之布尔查询
    elasticsearch之分页查询
    elasticsearch 之 排序查询
    elasticsearch 查询 term和match
    WSGI uwsgi wsgiref uWSGI werkzeug
    Django Contenttype组件
    迭代器
  • 原文地址:https://www.cnblogs.com/zhipeng-wang/p/14526645.html
Copyright © 2011-2022 走看看