make schema accessible from the companion object of the annotated class about avro-scala-macro-annotations HOT 3 CLOSED

    [error] (run-main-6) java.io.IOException: Not a data file.
    java.io.IOException: Not a data file.
at org.apache.avro.file.DataFileStream.initialize(DataFileStream.java:102)
at org.apache.avro.file.DataFileStream.<init>(DataFileStream.java:84)

def deserialize[R]( is: InputStream): Iterator[R] = {
    val bis = if( is.markSupported ) is
              else new BufferedInputStream( is )
    bis.mark( MAX_SCHEMA_SIZE )
    val schema = new DataFileStream( bis, new GenericDatumReader[R]).getSchema
    bis.reset
    val dr = new SpecificDatumReader[R]( schema )
    val dfr= new DataFileStream[R]( bis, dr)
    dfr.iterator
  }

val schema = MyRecord.SCHEMA$
def deserialize[R]( schema: Schema, is: InputStream): Iterator[R] = {
    val dr = new SpecificDatumReader[R]( schema )
    val dfr= new DataFileStream[R]( bis, dr)
    dfr.iterator
  }