1 files changed, 8 insertions, 5 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/pojo/PojoRecordReader.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/pojo/PojoRecordReader.java
index 3546c73bf..46784ecd0 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/pojo/PojoRecordReader.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/pojo/PojoRecordReader.java
@@ -17,14 +17,16 @@
  */
 package org.apache.drill.exec.store.pojo;
 
-import org.apache.drill.common.exceptions.DrillRuntimeException;
-import org.apache.drill.common.exceptions.ExecutionSetupException;
-import org.apache.drill.exec.physical.impl.OutputMutator;
-
 import java.lang.reflect.Field;
 import java.lang.reflect.Modifier;
-import java.util.ArrayList;
 import java.util.List;
+import java.util.ArrayList;
+
+import com.fasterxml.jackson.annotation.JsonTypeName;
+
+import org.apache.drill.common.exceptions.DrillRuntimeException;
+import org.apache.drill.common.exceptions.ExecutionSetupException;
+import org.apache.drill.exec.physical.impl.OutputMutator;
 
 /**
  * Reads values from the given list of pojo instances.
@@ -32,6 +34,7 @@ import java.util.List;
  *
  * @param <T> pojo class type
  */
+@JsonTypeName("PojoRecordReader")
 public class PojoRecordReader<T> extends AbstractPojoRecordReader<T> {
 
   private final Class<T> pojoClass;