Github user akashrn5 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2321#discussion_r191151271
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/loading/AbstractDataLoadProcessorStep.java
---
@@ -149,6 +153,22 @@ protected CarbonRowBatch
processRowBatch(CarbonRowBatch rowBatch) {
*/
protected abstract String getStepName();
+ /**
+ * This method registers all writer listeners and returns the listener
+ * @param rangeId bucketId
+ * @return
+ */
+ protected DataMapWriterListener getDataMapWriterListener(int rangeId) {
--- End diff --
it i=will be zero in all places except in a call from
DataWriterProcessorStepImpl, in processRange function, so we can keep it i think
---
