diff --git a/common/core/src/main/java/zingg/common/core/executor/Linker.java b/common/core/src/main/java/zingg/common/core/executor/Linker.java
index c271a2161..896c5f7ab 100644
--- a/common/core/src/main/java/zingg/common/core/executor/Linker.java
+++ b/common/core/src/main/java/zingg/common/core/executor/Linker.java
@@ -55,12 +55,19 @@ public void writeOutput(ZFrame<D,R,C> sampleOrginal, ZFrame<D,R,C> dupes) throws
 				dupesActual = getDSUtil().addUniqueCol(dupesActual, ColName.CLUSTER_COLUMN);
 				ZFrame<D,R,C>dupes2 =  getDSUtil().alignLinked(dupesActual, args);
 				dupes2 =  getDSUtil().postprocessLinked(dupes2, sampleOrginal);
-				LOG.debug("uncertain output schema is " + dupes2.showSchema());
-				getPipeUtil().write(dupes2, args.getOutput());
+				ZFrame<D, R, C> clusterAdjustedDF = getClusterAdjustedDF(dupes2);
+				LOG.debug("uncertain output schema is " + clusterAdjustedDF.showSchema());
+				getPipeUtil().write(clusterAdjustedDF, args.getOutput());
 			}
 		} catch (Exception e) {
 			e.printStackTrace();
 		}
 	}
 
+	public ZFrame<D,R,C> getClusterAdjustedDF(ZFrame<D, R, C> dupes) {
+		//no adjustment required here
+		//some class extending it may adjust cluster like adding guid etc
+		return dupes;
+	}
+
 }