Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2321#discussion_r191148855
--- 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) {
+ CarbonDataFileAttributes carbonDataFileAttributes =
+ new
CarbonDataFileAttributes(Long.parseLong(configuration.getTaskNo()),
+ (Long)
configuration.getDataLoadProperty(DataLoadProcessorConstants.FACT_TIME_STAMP));
+ DataMapWriterListener listener = new DataMapWriterListener();
+
listener.registerAllWriter(configuration.getTableSpec().getCarbonTable(),
--- End diff --
format the code properly
---
