Github user ajantha-bhat commented on a diff in the pull request: https://github.com/apache/carbondata/pull/2653#discussion_r212542105 --- Diff: store/sdk/src/main/java/org/apache/carbondata/sdk/file/CarbonWriterBuilder.java --- @@ -360,6 +382,33 @@ public CarbonWriter buildWriterForAvroInput(org.apache.avro.Schema avroSchema) return new AvroCarbonWriter(loadModel); } + /** + * Build a {@link CarbonWriter}, which accepts Avro object + * @param avroSchema avro Schema object {org.apache.avro.Schema} + * @param numOfThreads number of threads() in which .write will be called. + * @return AvroCarbonWriter + * @throws IOException + * @throws InvalidLoadOptionException + */ + public CarbonWriter buildWriterForAvroInput(org.apache.avro.Schema avroSchema, short numOfThreads) --- End diff -- done
---