Skip to content

G
gic-spark-tag-4.0
Commit 4fa3059d by guos
Options

会员标签4.0

parent 1c5ed4fd
Showing with 1 additions and 1 deletions
src/main/java/com/gic/spark/filter/TagLatelyConsumeCommodityFilter.java
...@@ -61,7 +61,7 @@ public class TagLatelyConsumeCommodityFilter extends AbstractTagConsumRecordFilt ...@@ -61,7 +61,7 @@ public class TagLatelyConsumeCommodityFilter extends AbstractTagConsumRecordFilt
}) })
.mapToPair(data->Tuple2.apply(data._2().getVirtual_id(),data._1())); .mapToPair(data->Tuple2.apply(data._2().getVirtual_id(),data._1()));
JavaPairRDD<Long,Long> orderItemRDD=MysqlRddManager.getPojoFromDataset(dataSourceHiveOrderItem.getDatasetByEnterpriseId(enterpriseId),TrdVirtualOrderItemBean.class).javaRDD() JavaPairRDD<Long,Long> orderItemRDD=MysqlRddManager.getPojoFromDataset(dataSourceHiveOrderItem.getDatasetByEntId(enterpriseId),TrdVirtualOrderItemBean.class).javaRDD()
.filter(data->{ .filter(data->{
if(StringUtils.isNotEmpty(data.getSku_code()) if(StringUtils.isNotEmpty(data.getSku_code())
&&commodityRequest.getSkuCodeList().contains(data.getSku_code())){ &&commodityRequest.getSkuCodeList().contains(data.getSku_code())){
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment