in spanner-data-validator-java/src/main/java/com/google/migration/dofns/MapWithRangeFn.java [123:149]
public PartitionRange getPartitionRangeForRecord(HashResult result,
List<PartitionRange> siBRanges) {
switch(rangeFieldType) {
case TableSpec.UUID_FIELD_TYPE:
return getRangeFromList(result.key,
siBRanges,
uuidPartitionRangeComparator);
case TableSpec.INT_FIELD_TYPE:
return getRangeFromList(result.key,
siBRanges,
intPartitionRangeComparator);
case TableSpec.LONG_FIELD_TYPE:
return getRangeFromList(result.key,
siBRanges,
longPartitionRangeComparator);
case TableSpec.TIMESTAMP_FIELD_TYPE:
case TableSpec.STRING_FIELD_TYPE:
return getRangeFromList(result.key,
siBRanges,
stringPartitionRangeComparator);
default:
break;
}
throw new RuntimeException(String.format("Unrecognized rangeFieldType (%s) in "
+ "MapWithRangeFn.getPartitionRangeForRecord", rangeFieldType));
}