id: 1 unit: private Object toConnectValue() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 174 end line: 457 size: 267 LOC McCabe index: 64 number of parameters: 2 id: 2 unit: public Object fromConnectData() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 660 end line: 868 size: 195 LOC McCabe index: 61 number of parameters: 4 id: 3 unit: public Schema toConnectSchema() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 464 end line: 650 size: 178 LOC McCabe index: 56 number of parameters: 1 id: 4 unit: private JsonNode getDefaultValueFromConnect() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 1216 end line: 1299 size: 82 LOC McCabe index: 22 number of parameters: 2 id: 5 unit: public T Deserialize() file: csharp/json/src/KafkaJsonDeserializer.cs start line: 43 end line: 99 size: 46 LOC McCabe index: 10 number of parameters: 3 id: 6 unit: private static boolean schemaEquals() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 1036 end line: 1072 size: 34 LOC McCabe index: 18 number of parameters: 4 id: 7 unit: public T deserialize() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/KafkaJsonDeserializer.java start line: 94 end line: 128 size: 30 LOC McCabe index: 5 number of parameters: 3 id: 8 unit: private boolean isInstanceOfAvroSchemaTypeForSimpleSchema() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 1323 end line: 1352 size: 30 LOC McCabe index: 8 number of parameters: 3 id: 9 unit: public SchemaAndValue toConnectData() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverter.java start line: 141 end line: 176 size: 27 LOC McCabe index: 5 number of parameters: 3 id: 10 unit: public void configure() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/KafkaAvroDeserializer.java start line: 51 end line: 75 size: 25 LOC McCabe index: 3 number of parameters: 2 id: 11 unit: public void configure() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/KafkaAvroSerializer.java start line: 50 end line: 75 size: 25 LOC McCabe index: 3 number of parameters: 2 id: 12 unit: public void configure() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/KafkaJsonSerializer.java start line: 52 end line: 75 size: 21 LOC McCabe index: 3 number of parameters: 2 id: 13 unit: public void configure() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverter.java start line: 57 end line: 81 size: 21 LOC McCabe index: 2 number of parameters: 2 id: 14 unit: private void addAvroRecordField() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 1194 end line: 1214 size: 20 LOC McCabe index: 6 number of parameters: 4 id: 15 unit: public T Deserialize() file: csharp/avro/src/KafkaAvroDeserializer.cs start line: 46 end line: 68 size: 20 LOC McCabe index: 3 number of parameters: 3 id: 16 unit: public void configure() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/KafkaJsonDeserializer.java start line: 52 end line: 72 size: 19 LOC McCabe index: 3 number of parameters: 2 id: 17 unit: public KafkaAvroSerializer() file: csharp/avro/src/KafkaAvroSerializer.cs start line: 27 end line: 45 size: 19 LOC McCabe index: 1 number of parameters: 4 id: 18 unit: private static boolean fieldListEquals() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 1074 end line: 1090 size: 17 LOC McCabe index: 7 number of parameters: 4 id: 19 unit: public KafkaAvroDeserializer() file: csharp/avro/src/KafkaAvroDeserializer.cs start line: 30 end line: 44 size: 15 LOC McCabe index: 1 number of parameters: 2 id: 20 unit: static file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 142 end line: 156 size: 14 LOC McCabe index: 1 number of parameters: 0 id: 21 unit: private boolean isMapEntry() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 1114 end line: 1126 size: 13 LOC McCabe index: 5 number of parameters: 1 id: 22 unit: private boolean fixedValueSizeMatch() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 1354 end line: 1366 size: 13 LOC McCabe index: 4 number of parameters: 4 id: 23 unit: public T deserialize() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/KafkaAvroDeserializer.java start line: 96 end line: 110 size: 13 LOC McCabe index: 2 number of parameters: 3 id: 24 unit: public KafkaJsonSerializer() file: csharp/json/src/KafkaJsonSerializer.cs start line: 32 end line: 44 size: 13 LOC McCabe index: 1 number of parameters: 4 id: 25 unit: static file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 76 end line: 87 size: 12 LOC McCabe index: 1 number of parameters: 0 id: 26 unit: private static boolean fieldEquals() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 1092 end line: 1103 size: 12 LOC McCabe index: 7 number of parameters: 4 id: 27 unit: public KafkaAvroAsyncSerializer() file: csharp/avro/src/KafkaAvroAsyncSerializer.cs start line: 26 end line: 37 size: 12 LOC McCabe index: 1 number of parameters: 4 id: 28 unit: static file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 92 end line: 102 size: 11 LOC McCabe index: 1 number of parameters: 0 id: 29 unit: private EnumSymbol enumSymbol() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 1400 end line: 1410 size: 11 LOC McCabe index: 2 number of parameters: 3 id: 30 unit: public KafkaJsonDeserializer() file: csharp/json/src/KafkaJsonDeserializer.cs start line: 31 end line: 41 size: 11 LOC McCabe index: 1 number of parameters: 2 id: 31 unit: public async Task SerializeAsync() file: csharp/avro/src/KafkaAvroAsyncSerializer.cs start line: 39 end line: 50 size: 11 LOC McCabe index: 2 number of parameters: 2 id: 32 unit: private static String unionMemberFieldName() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 1105 end line: 1112 size: 8 LOC McCabe index: 4 number of parameters: 2 id: 33 unit: private Pair getNameOrDefault() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 1301 end line: 1308 size: 8 LOC McCabe index: 2 number of parameters: 1 id: 34 unit: public SchemaAndValue toConnectData() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 164 end line: 172 size: 7 LOC McCabe index: 3 number of parameters: 2 id: 35 unit: public String getSchemaGroup() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/KafkaJsonSerializerConfig.java start line: 51 end line: 56 size: 6 LOC McCabe index: 2 number of parameters: 0 id: 36 unit: public String getSchemaGroup() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterConfig.java start line: 101 end line: 106 size: 6 LOC McCabe index: 2 number of parameters: 0 id: 37 unit: public TokenCredential getCredential() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterConfig.java start line: 108 end line: 113 size: 6 LOC McCabe index: 2 number of parameters: 0 id: 38 unit: private static String unionMemberFieldName() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 1368 end line: 1373 size: 6 LOC McCabe index: 4 number of parameters: 2 id: 39 unit: public String getSchemaGroup() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/KafkaAvroSerializerConfig.java start line: 50 end line: 55 size: 6 LOC McCabe index: 2 number of parameters: 0 id: 40 unit: private static boolean isFixedSchema() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 1375 end line: 1379 size: 5 LOC McCabe index: 4 number of parameters: 1 id: 41 unit: public Boolean getAutoRegisterSchemas() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/KafkaJsonSerializerConfig.java start line: 43 end line: 46 size: 4 LOC McCabe index: 1 number of parameters: 0 id: 42 unit: public Builder with() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterConfig.java start line: 36 end line: 39 size: 4 LOC McCabe index: 1 number of parameters: 2 id: 43 unit: static file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 69 end line: 72 size: 4 LOC McCabe index: 1 number of parameters: 0 id: 44 unit: private static boolean isEnumSchema() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 1381 end line: 1384 size: 4 LOC McCabe index: 3 number of parameters: 1 id: 45 unit: public Boolean getAutoRegisterSchemas() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/KafkaAvroSerializerConfig.java start line: 42 end line: 45 size: 4 LOC McCabe index: 1 number of parameters: 0 id: 46 unit: public Boolean getAvroSpecificReader() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/KafkaAvroDeserializerConfig.java start line: 31 end line: 34 size: 4 LOC McCabe index: 1 number of parameters: 0 id: 47 unit: public KafkaJsonDeserializer() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/KafkaJsonDeserializer.java start line: 39 end line: 41 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 48 unit: public T deserialize() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/KafkaJsonDeserializer.java start line: 81 end line: 83 size: 3 LOC McCabe index: 1 number of parameters: 2 id: 49 unit: public KafkaJsonSerializer() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/KafkaJsonSerializer.java start line: 38 end line: 40 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 50 unit: public JsonSerializationException() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/JsonSerializationException.java start line: 16 end line: 18 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 51 unit: public JsonSerializationException() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/JsonSerializationException.java start line: 25 end line: 27 size: 3 LOC McCabe index: 1 number of parameters: 2 id: 52 unit: public Map getProps() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/AbstractKafkaSerdeConfig.java start line: 47 end line: 49 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 53 unit: public String getSchemaRegistryUrl() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/AbstractKafkaSerdeConfig.java start line: 51 end line: 53 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 54 unit: public TokenCredential getCredential() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/AbstractKafkaSerdeConfig.java start line: 55 end line: 57 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 55 unit: public Boolean createDefaultAzureCredential() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/AbstractKafkaSerdeConfig.java start line: 59 end line: 61 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 56 unit: public Integer getMaxSchemaMapSize() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/AbstractKafkaSerdeConfig.java start line: 63 end line: 65 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 57 unit: public Class getJsonSpecificType() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/KafkaJsonDeserializerConfig.java start line: 26 end line: 28 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 58 unit: public AvroConverter() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverter.java start line: 48 end line: 50 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 59 unit: public SchemaAndValue toConnectData() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverter.java start line: 130 end line: 132 size: 3 LOC McCabe index: 1 number of parameters: 2 id: 60 unit: public AvroConverterConfig() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterConfig.java start line: 20 end line: 22 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 61 unit: public AvroConverterConfig build() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterConfig.java start line: 44 end line: 46 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 62 unit: public Map getProps() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterConfig.java start line: 90 end line: 92 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 63 unit: public String getSchemaRegistryUrl() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterConfig.java start line: 94 end line: 96 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 64 unit: public Integer getMaxSchemaMapSize() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterConfig.java start line: 115 end line: 117 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 65 unit: public Class getAvroSpecificType() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterConfig.java start line: 119 end line: 121 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 66 unit: private static boolean schemaEquals() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java start line: 1032 end line: 1034 size: 3 LOC McCabe index: 1 number of parameters: 2 id: 67 unit: public KafkaAvroDeserializer() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/KafkaAvroDeserializer.java start line: 38 end line: 40 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 68 unit: public T deserialize() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/KafkaAvroDeserializer.java start line: 84 end line: 86 size: 3 LOC McCabe index: 1 number of parameters: 2 id: 69 unit: public Class getAvroSpecificType() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/KafkaAvroDeserializerConfig.java start line: 39 end line: 41 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 70 unit: public Map getProps() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/AbstractKafkaSerdeConfig.java start line: 47 end line: 49 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 71 unit: public String getSchemaRegistryUrl() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/AbstractKafkaSerdeConfig.java start line: 51 end line: 53 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 72 unit: public TokenCredential getCredential() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/AbstractKafkaSerdeConfig.java start line: 55 end line: 57 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 73 unit: public Boolean createDefaultAzureCredential() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/AbstractKafkaSerdeConfig.java start line: 59 end line: 61 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 74 unit: public Integer getMaxSchemaMapSize() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/AbstractKafkaSerdeConfig.java start line: 63 end line: 65 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 75 unit: public KafkaAvroSerializer() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/KafkaAvroSerializer.java start line: 36 end line: 38 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 76 unit: public SerializationException() file: csharp/json/src/SerializationException.cs start line: 12 end line: 14 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 77 unit: public SerializationException() file: csharp/json/src/SerializationException.cs start line: 16 end line: 18 size: 3 LOC McCabe index: 1 number of parameters: 2 id: 78 unit: public AvroConverter() file: java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverter.java start line: 41 end line: 42 size: 2 LOC McCabe index: 1 number of parameters: 0 id: 79 unit: public void close() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/KafkaJsonDeserializer.java start line: 131 end line: 131 size: 1 LOC McCabe index: 1 number of parameters: 0 id: 80 unit: public void close() file: java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/KafkaJsonSerializer.java start line: 150 end line: 150 size: 1 LOC McCabe index: 1 number of parameters: 0 id: 81 unit: public void close() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/KafkaAvroDeserializer.java start line: 113 end line: 113 size: 1 LOC McCabe index: 1 number of parameters: 0 id: 82 unit: public void close() file: java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/KafkaAvroSerializer.java start line: 124 end line: 124 size: 1 LOC McCabe index: 1 number of parameters: 0