added cache

Author: Nitish1814

common/core/src/main/java/zingg/common/core/executor/Trainer.java

@@ -29,9 +29,8 @@ public void execute() throws ZinggClientException {
 			ZFrame<D,R,C> positives = null;
 			ZFrame<D,R,C> negatives = null;
 			ZFrame<D,R,C> traOriginal = getDSUtil().getTraining(getPipeUtil(), args, getModelHelper());
-			ZFrame<D,R,C> tra = preprocess(traOriginal);
+			ZFrame<D,R,C> tra = preprocess(traOriginal).cache();
 			tra = getDSUtil().joinWithItself(tra, ColName.CLUSTER_COLUMN, true);
-			tra = tra.cache();
 			positives = tra.filter(tra.equalTo(ColName.MATCH_FLAG_COL,ColValues.MATCH_TYPE_MATCH));
 			negatives = tra.filter(tra.equalTo(ColName.MATCH_FLAG_COL,ColValues.MATCH_TYPE_NOT_A_MATCH));
 

common/core/src/main/java/zingg/common/core/executor/TrainingDataFinder.java

@@ -47,7 +47,7 @@ public void execute() throws ZinggClientException {
 				ZFrame<D,R,C> trFile = getTraining();					
 
 				if (trFile != null) {
-					trFile = preprocess(trFile);
+					trFile = preprocess(trFile).cache();
 					ZFrame<D,R,C> trPairs = getDSUtil().joinWithItself(trFile, ColName.CLUSTER_COLUMN, true);
 
 						posPairs = trPairs.filter(trPairs.equalTo(ColName.MATCH_FLAG_COL, ColValues.MATCH_TYPE_MATCH));