我已经执行了下面的代码,用于从 .xdf 文件中选择行和列并创建一个新的 .xdf 文件,但它不起作用。以下是执行后显示的代码和消息:
S_date <- as.Date("2014-05-01")
rxDataStepXdf(inFile = "/poc/revor/data/ext_merchant_account.xdf",
outFile = "/poc/revor/data/ext_merchant_account_filtered.xdf",
rowSelection = ((CUR_MER_STA_CD %in% c("A","R")) &
(CLNT_MAN_CHAN_CD %in% c("I","X"," ")) &
(MER_SETUP_DT < S_date)),
varsToKeep = c("SE_NO","SEIMS_INDUS_DS_CD"),
transformObjects = list(S_date = S_date),
overwrite = TRUE)
信息 :
WARNING: No data was written to the output data source.
下面是 .Xdf 文件结构:
File name: /poc/revor/data/ext_merchant_account.xdf
Number of observations: 13529673
Number of variables: 74
Number of blocks: 136
Compression type: zlib
只想根据某些条件过滤行和列,但未创建输出 .xdf 文件。
我运行代码的环境:
Revolution R enviornment on Hadoop cluster.
谁能指出我在这里做的错误。
感谢您提前提供的帮助.... :)
干杯,
阿米特