in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/DynamoDbType.java [88:114]
public static DynamoDbType fromByteValue(byte value) {
switch (value) {
case 0:
return STRING;
case 1:
return NUMBER;
case 2:
return BOOLEAN;
case 3:
return NULL;
case 4:
return BINARY;
case 5:
return STRING_SET;
case 6:
return NUMBER_SET;
case 7:
return BINARY_SET;
case 8:
return LIST;
case 9:
return MAP;
default:
throw new UnsupportedOperationException(
"Unsupported byte value '" + value + "' for DynamoDb type.");
}
}