@Test public void testNumericFormats() { String schema = "{\n" + " \"title\": \"numerics with format\",\n" + " \"type\": \"object\",\n" + " \"properties\": {\n" + " \"id\": {\n" + " \"type\": \"integer\",\n" + " \"format\": \"int32\"\n" + " },\n" + " \"num\": {\n" + " \"type\": \"number\",\n" + " \"format\": \"double\"\n" + " }\n" + " },\n" + " \"required\": [\n" + " \"id\"\n" + " ],\n" + " \"additionalProperties\": false\n" + "}"; JsonSchema jsonSchema = new JsonSchema(schema); JsonSchemaData jsonSchemaData = new JsonSchemaData(); jsonSchemaData.toConnectSchema(jsonSchema); }
public Schema toConnectSchema(JsonSchema schema) { if (schema == null) { return null; } Schema cachedSchema = toConnectSchemaCache.get(schema); if (cachedSchema != null) { return cachedSchema; } Schema resultSchema = toConnectSchema(schema.rawSchema(), schema.version(), false); toConnectSchemaCache.put(schema, resultSchema); return resultSchema; }
JsonSchemaData { public Schema toConnectSchema(JsonSchema schema) { if (schema == null) { return null; } Schema cachedSchema = toConnectSchemaCache.get(schema); if (cachedSchema != null) { return cachedSchema; } Schema resultSchema = toConnectSchema(schema.rawSchema(), schema.version(), false); toConnectSchemaCache.put(schema, resultSchema); return resultSchema; } }
JsonSchemaData { public Schema toConnectSchema(JsonSchema schema) { if (schema == null) { return null; } Schema cachedSchema = toConnectSchemaCache.get(schema); if (cachedSchema != null) { return cachedSchema; } Schema resultSchema = toConnectSchema(schema.rawSchema(), schema.version(), false); toConnectSchemaCache.put(schema, resultSchema); return resultSchema; } JsonSchemaData();  JsonSchemaData(JsonSchemaDataConfig jsonSchemaDataConfig); }
JsonSchemaData { public Schema toConnectSchema(JsonSchema schema) { if (schema == null) { return null; } Schema cachedSchema = toConnectSchemaCache.get(schema); if (cachedSchema != null) { return cachedSchema; } Schema resultSchema = toConnectSchema(schema.rawSchema(), schema.version(), false); toConnectSchemaCache.put(schema, resultSchema); return resultSchema; } JsonSchemaData();  JsonSchemaData(JsonSchemaDataConfig jsonSchemaDataConfig); JsonNode fromConnectData(Schema schema, Object logicalValue); static Object toConnectData(Schema schema, JsonNode jsonValue); JsonSchema fromConnectSchema(Schema schema); Schema toConnectSchema(JsonSchema schema); }
JsonSchemaData { public Schema toConnectSchema(JsonSchema schema) { if (schema == null) { return null; } Schema cachedSchema = toConnectSchemaCache.get(schema); if (cachedSchema != null) { return cachedSchema; } Schema resultSchema = toConnectSchema(schema.rawSchema(), schema.version(), false); toConnectSchemaCache.put(schema, resultSchema); return resultSchema; } JsonSchemaData();  JsonSchemaData(JsonSchemaDataConfig jsonSchemaDataConfig); JsonNode fromConnectData(Schema schema, Object logicalValue); static Object toConnectData(Schema schema, JsonNode jsonValue); JsonSchema fromConnectSchema(Schema schema); Schema toConnectSchema(JsonSchema schema); static final String NAMESPACE; static final String KEY_FIELD; static final String VALUE_FIELD; static final String CONNECT_TYPE_PROP; static final String CONNECT_VERSION_PROP; static final String CONNECT_PARAMETERS_PROP; static final String CONNECT_INDEX_PROP; static final String CONNECT_TYPE_INT8; static final String CONNECT_TYPE_INT16; static final String CONNECT_TYPE_INT32; static final String CONNECT_TYPE_INT64; static final String CONNECT_TYPE_FLOAT32; static final String CONNECT_TYPE_FLOAT64; static final String CONNECT_TYPE_BYTES; static final String CONNECT_TYPE_MAP; static final String JSON_TYPE_ENUM; static final String JSON_TYPE_ENUM_PREFIX; static final String JSON_TYPE_ONE_OF; }