class JdbcTypeConverter {

    public static TypeInformation<?> getFlinkType(int typeIndex) {
		TypeInformation<?> typeInformation = MAP_INDEX_TO_FLINK_TYPE.get(typeIndex);
		Preconditions.checkArgument(typeInformation != null, "Unsupported type: %s", typeIndex);
		return typeInformation;
    }

}