class LocalStreamService extends AbstractService implements
ConfigConstants {

  @SuppressWarnings("unchecked")
  protected Class<? extends Mapper<Text, FileStatus, NullWritable, Text>> getMapperClass() {
    String className = srcCluster.getCopyMapperImpl();
    if (className == null || className.isEmpty()) {
      return CopyMapper.class;
    } else {
      try {
        return (Class<? extends Mapper<Text, FileStatus, NullWritable, Text>>) Class
            .forName(className);
      } catch (ClassNotFoundException e) {
        throw new IllegalArgumentException("Copy mapper Impl " + className
            + "is not found in class path");
      }
    }
  }

  public  LocalStreamService(ConduitConfig config, Cluster srcCluster,
      Cluster currentCluster, CheckpointProvider provider,
      Set<String> streamsToProcess);

}