getIdConverter()
+ {
+ return new IntegerConverter();
+ }
+
+ @JsonProperty
+ public String getTopic()
+ {
+ return topic;
+ }
+
+ @Override
+ public boolean equals(Object o)
+ {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+
+ Avro1124SubjectAndIdConverter converter = (Avro1124SubjectAndIdConverter) o;
+
+ return !(topic != null ? !topic.equals(converter.topic) : converter.topic != null);
+
+ }
+
+ @Override
+ public int hashCode()
+ {
+ return topic != null ? topic.hashCode() : 0;
+ }
+}
diff --git a/extensions/avro-extensions/src/main/java/io/druid/data/input/schemarepo/SubjectAndIdConverter.java b/extensions/avro-extensions/src/main/java/io/druid/data/input/schemarepo/SubjectAndIdConverter.java
new file mode 100644
index 000000000000..01331dfa25e9
--- /dev/null
+++ b/extensions/avro-extensions/src/main/java/io/druid/data/input/schemarepo/SubjectAndIdConverter.java
@@ -0,0 +1,59 @@
+/*
+ * Licensed to Metamarkets Group Inc. (Metamarkets) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. Metamarkets licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package io.druid.data.input.schemarepo;
+
+import com.fasterxml.jackson.annotation.JsonSubTypes;
+import com.fasterxml.jackson.annotation.JsonTypeInfo;
+import com.metamx.common.Pair;
+import org.schemarepo.api.converter.Converter;
+
+import java.nio.ByteBuffer;
+
+/**
+ * Schema Repository is a registry service, you can register a string schema which gives back an schema id for it,
+ * or lookup the schema with the schema id.
+ *
+ * In order to get the "latest" schema or handle compatibility enforcement on changes there has to be some way to group
+ * a set of schemas together and reason about the ordering of changes over these. Subject is introduced as
+ * the formal notion of group, defined as an ordered collection of mutually compatible schemas, according to
+ * Scott Carey on AVRO-1124.
+ *
+ * So you can register an string schema to a specific subject, get an schema id, and then query the schema using the
+ * subject and schema id pair. Working with Kafka and Avro, it's intuitive that using Kafka topic as subject name and an
+ * incrementing integer as schema id, serialize and attach them to the message payload, or extract and deserialize from
+ * message payload, which is implemented as {@link Avro1124SubjectAndIdConverter}.
+ *
+ * You can implement your own SubjectAndIdConverter based on your scenario, such as using canonical name of avro schema
+ * as subject name and incrementing short integer which serialized using varint.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "type", defaultImpl = Avro1124SubjectAndIdConverter.class)
+@JsonSubTypes(value = {
+ @JsonSubTypes.Type(name = "avro_1124", value = Avro1124SubjectAndIdConverter.class)
+})
+public interface SubjectAndIdConverter
+{
+
+ Pair getSubjectAndId(ByteBuffer payload);
+
+ void putSubjectAndId(SUBJECT subject, ID id, ByteBuffer payload);
+
+ Converter getSubjectConverter();
+
+ Converter getIdConverter();
+}
diff --git a/extensions/avro-extensions/src/main/resources/META-INF/services/io.druid.initialization.DruidModule b/extensions/avro-extensions/src/main/resources/META-INF/services/io.druid.initialization.DruidModule
new file mode 100644
index 000000000000..050a1dd0727b
--- /dev/null
+++ b/extensions/avro-extensions/src/main/resources/META-INF/services/io.druid.initialization.DruidModule
@@ -0,0 +1 @@
+io.druid.data.input.avro.AvroExtensionsModule
diff --git a/extensions/avro-extensions/src/test/avro/some-datum.avsc b/extensions/avro-extensions/src/test/avro/some-datum.avsc
new file mode 100644
index 000000000000..773313ae15ae
--- /dev/null
+++ b/extensions/avro-extensions/src/test/avro/some-datum.avsc
@@ -0,0 +1,31 @@
+[{
+ "namespace": "io.druid.data.input",
+ "name": "SomeAvroDatum",
+ "type": "record",
+ "fields" : [
+ {"name":"timestamp","type":"long"},
+ {"name":"eventType","type":"string"},
+ {"name":"id","type":"long"},
+ {"name":"someOtherId","type":"long"},
+ {"name":"isValid","type":"boolean"},
+ {"name":"someIntArray","type":{"type":"array","items":"int"}},
+ {"name":"someStringArray","type":{"type":"array","items":"string"}},
+ {"name":"someIntValueMap","type":{"type":"map","values":"int"}},
+ {"name":"someStringValueMap","type":{"type":"map","values":"string"}},
+ {"name":"someUnion","type":["null","string"]},
+ {"name":"someNull","type":"null"},
+ {"name":"someFixed","type":{"type":"fixed","size":16,"name":"MyFixed"}},
+ {"name":"someBytes","type":"bytes"},
+ {"name":"someEnum","type":{"type":"enum","name":"MyEnum","symbols":["ENUM0","ENUM1","ENUM2"]}},
+ {"name":"someRecord","type":{
+ "type":"record","name":"MySubRecord","fields":[
+ {"name":"subInt","type":"int"},
+ {"name":"subLong","type":"long"}
+ ]
+ }},
+
+ {"name":"someLong","type":"long"},
+ {"name":"someInt","type":"int"},
+ {"name":"someFloat","type":"float"}
+ ]
+}]
diff --git a/extensions/avro-extensions/src/test/java/io/druid/data/input/AvroHadoopInputRowParserTest.java b/extensions/avro-extensions/src/test/java/io/druid/data/input/AvroHadoopInputRowParserTest.java
new file mode 100644
index 000000000000..59c9a4cdaf89
--- /dev/null
+++ b/extensions/avro-extensions/src/test/java/io/druid/data/input/AvroHadoopInputRowParserTest.java
@@ -0,0 +1,132 @@
+/*
+ * Licensed to Metamarkets Group Inc. (Metamarkets) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. Metamarkets licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package io.druid.data.input;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.google.common.io.Closeables;
+import com.google.common.io.Files;
+import org.apache.avro.file.DataFileReader;
+import org.apache.avro.file.DataFileWriter;
+import org.apache.avro.file.FileReader;
+import org.apache.avro.generic.GenericDatumReader;
+import org.apache.avro.generic.GenericDatumWriter;
+import org.apache.avro.generic.GenericRecord;
+import org.apache.commons.io.FileUtils;
+import org.apache.pig.ExecType;
+import org.apache.pig.PigServer;
+import org.junit.Test;
+
+import java.io.File;
+import java.io.IOException;
+
+import static io.druid.data.input.AvroStreamInputRowParserTest.PARSE_SPEC;
+import static io.druid.data.input.AvroStreamInputRowParserTest.assertInputRowCorrect;
+import static io.druid.data.input.AvroStreamInputRowParserTest.buildSomeAvroDatum;
+
+public class AvroHadoopInputRowParserTest
+{
+ private final ObjectMapper jsonMapper = new ObjectMapper();
+
+ @Test
+ public void testParseNotFromPigAvroStorage() throws IOException
+ {
+ testParse(buildSomeAvroDatum(), false);
+ }
+
+ @Test
+ public void testParseFromPiggyBankAvroStorage() throws IOException
+ {
+ testParse(buildPiggyBankAvro(), false);
+ }
+
+ @Test
+ public void testParseFromPigAvroStorage() throws IOException
+ {
+ testParse(buildPigAvro(), true);
+ }
+
+ private void testParse(GenericRecord record, boolean fromPigAvroStorage) throws IOException
+ {
+ AvroHadoopInputRowParser parser = new AvroHadoopInputRowParser(PARSE_SPEC, fromPigAvroStorage);
+ AvroHadoopInputRowParser parser2 = jsonMapper.readValue(
+ jsonMapper.writeValueAsBytes(parser),
+ AvroHadoopInputRowParser.class
+ );
+ InputRow inputRow = parser2.parse(record);
+ assertInputRowCorrect(inputRow);
+ }
+
+
+ public static GenericRecord buildPigAvro() throws IOException
+ {
+ return buildPigAvro(buildSomeAvroDatum(), "AvroStorage", "AvroStorage");
+ }
+
+ public static GenericRecord buildPiggyBankAvro() throws IOException
+ {
+ return buildPigAvro(
+ buildSomeAvroDatum(),
+ "org.apache.pig.piggybank.storage.avro.AvroStorage",
+ "org.apache.pig.piggybank.storage.avro.AvroStorage('field7','{\"type\":\"map\",\"values\":\"int\"}','field8','{\"type\":\"map\",\"values\":\"string\"}')"
+ );
+ }
+
+ private static GenericRecord buildPigAvro(GenericRecord datum, String inputStorage, String outputStorage)
+ throws IOException
+ {
+ final File tmpDir = Files.createTempDir();
+ FileReader reader = null;
+ PigServer pigServer = null;
+ try {
+ // 0. write avro object into temp file.
+ File someAvroDatumFile = new File(tmpDir, "someAvroDatum.avro");
+ DataFileWriter dataFileWriter = new DataFileWriter(
+ new GenericDatumWriter()
+ );
+ dataFileWriter.create(SomeAvroDatum.getClassSchema(), someAvroDatumFile);
+ dataFileWriter.append(datum);
+ dataFileWriter.close();
+ // 1. read avro files into Pig
+ pigServer = new PigServer(ExecType.LOCAL);
+ pigServer.registerQuery(
+ String.format(
+ "A = LOAD '%s' USING %s;",
+ someAvroDatumFile,
+ inputStorage
+ )
+ );
+ // 2. write new avro file using AvroStorage
+ File outputDir = new File(tmpDir, "output");
+ pigServer.store("A", String.valueOf(outputDir), outputStorage);
+ // 3. read avro object from AvroStorage
+ reader = DataFileReader.openReader(
+ new File(outputDir, "part-m-00000.avro"),
+ new GenericDatumReader()
+ );
+ return reader.next();
+ }
+ finally {
+ if (pigServer != null) {
+ pigServer.shutdown();
+ }
+ Closeables.close(reader, true);
+ FileUtils.deleteDirectory(tmpDir);
+ }
+ }
+}
diff --git a/extensions/avro-extensions/src/test/java/io/druid/data/input/AvroStreamInputRowParserTest.java b/extensions/avro-extensions/src/test/java/io/druid/data/input/AvroStreamInputRowParserTest.java
new file mode 100644
index 000000000000..609d67f6794e
--- /dev/null
+++ b/extensions/avro-extensions/src/test/java/io/druid/data/input/AvroStreamInputRowParserTest.java
@@ -0,0 +1,273 @@
+/*
+ * Licensed to Metamarkets Group Inc. (Metamarkets) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. Metamarkets licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package io.druid.data.input;
+
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.MapperFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
+import com.google.common.base.Function;
+import com.google.common.base.Splitter;
+import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
+import io.druid.data.input.avro.AvroExtensionsModule;
+import io.druid.data.input.avro.SchemaRepoBasedAvroBytesDecoder;
+import io.druid.data.input.impl.DimensionsSpec;
+import io.druid.data.input.impl.TimeAndDimsParseSpec;
+import io.druid.data.input.impl.TimestampSpec;
+import io.druid.data.input.schemarepo.Avro1124RESTRepositoryClientWrapper;
+import io.druid.data.input.schemarepo.Avro1124SubjectAndIdConverter;
+import org.apache.avro.Schema;
+import org.apache.avro.generic.GenericDatumWriter;
+import org.apache.avro.generic.GenericRecord;
+import org.apache.avro.io.DatumWriter;
+import org.apache.avro.io.EncoderFactory;
+import org.joda.time.DateTime;
+import org.junit.Before;
+import org.junit.Test;
+import org.schemarepo.InMemoryRepository;
+import org.schemarepo.Repository;
+import org.schemarepo.SchemaValidationException;
+import org.schemarepo.api.TypedSchemaRepository;
+import org.schemarepo.api.converter.AvroSchemaConverter;
+import org.schemarepo.api.converter.IdentityConverter;
+import org.schemarepo.api.converter.IntegerConverter;
+
+import javax.annotation.Nullable;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+
+import static org.junit.Assert.assertEquals;
+
+public class AvroStreamInputRowParserTest
+{
+ public static final String EVENT_TYPE = "eventType";
+ public static final String ID = "id";
+ public static final String SOME_OTHER_ID = "someOtherId";
+ public static final String IS_VALID = "isValid";
+ public static final String TOPIC = "aTopic";
+ public static final String EVENT_TYPE_VALUE = "type-a";
+ public static final long ID_VALUE = 1976491L;
+ public static final long SOME_OTHER_ID_VALUE = 6568719896L;
+ public static final float SOME_FLOAT_VALUE = 0.23555f;
+ public static final int SOME_INT_VALUE = 1;
+ public static final long SOME_LONG_VALUE = 679865987569912369L;
+ public static final DateTime DATE_TIME = new DateTime(2015, 10, 25, 19, 30);
+ public static final List DIMENSIONS = Arrays.asList(EVENT_TYPE, ID, SOME_OTHER_ID, IS_VALID);
+ public static final TimeAndDimsParseSpec PARSE_SPEC = new TimeAndDimsParseSpec(
+ new TimestampSpec("timestamp", "millis", null),
+ new DimensionsSpec(DIMENSIONS, Collections.emptyList(), null)
+ );
+ public static final MyFixed SOME_FIXED_VALUE = new MyFixed(ByteBuffer.allocate(16).array());
+ private static final long SUB_LONG_VALUE = 1543698L;
+ private static final int SUB_INT_VALUE = 4892;
+ public static final MySubRecord SOME_RECORD_VALUE = MySubRecord.newBuilder()
+ .setSubInt(SUB_INT_VALUE)
+ .setSubLong(SUB_LONG_VALUE)
+ .build();
+ public static final List SOME_STRING_ARRAY_VALUE = Arrays.asList((CharSequence) "8", "4", "2", "1");
+ public static final List SOME_INT_ARRAY_VALUE = Arrays.asList(1, 2, 4, 8);
+ public static final Map SOME_INT_VALUE_MAP_VALUE = Maps.asMap(
+ new HashSet(Arrays.asList("8", "2", "4", "1")), new Function()
+ {
+ @Nullable
+ @Override
+ public Integer apply(@Nullable CharSequence input) { return Integer.parseInt(input.toString()); }
+ }
+ );
+ public static final Map SOME_STRING_VALUE_MAP_VALUE = Maps.asMap(
+ new HashSet(Arrays.asList("8", "2", "4", "1")), new Function()
+ {
+ @Nullable
+ @Override
+ public CharSequence apply(@Nullable CharSequence input) { return input.toString(); }
+ }
+ );
+ public static final String SOME_UNION_VALUE = "string as union";
+ public static final ByteBuffer SOME_BYTES_VALUE = ByteBuffer.allocate(8);
+ private static final Function TO_STRING_INCLUDING_NULL = new Function()
+ {
+ public String apply(Object o) { return String.valueOf(o); }
+ };
+
+ private final ObjectMapper jsonMapper = new ObjectMapper();
+
+
+ @Before
+ public void before()
+ {
+ jsonMapper.configure(SerializationFeature.FAIL_ON_EMPTY_BEANS, false);
+ jsonMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
+ for (com.fasterxml.jackson.databind.Module jacksonModule : new AvroExtensionsModule().getJacksonModules()) {
+ jsonMapper.registerModule(jacksonModule);
+ }
+ }
+
+ @Test
+ public void testSerde() throws IOException
+ {
+ Repository repository = new Avro1124RESTRepositoryClientWrapper("http://github.io");
+ AvroStreamInputRowParser parser = new AvroStreamInputRowParser(
+ PARSE_SPEC,
+ new SchemaRepoBasedAvroBytesDecoder(new Avro1124SubjectAndIdConverter(TOPIC), repository)
+ );
+ ByteBufferInputRowParser parser2 = jsonMapper.readValue(
+ jsonMapper.writeValueAsString(parser),
+ ByteBufferInputRowParser.class
+ );
+
+ assertEquals(parser, parser2);
+ }
+
+ @Test
+ public void testParse() throws SchemaValidationException, IOException
+ {
+ // serde test
+ Repository repository = new InMemoryRepository(null);
+ AvroStreamInputRowParser parser = new AvroStreamInputRowParser(
+ PARSE_SPEC,
+ new SchemaRepoBasedAvroBytesDecoder(new Avro1124SubjectAndIdConverter(TOPIC), repository)
+ );
+ ByteBufferInputRowParser parser2 = jsonMapper.readValue(
+ jsonMapper.writeValueAsString(parser),
+ ByteBufferInputRowParser.class
+ );
+ repository = ((SchemaRepoBasedAvroBytesDecoder) ((AvroStreamInputRowParser) parser2).getAvroBytesDecoder()).getSchemaRepository();
+
+ // prepare data
+ GenericRecord someAvroDatum = buildSomeAvroDatum();
+
+ // encode schema id
+ Avro1124SubjectAndIdConverter converter = new Avro1124SubjectAndIdConverter(TOPIC);
+ TypedSchemaRepository repositoryClient = new TypedSchemaRepository(
+ repository,
+ new IntegerConverter(),
+ new AvroSchemaConverter(),
+ new IdentityConverter()
+ );
+ Integer id = repositoryClient.registerSchema(TOPIC, SomeAvroDatum.getClassSchema());
+ ByteBuffer byteBuffer = ByteBuffer.allocate(4);
+ converter.putSubjectAndId(TOPIC, id, byteBuffer);
+ ByteArrayOutputStream out = new ByteArrayOutputStream();
+ out.write(byteBuffer.array());
+ // encode data
+ DatumWriter writer = new GenericDatumWriter(someAvroDatum.getSchema());
+ // write avro datum to bytes
+ writer.write(someAvroDatum, EncoderFactory.get().directBinaryEncoder(out, null));
+
+ InputRow inputRow = parser2.parse(ByteBuffer.wrap(out.toByteArray()));
+
+ assertInputRowCorrect(inputRow);
+ }
+
+ public static void assertInputRowCorrect(InputRow inputRow)
+ {
+ Collections.sort(DIMENSIONS);
+ assertEquals(DIMENSIONS, inputRow.getDimensions());
+ assertEquals(DATE_TIME.getMillis(), inputRow.getTimestampFromEpoch());
+
+ // test dimensions
+ assertEquals(Collections.singletonList(String.valueOf(EVENT_TYPE_VALUE)), inputRow.getDimension(EVENT_TYPE));
+ assertEquals(Collections.singletonList(String.valueOf(ID_VALUE)), inputRow.getDimension(ID));
+ assertEquals(Collections.singletonList(String.valueOf(SOME_OTHER_ID_VALUE)), inputRow.getDimension(SOME_OTHER_ID));
+ assertEquals(Collections.singletonList(String.valueOf(true)), inputRow.getDimension(IS_VALID));
+ assertEquals(
+ Lists.transform(SOME_INT_ARRAY_VALUE, TO_STRING_INCLUDING_NULL),
+ inputRow.getDimension("someIntArray")
+ );
+ assertEquals(
+ Lists.transform(SOME_STRING_ARRAY_VALUE, TO_STRING_INCLUDING_NULL),
+ inputRow.getDimension("someStringArray")
+ );
+ // towards Map avro field as druid dimension, need to convert its toString() back to HashMap to check equality
+ assertEquals(1, inputRow.getDimension("someIntValueMap").size());
+ assertEquals(
+ SOME_INT_VALUE_MAP_VALUE, new HashMap(
+ Maps.transformValues(
+ Splitter.on(",")
+ .withKeyValueSeparator("=")
+ .split(inputRow.getDimension("someIntValueMap").get(0).replaceAll("[\\{\\} ]", "")),
+ new Function()
+ {
+ @Nullable
+ @Override
+ public Integer apply(@Nullable String input)
+ {
+ return Integer.valueOf(input);
+ }
+ }
+ )
+ )
+ );
+ assertEquals(
+ SOME_STRING_VALUE_MAP_VALUE, new HashMap(
+ Splitter.on(",")
+ .withKeyValueSeparator("=")
+ .split(inputRow.getDimension("someIntValueMap").get(0).replaceAll("[\\{\\} ]", ""))
+ )
+ );
+ assertEquals(Collections.singletonList(SOME_UNION_VALUE), inputRow.getDimension("someUnion"));
+ assertEquals(Collections.emptyList(), inputRow.getDimension("someNull"));
+ assertEquals(Collections.singletonList(String.valueOf(SOME_FIXED_VALUE)), inputRow.getDimension("someFixed"));
+ assertEquals(
+ Collections.singletonList(Arrays.toString(SOME_BYTES_VALUE.array())),
+ inputRow.getDimension("someBytes")
+ );
+ assertEquals(Collections.singletonList(String.valueOf(MyEnum.ENUM1)), inputRow.getDimension("someEnum"));
+ assertEquals(Collections.singletonList(String.valueOf(SOME_RECORD_VALUE)), inputRow.getDimension("someRecord"));
+
+ // test metrics
+ assertEquals(SOME_FLOAT_VALUE, inputRow.getFloatMetric("someFloat"), 0);
+ assertEquals(SOME_LONG_VALUE, inputRow.getLongMetric("someLong"));
+ assertEquals(SOME_INT_VALUE, inputRow.getLongMetric("someInt"));
+ }
+
+ public static GenericRecord buildSomeAvroDatum() throws IOException
+ {
+ SomeAvroDatum datum = SomeAvroDatum.newBuilder()
+ .setTimestamp(DATE_TIME.getMillis())
+ .setEventType(EVENT_TYPE_VALUE)
+ .setId(ID_VALUE)
+ .setSomeOtherId(SOME_OTHER_ID_VALUE)
+ .setIsValid(true)
+ .setSomeFloat(SOME_FLOAT_VALUE)
+ .setSomeInt(SOME_INT_VALUE)
+ .setSomeLong(SOME_LONG_VALUE)
+ .setSomeIntArray(SOME_INT_ARRAY_VALUE)
+ .setSomeStringArray(SOME_STRING_ARRAY_VALUE)
+ .setSomeIntValueMap(SOME_INT_VALUE_MAP_VALUE)
+ .setSomeStringValueMap(SOME_STRING_VALUE_MAP_VALUE)
+ .setSomeUnion(SOME_UNION_VALUE)
+ .setSomeFixed(SOME_FIXED_VALUE)
+ .setSomeBytes(SOME_BYTES_VALUE)
+ .setSomeNull(null)
+ .setSomeEnum(MyEnum.ENUM1)
+ .setSomeRecord(SOME_RECORD_VALUE)
+ .build();
+
+ return datum;
+ }
+}
diff --git a/pom.xml b/pom.xml
index 3f529747326d..d2d1ddfef91b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -103,7 +103,7 @@
extensions/kafka-extraction-namespace
extensions/cloudfiles-extensions
extensions/datasketches
-
+ extensions/avro-extensions
distribution