Repository: incubator-gobblin Updated Branches: refs/heads/master 7c2833a12 -> 6618c7f72
[GOBBLIN-481] Add "Alias" annotation to class, KafkaSimpleJsonExtractor. Closes #2351 from jackkidwell/master Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/6618c7f7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/6618c7f7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/6618c7f7 Branch: refs/heads/master Commit: 6618c7f72fffbe52494e7823d42f9e9cf2fbf785 Parents: 7c2833a Author: Jack Kidwell <[email protected]> Authored: Fri May 4 10:54:05 2018 -0700 Committer: Abhishek Tiwari <[email protected]> Committed: Fri May 4 10:54:05 2018 -0700 ---------------------------------------------------------------------- .../source/extractor/extract/kafka/KafkaSimpleJsonExtractor.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/6618c7f7/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleJsonExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleJsonExtractor.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleJsonExtractor.java index 44a2674..130ffdf 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleJsonExtractor.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleJsonExtractor.java @@ -23,10 +23,12 @@ import java.nio.charset.StandardCharsets; import com.google.gson.Gson; +import org.apache.gobblin.annotation.Alias; import org.apache.gobblin.configuration.WorkUnitState; import org.apache.gobblin.kafka.client.ByteArrayBasedKafkaRecord; import org.apache.gobblin.source.extractor.Extractor; +@Alias("KafkaSimpleJsonExtractor") public class KafkaSimpleJsonExtractor extends KafkaSimpleExtractor implements Extractor<String, byte[]> { private static final Gson gson = new Gson();
