KieServices ks = KieServices.Factory.get();
KieFileSystem kfs = ks.newKieFileSystem();
kfs.write(ResourceFactory.newFileResource(new File("hdfs:////tthrniapp4:54310/user/hive/warehouse/eventsdrl/Sample.drl")));
KieBuilder kieBuilder = ks.newKieBuilder(kfs).buildAll();
KieContainer kieContainer = ks.newKieContainer(ks.getRepository().getDefaultReleaseId());
KieBaseConfiguration kbconf = ks.newKieBaseConfiguration();
KieBase kb =kieContainer.newKieBase(kbconf);
KieSession ksession = kb.newKieSession();
ksession.insert(fl);
ksession.insert(eventMethod);
ksession.insert(eventsPojo);
ksession.fireAllRules();