This follows my earlier Part 3 posting in May.
I have integrated the Bayesian System into the Truth Maintenance System, with a first end to end test. It’s still very raw, but it demonstrates how the TMS can be used to provide evidence via logical insertions.
The BBN variables are mapped to fields on the Garden class. Evidence is applied as a logical insert, using a property reference – indicating it’s evidence for the variable mapped to that property. If there is conflict evidence for the same field, then the fact becomes undecided.
The rules are added via a String, while the BBN is added from a file. This code uses the new pluggable knowledge types, which allow pluggable parsers, builders and runtimes. This is how the Bayesian stuff is added cleanly, without touching the core – but I’ll blog about those another time.
I have integrated the Bayesian System into the Truth Maintenance System, with a first end to end test. It’s still very raw, but it demonstrates how the TMS can be used to provide evidence via logical insertions.
The BBN variables are mapped to fields on the Garden class. Evidence is applied as a logical insert, using a property reference – indicating it’s evidence for the variable mapped to that property. If there is conflict evidence for the same field, then the fact becomes undecided.
The rules are added via a String, while the BBN is added from a file. This code uses the new pluggable knowledge types, which allow pluggable parsers, builders and runtimes. This is how the Bayesian stuff is added cleanly, without touching the core – but I’ll blog about those another time.
String drlString = "package org.drools.bayes; " +
"import " + Garden.class.getCanonicalName() + "; n" +
"import " + PropertyReference.class.getCanonicalName() + "; n" +
"global " + BayesBeliefFactory.class.getCanonicalName() + " bsFactory; n" +
"dialect 'mvel'; n" +
" " +
"rule rule1 when " +
" String( this == 'rule1') n" +
" g : Garden()" +
"then " +
" System.out.println("rule 1"); n" +
" insertLogical( new PropertyReference(g, 'cloudy'), bsFactory.create( new double[] {1.0,0.0} ) ); n " +
"end " +
"rule rule2 when " +
" String( this == 'rule2') n" +
" g : Garden()" +
"then " +
" System.out.println("rule2"); n" +
" insertLogical( new PropertyReference(g, 'sprinkler'), bsFactory.create( new double[] {1.0,0.0} ) ); n " +
"end " +
"rule rule3 when " +
" String( this == 'rule3') n" +
" g : Garden()" +
"then " +
" System.out.println("rule3"); n" +
" insertLogical( new PropertyReference(g, 'sprinkler'), bsFactory.create( new double[] {1.0,0.0} ) ); n " +
"end " +
"rule rule4 when " +
" String( this == 'rule4') n" +
" g : Garden()" +
"then " +
" System.out.println("rule4"); n" +
" insertLogical( new PropertyReference(g, 'sprinkler'), bsFactory.create( new double[] {0.0,1.0} ) ); n " +
"end " +
"n";
KnowledgeBuilder kBuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
kBuilder.add( ResourceFactory.newByteArrayResource(drlString.getBytes()),
ResourceType.DRL );
kBuilder.add( ResourceFactory.newClassPathResource("Garden.xmlbif", AssemblerTest.class), ResourceType.BAYES );
KnowledgeBase kBase = KnowledgeBaseFactory.newKnowledgeBase();
kBase.addKnowledgePackages( kBuilder.getKnowledgePackages() );
StatefulKnowledgeSession kSession = kBase.newStatefulKnowledgeSession();
NamedEntryPoint ep = (NamedEntryPoint) ksession.getEntryPoint(EntryPointId.DEFAULT.getEntryPointId());
BayesBeliefSystem bayesBeliefSystem = new BayesBeliefSystem( ep, ep.getTruthMaintenanceSystem());
BayesBeliefFactoryImpl bayesBeliefValueFactory = new BayesBeliefFactoryImpl(bayesBeliefSystem);
ksession.setGlobal( "bsFactory", bayesBeliefValueFactory);
BayesRuntime bayesRuntime = ksession.getKieRuntime(BayesRuntime.class);
BayesInstance<Garden> instance = bayesRuntime.createInstance(Garden.class);
assertNotNull( instance );
assertTrue(instance.isDecided());
instance.globalUpdate();
Garden garden = instance.marginalize();
assertTrue( garden.isWetGrass() );
FactHandle fh = ksession.insert( garden );
FactHandle fh1 = ksession.insert( "rule1" );
ksession.fireAllRules();
assertTrue(instance.isDecided());
instance.globalUpdate(); // rule1 has added evidence, update the bayes network
garden = instance.marginalize();
assertTrue(garden.isWetGrass()); // grass was wet before rule1 and continues to be wet
FactHandle fh2 = ksession.insert( "rule2" ); // applies 2 logical insertions
ksession.fireAllRules();
assertTrue(instance.isDecided());
instance.globalUpdate();
garden = instance.marginalize();
assertFalse(garden.isWetGrass() ); // new evidence means grass is no longer wet
FactHandle fh3 = ksession.insert( "rule3" ); // adds an additional support for the sprinkler, belief set of 2
ksession.fireAllRules();
assertTrue(instance.isDecided());
instance.globalUpdate();
garden = instance.marginalize();
assertFalse(garden.isWetGrass() ); // nothing has changed
FactHandle fh4 = ksession.insert( "rule4" ); // rule4 introduces a conflict, and the BayesFact becomes undecided
ksession.fireAllRules();
assertFalse(instance.isDecided());
try {
instance.globalUpdate();
fail( "The BayesFact is undecided, it should throw an exception, as it cannot be updated." );
} catch ( Exception e ) {
// this should fail
}
ksession.delete( fh4 ); // the conflict is resolved, so it should be decided again
ksession.fireAllRules();
assertTrue(instance.isDecided());
instance.globalUpdate();
garden = instance.marginalize();
assertFalse(garden.isWetGrass() );// back to grass is not wet
ksession.delete( fh2 ); // takes the sprinkler belief set back to 1
ksession.fireAllRules();
instance.globalUpdate();
garden = instance.marginalize();
assertFalse(garden.isWetGrass() ); // still grass is not wet
ksession.delete( fh3 ); // no sprinkler support now
ksession.fireAllRules();
instance.globalUpdate();
garden = instance.marginalize();
assertTrue(garden.isWetGrass()); // grass is wet again
