Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2653#discussion_r212534244
--- 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 --
same comment as above
---
