v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/transforms/AssignShardIdFn.java [380:420]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private Object getColumnValueFromJson(Column column, JsonNode valuesJson) throws Exception {
    try {
      Type colType = column.type();
      String colName = column.name();
      switch (colType.getCode()) {
        case BOOL:
        case PG_BOOL:
          return DataChangeRecordTypeConvertor.toBoolean(valuesJson, colName, false);
        case INT64:
        case PG_INT8:
          return DataChangeRecordTypeConvertor.toLong(valuesJson, colName, false);
        case FLOAT64:
        case PG_FLOAT8:
          return DataChangeRecordTypeConvertor.toDouble(valuesJson, colName, false);
        case STRING:
        case PG_VARCHAR:
        case PG_TEXT:
          return DataChangeRecordTypeConvertor.toString(valuesJson, colName, false);
        case NUMERIC:
        case PG_NUMERIC:
          return DataChangeRecordTypeConvertor.toNumericBigDecimal(valuesJson, colName, false);
        case JSON:
        case PG_JSONB:
          return DataChangeRecordTypeConvertor.toString(valuesJson, colName, false);
        case BYTES:
        case PG_BYTEA:
          return DataChangeRecordTypeConvertor.toByteArray(valuesJson, colName, false);
        case TIMESTAMP:
        case PG_TIMESTAMPTZ:
          return DataChangeRecordTypeConvertor.toTimestamp(valuesJson, colName, false);
        case DATE:
        case PG_DATE:
          return DataChangeRecordTypeConvertor.toDate(valuesJson, colName, false);
        default:
          throw new IllegalArgumentException(
              "Column name(" + colName + ") has unsupported column type(" + colType + ")");
      }
    } catch (Exception e) {
      throw new Exception("Error getting column value from json: " + e.getMessage());
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/AssignShardIdFn.java [368:408]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private Object getColumnValueFromJson(Column column, JsonNode valuesJson) throws Exception {
    try {
      Type colType = column.type();
      String colName = column.name();
      switch (colType.getCode()) {
        case BOOL:
        case PG_BOOL:
          return DataChangeRecordTypeConvertor.toBoolean(valuesJson, colName, false);
        case INT64:
        case PG_INT8:
          return DataChangeRecordTypeConvertor.toLong(valuesJson, colName, false);
        case FLOAT64:
        case PG_FLOAT8:
          return DataChangeRecordTypeConvertor.toDouble(valuesJson, colName, false);
        case STRING:
        case PG_VARCHAR:
        case PG_TEXT:
          return DataChangeRecordTypeConvertor.toString(valuesJson, colName, false);
        case NUMERIC:
        case PG_NUMERIC:
          return DataChangeRecordTypeConvertor.toNumericBigDecimal(valuesJson, colName, false);
        case JSON:
        case PG_JSONB:
          return DataChangeRecordTypeConvertor.toString(valuesJson, colName, false);
        case BYTES:
        case PG_BYTEA:
          return DataChangeRecordTypeConvertor.toByteArray(valuesJson, colName, false);
        case TIMESTAMP:
        case PG_TIMESTAMPTZ:
          return DataChangeRecordTypeConvertor.toTimestamp(valuesJson, colName, false);
        case DATE:
        case PG_DATE:
          return DataChangeRecordTypeConvertor.toDate(valuesJson, colName, false);
        default:
          throw new IllegalArgumentException(
              "Column name(" + colName + ") has unsupported column type(" + colType + ")");
      }
    } catch (Exception e) {
      throw new Exception("Error getting column value from json: " + e.getMessage());
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -