Fixed git issue #14

datum_writer.go

@@ -230,16 +230,22 @@ func (this *SpecificDatumWriter) writeRecord(v reflect.Value, enc Encoder, s Sch
 }
 
 func (this *SpecificDatumWriter) findField(where reflect.Value, name string) (reflect.Value, error) {
-	elem := where.Elem() //TODO maybe check first?
-	field := elem.FieldByName(strings.ToUpper(name[0:1]) + name[1:])
+	if where.Kind() == reflect.Ptr {
+		where = where.Elem()
+	}
+	field := where.FieldByName(strings.ToUpper(name[0:1]) + name[1:])
 	if !field.IsValid() {
-		field = elem.FieldByName(name)
+		field = where.FieldByName(name)
 	}
 
 	if !field.IsValid() {
 		return reflect.Zero(nil), fmt.Errorf("Field %s does not exist", name)
 	}
 
+	if field.Kind() == reflect.Interface {
+		return field.Elem(), nil
+	}
+
 	return field, nil
 }
 

schema.go

@@ -5,7 +5,6 @@ import (
 	"fmt"
 	"math"
 	"reflect"
-	"strings"
 )
 
 const (
@@ -899,24 +898,3 @@ func dereference(v reflect.Value) reflect.Value {
 
 	return v
 }
-
-func findField(where reflect.Value, name string) (reflect.Value, bool) {
-	if where.Kind() != reflect.Struct {
-		return reflect.ValueOf(nil), false
-	}
-
-	field := where.FieldByName(strings.ToUpper(name[0:1]) + name[1:])
-	if !field.IsValid() {
-		field = where.FieldByName(name)
-	}
-
-	if !field.IsValid() {
-		return reflect.ValueOf(nil), false
-	}
-
-	if field.Kind() == reflect.Interface {
-		field = field.Elem()
-	}
-
-	return field, true
-}