Repository: incubator-carbondata Updated Branches: refs/heads/master 936c73d6b -> 510a4583c
Log the data size of each blocklet fix review comments Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/bf9f991a Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/bf9f991a Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/bf9f991a Branch: refs/heads/master Commit: bf9f991a94964794b872127099cc237dbfcc50bf Parents: 936c73d Author: Zhangshunyu <zhangshu...@huawei.com> Authored: Thu Oct 13 11:17:21 2016 +0800 Committer: jackylk <jacky.li...@huawei.com> Committed: Fri Oct 21 19:38:21 2016 +0800 ---------------------------------------------------------------------- .../writer/CarbonFactDataWriterImplForIntIndexAndAggBlock.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/bf9f991a/processing/src/main/java/org/apache/carbondata/processing/store/writer/CarbonFactDataWriterImplForIntIndexAndAggBlock.java ---------------------------------------------------------------------- diff --git a/processing/src/main/java/org/apache/carbondata/processing/store/writer/CarbonFactDataWriterImplForIntIndexAndAggBlock.java b/processing/src/main/java/org/apache/carbondata/processing/store/writer/CarbonFactDataWriterImplForIntIndexAndAggBlock.java index dc1d7b1..259482e 100644 --- a/processing/src/main/java/org/apache/carbondata/processing/store/writer/CarbonFactDataWriterImplForIntIndexAndAggBlock.java +++ b/processing/src/main/java/org/apache/carbondata/processing/store/writer/CarbonFactDataWriterImplForIntIndexAndAggBlock.java @@ -24,6 +24,8 @@ import java.nio.ByteBuffer; import java.nio.channels.FileChannel; import java.util.List; +import org.apache.carbondata.common.logging.LogService; +import org.apache.carbondata.common.logging.LogServiceFactory; import org.apache.carbondata.core.carbon.datastore.block.SegmentProperties; import org.apache.carbondata.core.carbon.metadata.schema.table.column.ColumnSchema; import org.apache.carbondata.core.constants.CarbonCommonConstants; @@ -45,6 +47,8 @@ public class CarbonFactDataWriterImplForIntIndexAndAggBlock extends AbstractFact private boolean[] isComplexType; private int numberOfNoDictionaryColumn; private boolean[] isDictionaryColumn; + private static final LogService LOGGER = LogServiceFactory.getLogService( + CarbonFactDataWriterImplForIntIndexAndAggBlock.class.getName()); public CarbonFactDataWriterImplForIntIndexAndAggBlock(String storeLocation, int measureCount, int mdKeyLength, String tableName, IFileManagerComposite fileManager, int[] keyBlockSize, @@ -252,6 +256,7 @@ public class CarbonFactDataWriterImplForIntIndexAndAggBlock extends AbstractFact holder.getKeyArray().length + holder.getDataArray().length + indexBlockSize; updateBlockletFileChannel(blockletDataSize); writeDataToFile(holder); + LOGGER.info("A new blocklet is added, its data size is: " + blockletDataSize + " Byte"); } /**
