private static RuntimeConverter createObjectArrayRuntimeConverter(TypeInformation<?> elementType) {
		final RuntimeConverter elementConverter = createNullableRuntimeConverter(elementType);
		return (csvMapper, container, obj) -> {
			final Object[] array = (Object[]) obj;
			final ArrayNode arrayNode = csvMapper.createArrayNode();
			for (Object element : array) {
				arrayNode.add(elementConverter.convert(csvMapper, arrayNode, element));
			}
			return arrayNode;
		};
	}
Creates a {@link CsvRowSerializationSchema} expecting the given {@link TypeInformation}.

@param typeInfo type information used to create schema.
kafka-base/kafka-base-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/serialization/CsvTupleSerializationSchema.java