Skip to content

Commit

Permalink
Fix
Browse files Browse the repository at this point in the history
  • Loading branch information
li-kramgopa committed Jan 19, 2024
1 parent 14bc7c3 commit 4f0668b
Showing 1 changed file with 4 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -175,13 +175,10 @@ public static DataSchema avroToDataSchema(String avroSchemaInJson, AvroToDataSch
// translationMode == TRANSLATE or no embedded schema

DataSchemaTraverse traverse = new DataSchemaTraverse();
DataSchemaTraverse.Callback callback = (path, schema) -> {
// convert values
AvroToDataSchemaConvertCallback.INSTANCE.callback(path, schema);
// convert default values
DefaultAvroToDataConvertCallback.INSTANCE.callback(path, schema);
};
traverse.traverse(dataSchema, callback);
// convert values
traverse.traverse(dataSchema, AvroToDataSchemaConvertCallback.INSTANCE);
// convert default values
traverse.traverse(dataSchema, DefaultAvroToDataConvertCallback.INSTANCE);

// make sure it can round-trip if configured to do so.
if (options.shouldRoundTripTranslatedSchemas())
Expand Down

0 comments on commit 4f0668b

Please sign in to comment.