v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/utils/ShardingLogicImplFetcher.java [34:51]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public static synchronized IShardIdFetcher getShardingLogicImpl(
      String customJarPath,
      String shardingCustomClassName,
      String shardingCustomParameters,
      Schema schema,
      String skipDirName) {

    if (shardIdFetcher == null) {
      shardIdFetcher =
          getShardIdFetcherImpl(
              customJarPath,
              shardingCustomClassName,
              shardingCustomParameters,
              schema,
              skipDirName);
    }
    return shardIdFetcher;
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/ShardingLogicImplFetcher.java [46:63]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public static synchronized IShardIdFetcher getShardingLogicImpl(
      String customJarPath,
      String shardingCustomClassName,
      String shardingCustomParameters,
      Schema schema,
      String skipDirName) {

    if (shardIdFetcher == null) {
      shardIdFetcher =
          getShardIdFetcherImpl(
              customJarPath,
              shardingCustomClassName,
              shardingCustomParameters,
              schema,
              skipDirName);
    }
    return shardIdFetcher;
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -