0

我已经执行了下面的代码,用于从 .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.

谁能指出我在这里做的错误。

感谢您提前提供的帮助.... :)

干杯,

阿米特

4

0 回答 0