Commit 761ab623 authored by she's avatar she

增加混合平台模式 1

parent bdeb0290
...@@ -4,13 +4,11 @@ import com.fshark.overseas.advert.modle.AppsFlyerEvent; ...@@ -4,13 +4,11 @@ import com.fshark.overseas.advert.modle.AppsFlyerEvent;
import org.apache.flink.streaming.api.functions.ProcessFunction; import org.apache.flink.streaming.api.functions.ProcessFunction;
import org.apache.flink.util.Collector; import org.apache.flink.util.Collector;
import java.util.ArrayList;
import java.util.List;
public class MutiplatDataProcess extends ProcessFunction<AppsFlyerEvent, AppsFlyerEvent> { public class MutiplatDataProcess extends ProcessFunction<AppsFlyerEvent, AppsFlyerEvent> {
//需要混合的包名 //需要混合的包名
private String[] packages = {"com.chaosportal.samsung", "com.chaosportal.onestore", "com.chaosportal.shark"}; private String[] packages = {"com.chaosportal.samsung", "com.chaosportal.onestore", "com.chaosportal.shark","com.chaosportal.fshark"};
@Override @Override
public void processElement(AppsFlyerEvent value, ProcessFunction<AppsFlyerEvent, AppsFlyerEvent>.Context ctx, Collector<AppsFlyerEvent> out) throws Exception { public void processElement(AppsFlyerEvent value, ProcessFunction<AppsFlyerEvent, AppsFlyerEvent>.Context ctx, Collector<AppsFlyerEvent> out) throws Exception {
......
...@@ -94,7 +94,7 @@ public class OuidLoginProcess extends RichFlatMapFunction<AppsFlyerEvent, Activa ...@@ -94,7 +94,7 @@ public class OuidLoginProcess extends RichFlatMapFunction<AppsFlyerEvent, Activa
activationMetrics.setData_active_day_dau(1L); activationMetrics.setData_active_day_dau(1L);
} }
} }
if (EventTypeEnum.createRoleEvent(value)) { if (EventTypeEnum.roleEvent(value)) {
boolean isRole = false; boolean isRole = false;
Optional<GameAccount> accountCreateRole = gameAccountDao.findByOuid(value, ouid,Constants.TYPE_CREATEROLE); Optional<GameAccount> accountCreateRole = gameAccountDao.findByOuid(value, ouid,Constants.TYPE_CREATEROLE);
if (!accountCreateRole.isPresent()) { if (!accountCreateRole.isPresent()) {
......
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