减少数据集按股票分组字符串分配
This commit is contained in:
@@ -1304,10 +1304,11 @@ impl DataSet {
|
|||||||
sort_groups_by_symbol(&mut factor_by_date, |item| item.symbol.as_str());
|
sort_groups_by_symbol(&mut factor_by_date, |item| item.symbol.as_str());
|
||||||
let mut market_rows_by_symbol = AHashMap::<String, Vec<&DailyMarketSnapshot>>::new();
|
let mut market_rows_by_symbol = AHashMap::<String, Vec<&DailyMarketSnapshot>>::new();
|
||||||
for row in market_by_date.values().flatten() {
|
for row in market_by_date.values().flatten() {
|
||||||
market_rows_by_symbol
|
if let Some(rows) = market_rows_by_symbol.get_mut(row.symbol.as_str()) {
|
||||||
.entry(row.symbol.clone())
|
rows.push(row);
|
||||||
.or_default()
|
continue;
|
||||||
.push(row);
|
}
|
||||||
|
market_rows_by_symbol.insert(row.symbol.clone(), vec![row]);
|
||||||
}
|
}
|
||||||
let market_rows_by_symbol = market_rows_by_symbol.into_iter().collect::<Vec<_>>();
|
let market_rows_by_symbol = market_rows_by_symbol.into_iter().collect::<Vec<_>>();
|
||||||
let market_series_by_symbol = market_rows_by_symbol
|
let market_series_by_symbol = market_rows_by_symbol
|
||||||
|
|||||||
Reference in New Issue
Block a user