oracle 到hive
{
"job": {
"jobId": "${jobId}",
"jobVersionId": "${jobVersionId}",
"executeId": "${executeId}",
"serverPort": "${serverPort}",
"msg": "${msg}",
"setting": {
"speed": {
"channel": "1"
},
"errorLimit": {}
},
"content": [
{
"reader": {
"name": "oraclereader",
"parameter": {
"username": "taquery",
"password": "natx_2003",
"column": [
""TRANSACTIONCFMDATE"",
""INCOMEDATE"",
""TANO"",
""CUSTNO"",
""INVESTORNAME"",
""TAACCOUNTID"",
""DISTRIBUTORCODE"",
""TRANSACTIONACCOUNTID"",
""BRANCHCODE"",
""INVTP"",
""FUNDCODE"",
""SHARETYPE"",
""LAST_SHARECLASS"",
""SHARECLASS"",
""BASEFUNDVOL"",
""TAFUNDVOL"",
""MINUSFUNDVOL"",
""LAST_UNCOME"",
""UNCOME"",
""LAST_UNFOOTINCOME"",
""UNFOOTINCOME"",
""LAST_UNFOOTFROZENINCOME"",
""UNFOOTFROZENINCOME"",
""INCOMECHG"",
""DISPERSION"",
""FOOTINCOME"",
""TOTINVESTAMT"",
""TOTINCOMEAMT"",
""REDEEMVOL"",
""LASTUPDATEDATE"",
""LAST_ABNMFROZEN""
],
"connection": [
{
"table": [
""KDSSTA"."BAL_INCOME""
],
"jdbcUrl": [
"jdbc:oracle:thin:@10.20.0.102:1521:nata2"
]
}
],
"where": "1=1 and ("INCOMEDATE" >='${ld_beginDate}') and ("INCOMEDATE" <='${ld_endDate}')"
}
},
"writer": {
"name": "hivewriter",
"parameter": {
"jdbcUrl": "jdbc:hive2://10.32.11.3:10000/ld",
"databaseName": "ld",
"tableName": "`ssta_bal_income`",
"defaultFS": "hdfs://10.32.11.1:8020",
"writeMode": "truncate",
"column": [
{
"name": "`transactioncfmdate`",
"type": "string"
},
{
"name": "`incomedate`",
"type": "string"
},
{
"name": "`tano`",
"type": "string"
},
{
"name": "`custno`",
"type": "string"
},
{
"name": "`investorname`",
"type": "string"
},
{
"name": "`taaccountid`",
"type": "string"
},
{
"name": "`distributorcode`",
"type": "string"
},
{
"name": "`transactionaccountid`",
"type": "string"
},
{
"name": "`branchcode`",
"type": "string"
},
{
"name": "`invtp`",
"type": "string"
},
{
"name": "`fundcode`",
"type": "string"
},
{
"name": "`sharetype`",
"type": "string"
},
{
"name": "`last_shareclass`",
"type": "string"
},
{
"name": "`shareclass`",
"type": "string"
},
{
"name": "`basefundvol`",
"type": "decimal(16,2)"
},
{
"name": "`tafundvol`",
"type": "decimal(16,2)"
},
{
"name": "`minusfundvol`",
"type": "decimal(16,2)"
},
{
"name": "`last_uncome`",
"type": "decimal(16,2)"
},
{
"name": "`uncome`",
"type": "decimal(16,2)"
},
{
"name": "`last_unfootincome`",
"type": "decimal(16,2)"
},
{
"name": "`unfootincome`",
"type": "decimal(16,2)"
},
{
"name": "`last_unfootfrozenincome`",
"type": "decimal(16,2)"
},
{
"name": "`unfootfrozenincome`",
"type": "decimal(16,2)"
},
{
"name": "`incomechg`",
"type": "decimal(16,2)"
},
{
"name": "`dispersion`",
"type": "decimal(9,8)"
},
{
"name": "`footincome`",
"type": "decimal(16,2)"
},
{
"name": "`totinvestamt`",
"type": "decimal(16,2)"
},
{
"name": "`totincomeamt`",
"type": "decimal(16,2)"
},
{
"name": "`redeemvol`",
"type": "decimal(16,2)"
},
{
"name": "`lastupdatedate`",
"type": "string"
},
{
"name": "`last_abnmfrozen`",
"type": "decimal(16,2)"
}
],
"originalColumn": [
{
"name": "`transactioncfmdate`",
"type": "string"
},
{
"name": "`incomedate`",
"type": "string"
},
{
"name": "`tano`",
"type": "string"
},
{
"name": "`custno`",
"type": "string"
},
{
"name": "`investorname`",
"type": "string"
},
{
"name": "`taaccountid`",
"type": "string"
},
{
"name": "`distributorcode`",
"type": "string"
},
{
"name": "`transactionaccountid`",
"type": "string"
},
{
"name": "`branchcode`",
"type": "string"
},
{
"name": "`invtp`",
"type": "string"
},
{
"name": "`fundcode`",
"type": "string"
},
{
"name": "`sharetype`",
"type": "string"
},
{
"name": "`last_shareclass`",
"type": "string"
},
{
"name": "`shareclass`",
"type": "string"
},
{
"name": "`basefundvol`",
"type": "decimal(16,2)"
},
{
"name": "`tafundvol`",
"type": "decimal(16,2)"
},
{
"name": "`minusfundvol`",
"type": "decimal(16,2)"
},
{
"name": "`last_uncome`",
"type": "decimal(16,2)"
},
{
"name": "`uncome`",
"type": "decimal(16,2)"
},
{
"name": "`last_unfootincome`",
"type": "decimal(16,2)"
},
{
"name": "`unfootincome`",
"type": "decimal(16,2)"
},
{
"name": "`last_unfootfrozenincome`",
"type": "decimal(16,2)"
},
{
"name": "`unfootfrozenincome`",
"type": "decimal(16,2)"
},
{
"name": "`incomechg`",
"type": "decimal(16,2)"
},
{
"name": "`dispersion`",
"type": "decimal(9,8)"
},
{
"name": "`footincome`",
"type": "decimal(16,2)"
},
{
"name": "`totinvestamt`",
"type": "decimal(16,2)"
},
{
"name": "`totincomeamt`",
"type": "decimal(16,2)"
},
{
"name": "`redeemvol`",
"type": "decimal(16,2)"
},
{
"name": "`lastupdatedate`",
"type": "string"
},
{
"name": "`last_abnmfrozen`",
"type": "decimal(16,2)"
}
]
}
}
}
]
}
}
