in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbTypeInformedElementConverter.java [306:353]
private List<String> convertPrimitiveArrayToStringList(Object objectArray) {
if (objectArray instanceof int[]) {
int[] intArray = (int[]) objectArray;
List<String> stringList = new ArrayList<>();
for (int i : intArray) {
stringList.add(Integer.toString(i));
}
return stringList;
} else if (objectArray instanceof double[]) {
double[] doubleArray = (double[]) objectArray;
List<String> stringList = new ArrayList<>();
for (double d : doubleArray) {
stringList.add(Double.toString(d));
}
return stringList;
} else if (objectArray instanceof long[]) {
long[] longArray = (long[]) objectArray;
List<String> stringList = new ArrayList<>();
for (long l : longArray) {
stringList.add(Long.toString(l));
}
return stringList;
} else if (objectArray instanceof float[]) {
float[] longArray = (float[]) objectArray;
List<String> stringList = new ArrayList<>();
for (float f : longArray) {
stringList.add(Float.toString(f));
}
return stringList;
} else if (objectArray instanceof short[]) {
short[] longArray = (short[]) objectArray;
List<String> stringList = new ArrayList<>();
for (short s : longArray) {
stringList.add(Short.toString(s));
}
return stringList;
} else {
throw new IllegalArgumentException(
String.format(
"Unsupported primitive typeInfo %s",
objectArray.getClass().getComponentType()));
}
}