Skip to content

Hive MongoDB 需要加入的 lib

file:///Users/zhenqin/software/hive/lib/mongo-hadoop-core-1.5.2.jar,
file:///Users/zhenqin/software/hive/lib/mongo-hadoop-hive-1.5.2.jar,
file:///Users/zhenqin/software/hive/lib/mongo-java-driver-3.2.2.jar

股票基础数据表(最新到2017年-2月-23日收盘):

CREATE TABLE ivy_stock_info
( 
    id string,
    name string,
    area string,
    industry string,
    profit float,
    timeToMarket int,
    esp  float,
    reserved float, 
    outstanding float, 
    totalAssets float, 
    rev float, 
    totals float, 
    pb float, 
    fixedAssets float, 
    pe float, 
    gpr float, 
    undp float, 
    perundp float, 
    npr float, 
    reservedPerShare float, 
    liquidAssets float, 
    bvps float, 
    holders int
)
STORED BY 'com.mongodb.hadoop.hive.MongoStorageHandler' 
WITH SERDEPROPERTIES('mongo.columns.mapping'='{"id":"_id"}') 
TBLPROPERTIES('mongo.uri'='mongodb://localhost:27017/ivystock.ivy_stock_info');

股票日线数据:

CREATE TABLE yii_stock_day
(  
    id string, 
    volume float, 
    v_ma10 float, 
    v_ma20 float, 
    ma5    float, 
    price_change float, 
    v_ma5 float, 
    p_change float, 
    high float, 
    code string, 
    ma20 float, 
    low   float, 
    datee timestamp, 
    close float, 
    pre_close float,
    open float, 
    ma10 float, 
    turnover float
)
STORED BY 'com.mongodb.hadoop.hive.MongoStorageHandler' 
WITH SERDEPROPERTIES('mongo.columns.mapping'='{"id":"_id", "datee":"date"}') 
TBLPROPERTIES('mongo.uri'='mongodb://localhost:27017/ivystock.yii_stock_day');

OK