第1个问题,datasetName要改成: "candle_201801.csv";
第2个问题,是因为导入的文件字段,tradingDay,默认不是date型,现新版本,loadHDF5Ex增加,transform函数,可以将数据类型进行转换,教程里面的可以修改为如下:
def datechange(mutable t){
return t.replaceColumn!(`tradingDay, t.tradingDay.format("00000000").temporalParse("yyyyMMdd") )
}
schemaHd = hdf5::extractHDF5Schema(dir+n, datasetName);
update schemaHd set type = `DATE where name = `tradingDay;
tb = table(1:0, schemaHd.name , schemaHd.type);
db.createPartitionedTable(tb, `cycle, `tradingDay)
hdf5::loadHDF5Ex(db, `cycle, `tradingDay, dir+n, datasetName ,,,, datechange);
详细教程请参考: