@@ -152,14 +152,16 @@ public MessageType convert(Schema avroSchema) {
152152 throw new IllegalArgumentException ("Avro schema must be a record." );
153153 }
154154 return new MessageType (
155- avroSchema .getFullName (), convertFields (avroSchema .getFields (), "" , new IdentityHashMap <Schema , Void >()));
155+ avroSchema .getFullName (),
156+ convertFields (avroSchema .getFields (), "" , new IdentityHashMap <Schema , Void >()));
156157 }
157158
158159 private List <Type > convertFields (List <Schema .Field > fields , String schemaPath ) {
159160 return convertFields (fields , schemaPath , new IdentityHashMap <Schema , Void >());
160161 }
161162
162- private List <Type > convertFields (List <Schema .Field > fields , String schemaPath , IdentityHashMap <Schema , Void > seenSchemas ) {
163+ private List <Type > convertFields (
164+ List <Schema .Field > fields , String schemaPath , IdentityHashMap <Schema , Void > seenSchemas ) {
163165 List <Type > types = new ArrayList <Type >();
164166 for (Schema .Field field : fields ) {
165167 if (field .schema ().getType ().equals (Schema .Type .NULL )) {
@@ -174,7 +176,8 @@ private Type convertField(String fieldName, Schema schema, String schemaPath) {
174176 return convertField (fieldName , schema , Type .Repetition .REQUIRED , schemaPath );
175177 }
176178
177- private Type convertField (String fieldName , Schema schema , String schemaPath , IdentityHashMap <Schema , Void > seenSchemas ) {
179+ private Type convertField (
180+ String fieldName , Schema schema , String schemaPath , IdentityHashMap <Schema , Void > seenSchemas ) {
178181 return convertField (fieldName , schema , Type .Repetition .REQUIRED , schemaPath , seenSchemas );
179182 }
180183
@@ -185,7 +188,11 @@ private Type convertField(String fieldName, Schema schema, Type.Repetition repet
185188
186189 @ SuppressWarnings ("deprecation" )
187190 private Type convertField (
188- String fieldName , Schema schema , Type .Repetition repetition , String schemaPath , IdentityHashMap <Schema , Void > seenSchemas ) {
191+ String fieldName ,
192+ Schema schema ,
193+ Type .Repetition repetition ,
194+ String schemaPath ,
195+ IdentityHashMap <Schema , Void > seenSchemas ) {
189196 Schema .Type type = schema .getType ();
190197 LogicalType logicalType = schema .getLogicalType ();
191198
@@ -280,7 +287,11 @@ private Type convertUnion(String fieldName, Schema schema, Type.Repetition repet
280287 }
281288
282289 private Type convertUnion (
283- String fieldName , Schema schema , Type .Repetition repetition , String schemaPath , IdentityHashMap <Schema , Void > seenSchemas ) {
290+ String fieldName ,
291+ Schema schema ,
292+ Type .Repetition repetition ,
293+ String schemaPath ,
294+ IdentityHashMap <Schema , Void > seenSchemas ) {
284295 List <Schema > nonNullSchemas = new ArrayList <Schema >(schema .getTypes ().size ());
285296 // Found any schemas in the union? Required for the edge case, where the union contains only a single type.
286297 boolean foundNullSchema = false ;
@@ -312,7 +323,8 @@ private Type convertUnion(
312323
313324 private Type convertUnionToGroupType (
314325 String fieldName , Type .Repetition repetition , List <Schema > nonNullSchemas , String schemaPath ) {
315- return convertUnionToGroupType (fieldName , repetition , nonNullSchemas , schemaPath , new IdentityHashMap <Schema , Void >());
326+ return convertUnionToGroupType (
327+ fieldName , repetition , nonNullSchemas , schemaPath , new IdentityHashMap <Schema , Void >());
316328 }
317329
318330 private Type convertUnionToGroupType (
0 commit comments