Add operations to increase counter of tripletype and rule during

reasoning

Author: gibeon

mrj-0.1/src/cn/edu/neu/mitt/mrj/io/dbs/CassandraDB.java

@@ -63,6 +63,7 @@
 import com.datastax.driver.core.querybuilder.QueryBuilder;
 
 
+
 //modified 
 import org.apache.cassandra.thrift.CassandraServer;
 
@@ -414,7 +415,7 @@ public void increaseTripletypeCounter(int field)
         args.add(ByteBufferUtil.bytes(field));
         CqlPreparedResult p_result = client.prepare_cql3_query(ByteBufferUtil.bytes(query), Compression.NONE);
         CqlResult result = client.execute_prepared_cql3_query(p_result.itemId, args, ConsistencyLevel.ONE);
-        logger.info("Increase TripletypeCounter of " + field + ": " + result.getNum());
+//        logger.info("Increase TripletypeCounter of " + field + ": " + result.getNum());
 	}
 
 	public static Triple readJustificationFromMapReduceRow(Row row){
@@ -481,6 +482,19 @@ public static void writeJustificationToMapReduceContext(
     	variables.add(ByteBufferUtil.bytes(source.getStep()));		// It corresponds to COLUMN_INFERRED_STEPS where steps = 0 means an original triple 
         context.write(keys, variables);
 
+		// Added by WuGang, 2015-06-03
+		try{
+			CassandraDB db = new CassandraDB();
+			db.increaseTripletypeCounter(tripletype);
+			db.increaseRuleCounter((int)triple.getType());
+			db.close();
+		}catch (TTransportException e) {
+			e.printStackTrace();
+		} catch (InvalidRequestException e) {
+			e.printStackTrace();
+		} catch (TException e) {
+			e.printStackTrace();
+		}
 	}
 
 	public boolean loadSetIntoMemory(Set<Long> schemaTriples, Set<Integer> filters, int previousStep) throws IOException, InvalidRequestException, UnavailableException, TimedOutException, SchemaDisagreementException, TException {