Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2832#discussion_r226211737
--- Diff:
integration/spark-common/src/main/scala/org/apache/spark/sql/execution/streaming/CarbonAppendableStreamSink.scala
---
@@ -102,6 +102,16 @@ class CarbonAppendableStreamSink(
CarbonProperties.getInstance().isEnableAutoHandoff
)
+ // measure data type array
+ private lazy val msrDataTypes = {
+ val msrList =
carbonLoadModel.getCarbonDataLoadSchema.getCarbonTable.getMeasures
--- End diff --
suggest to use map instead of `(0 until msrDataTypes.length).foreach`
---
