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)"
}
]
}
}
}
]
}
}
