class MirrorStreamValidator extends AbstractStreamValidator {

  public MirrorStreamValidator(ConduitConfig conduitConfig,
      String streamName, String clusterName, boolean fix, Date startTime,
      Date stopTime, int numThreads) {
    this.conduitConfig = conduitConfig;
    this.streamName = streamName;
    this.fix = fix;  
    // get the source cluster where merge stream service is running
    mergedCluster = conduitConfig.getPrimaryClusterForDestinationStream(streamName);
    // get the dest cluster where mirror stream service is running
    mirrorCluster = conduitConfig.getClusters().get(clusterName);
    this.startTime = startTime;
    this.stopTime = stopTime;
    this.numThreads = numThreads;
  }

  public  MirrorStreamValidator(ConduitConfig conduitConfig,
      String streamName, String clusterName, boolean fix, Date startTime,
      Date stopTime, int numThreads);

}