[jira] [Created] (CARBONDATA-2627) remove dependecy of tech.allegro.schema.json2avro

[Akash R Nilugal (Jira)]

Babulal created CARBONDATA-2627:
-----------------------------------

             Summary: remove dependecy of tech.allegro.schema.json2avro
                 Key: CARBONDATA-2627
                 URL: https://issues.apache.org/jira/browse/CARBONDATA-2627
             Project: CarbonData
          Issue Type: Bug
            Reporter: Babulal


currently tech.allegro.schema.json2avro is used for json to avro converter but it is not formally supported by AVRO and may feature does not work in converter like byte data type. 

Below code can be used instead of 

 

def jsonToAvro( json:String, schemaStr:String) :GenericRecord= {
 var input :InputStream= null;
 var writer :DataFileWriter[GenericRecord] = null;
 var encoder :Encoder= null;
 var output :ByteArrayOutputStream= null;
 try {
 val schema = new org.apache.avro.Schema.Parser().parse(schemaStr);
 val reader = new GenericDatumReader[GenericRecord](schema);
 input = new ByteArrayInputStream(json.getBytes());
 output = new ByteArrayOutputStream();
 val din = new DataInputStream(input);
 writer = new DataFileWriter[GenericRecord](new GenericDatumWriter[GenericRecord]());
 writer.create(schema, output);
 val decoder = DecoderFactory.get().jsonDecoder(schema, din);
 var datum :GenericRecord=null;
 datum = reader.read(null, decoder);
 return datum;
 } finally {
 try {
 input.close();
 writer.close();
 } catch {
 case e:Exception => {
 e.printStackTrace()
 }

 }
 }
 }



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)