diff --git a/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBJDBCDataSet.java b/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBJDBCDataSet.java index b4516efa7c81f..7ec09bce042fd 100644 --- a/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBJDBCDataSet.java +++ b/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBJDBCDataSet.java @@ -112,8 +112,8 @@ public IoTDBJDBCDataSet( this.zoneId = zoneId; columnSize = columnNameList.size(); - this.columnNameList = new ArrayList<>(); - this.columnTypeList = new ArrayList<>(); + this.columnNameList = new ArrayList<>(columnSize + (ignoreTimeStamp ? 0 : 1)); + this.columnTypeList = new ArrayList<>(columnSize + (ignoreTimeStamp ? 0 : 1)); if (!ignoreTimeStamp) { this.columnNameList.add(TIMESTAMP_STR); this.columnTypeList.add(String.valueOf(TSDataType.INT64)); @@ -191,8 +191,8 @@ public IoTDBJDBCDataSet( this.zoneId = zoneId; columnSize = columnNameList.size(); - this.columnNameList = new ArrayList<>(); - this.columnTypeList = new ArrayList<>(); + this.columnNameList = new ArrayList<>(columnSize + (ignoreTimeStamp ? 0 : 1)); + this.columnTypeList = new ArrayList<>(columnSize + (ignoreTimeStamp ? 0 : 1)); if (!ignoreTimeStamp) { this.columnNameList.add(TIMESTAMP_STR); this.columnTypeList.add(String.valueOf(TSDataType.INT64)); diff --git a/iotdb-client/session/src/main/java/org/apache/iotdb/session/Session.java b/iotdb-client/session/src/main/java/org/apache/iotdb/session/Session.java index 5d20754fff4be..fe9fb38f6dbbe 100644 --- a/iotdb-client/session/src/main/java/org/apache/iotdb/session/Session.java +++ b/iotdb-client/session/src/main/java/org/apache/iotdb/session/Session.java @@ -2648,7 +2648,7 @@ private List objectValuesListToByteBufferList( List> typesList, List> measurementsList) throws IoTDBConnectionException { - List buffersList = new ArrayList<>(); + List buffersList = new ArrayList<>(valuesList.size()); for (int i = 0; i < valuesList.size(); i++) { ByteBuffer buffer = SessionUtils.getValueBuffer(typesList.get(i), valuesList.get(i), measurementsList.get(i)); @@ -2879,7 +2879,7 @@ private void insertRelationalTabletWithLeaderCache(Tablet tablet) (k, v) -> { if (v == null) { List measurements = new ArrayList<>(tablet.getSchemas().size()); - List dataTypes = new ArrayList<>(); + List dataTypes = new ArrayList<>(tablet.getSchemas().size()); tablet .getSchemas() .forEach( @@ -3289,8 +3289,8 @@ private void updateTSInsertTabletsReq( return; } request.addToPrefixPaths(filtered.getDeviceId()); - List measurements = new ArrayList<>(); - List dataTypes = new ArrayList<>(); + List measurements = new ArrayList<>(filtered.getSchemas().size()); + List dataTypes = new ArrayList<>(filtered.getSchemas().size()); request.setIsAligned(isAligned); for (IMeasurementSchema measurementSchema : filtered.getSchemas()) { if (measurementSchema.getMeasurementName() == null) { @@ -3980,9 +3980,9 @@ public void createSchemaTemplate( List> encodings, List compressors) throws IoTDBConnectionException, StatementExecutionException { - List flatMeasurements = new ArrayList<>(); - List flatDataTypes = new ArrayList<>(); - List flatEncodings = new ArrayList<>(); + List flatMeasurements = new ArrayList<>(measurements.size()); + List flatDataTypes = new ArrayList<>(measurements.size()); + List flatEncodings = new ArrayList<>(measurements.size()); for (int idx = 0; idx < measurements.size(); idx++) { flatMeasurements.add(measurements.get(idx).get(0)); flatDataTypes.add(dataTypes.get(idx).get(0)); diff --git a/iotdb-client/session/src/main/java/org/apache/iotdb/session/SessionConnection.java b/iotdb-client/session/src/main/java/org/apache/iotdb/session/SessionConnection.java index 6bcc41859a8c4..47ed514e0c88f 100644 --- a/iotdb-client/session/src/main/java/org/apache/iotdb/session/SessionConnection.java +++ b/iotdb-client/session/src/main/java/org/apache/iotdb/session/SessionConnection.java @@ -1341,7 +1341,7 @@ private String logForReconnectionFailure() { if (endPointList == null) { return MSG_RECONNECTION_FAIL; } - List urls = new ArrayList<>(); + List urls = new ArrayList<>(endPointList.size()); for (TEndPoint end : endPointList) { urls.add(UrlUtils.convertTEndPointIpv4AndIpv6Url(end)); } diff --git a/iotdb-client/session/src/main/java/org/apache/iotdb/session/util/SessionUtils.java b/iotdb-client/session/src/main/java/org/apache/iotdb/session/util/SessionUtils.java index d6ff4d735ae50..5203fffd9157b 100644 --- a/iotdb-client/session/src/main/java/org/apache/iotdb/session/util/SessionUtils.java +++ b/iotdb-client/session/src/main/java/org/apache/iotdb/session/util/SessionUtils.java @@ -296,7 +296,7 @@ public static List parseSeedNodeUrls(List nodeUrls) { if (nodeUrls == null) { throw new NumberFormatException(SessionMessages.NODE_URLS_IS_NULL); } - List endPointsList = new ArrayList<>(); + List endPointsList = new ArrayList<>(nodeUrls.size()); for (String nodeUrl : nodeUrls) { try { endPointsList.add(UrlUtils.parseTEndPointIpv4AndIpv6Url(nodeUrl)); diff --git a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/SimpleTsBlockWithPositionComparator.java b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/SimpleTsBlockWithPositionComparator.java index 8cab1352032a2..5a068c5337141 100644 --- a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/SimpleTsBlockWithPositionComparator.java +++ b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/SimpleTsBlockWithPositionComparator.java @@ -36,7 +36,7 @@ public class SimpleTsBlockWithPositionComparator implements TsBlockWithPositionC public SimpleTsBlockWithPositionComparator( List types, List sortChannels, List sortOrders) { - List sortedTypes = new ArrayList<>(); + List sortedTypes = new ArrayList<>(sortChannels.size()); for (Integer sortChannel : sortChannels) { sortedTypes.add(types.get(sortChannel)); } diff --git a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/FilterAndProjectOperator.java b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/FilterAndProjectOperator.java index 5ab7e58a6962f..67d0d69874a36 100644 --- a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/FilterAndProjectOperator.java +++ b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/FilterAndProjectOperator.java @@ -164,7 +164,9 @@ private TsBlock getFilterTsBlock(TsBlock input) { // reuse this builder filterTsBlockBuilder.reset(); - List resultColumns = new ArrayList<>(); + List resultColumns = + new ArrayList<>( + input.getValueColumnCount() + (hasNonMappableUDF ? 0 : commonTransformerList.size())); for (int i = 0, n = input.getValueColumnCount(); i < n; i++) { resultColumns.add(input.getColumn(i)); } @@ -268,7 +270,7 @@ private TsBlock getTransformedTsBlock(TsBlock input) { leafColumnTransformer.initFromTsBlock(input); } - List resultColumns = new ArrayList<>(); + List resultColumns = new ArrayList<>(projectOutputTransformerList.size()); for (ColumnTransformer columnTransformer : projectOutputTransformerList) { columnTransformer.tryEvaluate(); resultColumns.add(columnTransformer.getColumn()); diff --git a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/PatternRecognitionOperator.java b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/PatternRecognitionOperator.java index d0ee968c0e569..28c184eb17d8b 100644 --- a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/PatternRecognitionOperator.java +++ b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/PatternRecognitionOperator.java @@ -117,7 +117,7 @@ public PatternRecognitionOperator( // Partition Part this.partitionChannels = ImmutableList.copyOf(partitionChannels); // Acquire partition channels' data types - List partitionDataTypes = new ArrayList<>(); + List partitionDataTypes = new ArrayList<>(partitionChannels.size()); for (Integer channel : partitionChannels) { partitionDataTypes.add(inputDataTypes.get(channel)); } diff --git a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/PatternPartitionExecutor.java b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/PatternPartitionExecutor.java index 82637f82125ef..4d475fbf40530 100644 --- a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/PatternPartitionExecutor.java +++ b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/PatternPartitionExecutor.java @@ -118,7 +118,7 @@ public PatternPartitionExecutor( this.matchNumber = 1; // Prepare for peer group comparing - List sortDataTypes = new ArrayList<>(); + List sortDataTypes = new ArrayList<>(sortChannels.size()); for (int channel : sortChannels) { TSDataType dataType = dataTypes.get(channel); sortDataTypes.add(dataType); diff --git a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/expression/Computation.java b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/expression/Computation.java index 59de959cd7cdf..860f8812d4f25 100644 --- a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/expression/Computation.java +++ b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/expression/Computation.java @@ -108,7 +108,7 @@ private static Computation parse( return new BinaryComputation(left, right, op); } else if (expression instanceof LogicalExpression) { LogicalExpression logicalExpr = (LogicalExpression) expression; - List computations = new ArrayList<>(); + List computations = new ArrayList<>(logicalExpr.getTerms().size()); for (Expression term : logicalExpr.getTerms()) { computations.add(parse(term, counter, symbolToIndex)); } diff --git a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/expression/NaryComputation.java b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/expression/NaryComputation.java index b077ccd1b3593..c7862f1a5241e 100644 --- a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/expression/NaryComputation.java +++ b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/expression/NaryComputation.java @@ -33,7 +33,7 @@ public NaryComputation(List terms, NaryOperator operator) { @Override public Object evaluate(List values) { - List operandValues = new ArrayList<>(); + List operandValues = new ArrayList<>(terms.size()); for (Computation term : terms) { operandValues.add(term.evaluate(values)); } diff --git a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/AbstractCaseWhenThenColumnTransformer.java b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/AbstractCaseWhenThenColumnTransformer.java index 5603bde031d1a..8452a590a25a1 100644 --- a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/AbstractCaseWhenThenColumnTransformer.java +++ b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/AbstractCaseWhenThenColumnTransformer.java @@ -46,7 +46,7 @@ protected AbstractCaseWhenThenColumnTransformer( whenTransformers.size() == thenTransformers.size(), CalcMessages .EXCEPTION_THE_SIZE_BETWEEN_WHENTRANSFORMERS_AND_THENTRANSFORMERS_NEEDS_TO_BE_SAME_AC796883); - this.whenThenTransformers = new ArrayList<>(); + this.whenThenTransformers = new ArrayList<>(whenTransformers.size()); for (int i = 0; i < whenTransformers.size(); i++) { this.whenThenTransformers.add(new Pair<>(whenTransformers.get(i), thenTransformers.get(i))); } diff --git a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/multi/LogicalAndMultiColumnTransformer.java b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/multi/LogicalAndMultiColumnTransformer.java index 7e8dce8502e6c..0510ce0c1944e 100644 --- a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/multi/LogicalAndMultiColumnTransformer.java +++ b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/multi/LogicalAndMultiColumnTransformer.java @@ -40,7 +40,7 @@ public void evaluateWithSelection(boolean[] selection) { boolean[] selectionCopy = selection.clone(); boolean[] hasNull = new boolean[selection.length]; - List childrenColumns = new ArrayList<>(); + List childrenColumns = new ArrayList<>(columnTransformerList.size()); for (ColumnTransformer child : columnTransformerList) { child.evaluateWithSelection(selectionCopy); Column childColumn = child.getColumn(); diff --git a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/multi/LogicalOrMultiColumnTransformer.java b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/multi/LogicalOrMultiColumnTransformer.java index 326948200130c..b754de9f13ab1 100644 --- a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/multi/LogicalOrMultiColumnTransformer.java +++ b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/multi/LogicalOrMultiColumnTransformer.java @@ -40,7 +40,7 @@ public void evaluateWithSelection(boolean[] selection) { boolean[] selectionCopy = selection.clone(); boolean[] hasNull = new boolean[selection.length]; - List childColumns = new ArrayList<>(); + List childColumns = new ArrayList<>(columnTransformerList.size()); for (ColumnTransformer child : columnTransformerList) { child.evaluateWithSelection(selectionCopy); Column childColumn = child.getColumn(); diff --git a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/multi/MultiColumnTransformer.java b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/multi/MultiColumnTransformer.java index 09cb1530bc475..827836a39ccb3 100644 --- a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/multi/MultiColumnTransformer.java +++ b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/multi/MultiColumnTransformer.java @@ -61,7 +61,7 @@ public void evaluate() { @Override public void evaluateWithSelection(boolean[] selection) { - List childrenColumns = new ArrayList<>(); + List childrenColumns = new ArrayList<>(columnTransformerList.size()); for (ColumnTransformer child : columnTransformerList) { child.evaluateWithSelection(selection); diff --git a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/utils/sort/DiskSpiller.java b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/utils/sort/DiskSpiller.java index cdda259e2b076..cc7d91b309283 100644 --- a/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/utils/sort/DiskSpiller.java +++ b/iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/utils/sort/DiskSpiller.java @@ -155,7 +155,7 @@ public boolean hasSpilledData() { } private List getFilePaths() { - List filePaths = new ArrayList<>(); + List filePaths = new ArrayList<>(fileIndex); for (int i = 0; i < fileIndex; i++) { filePaths.add(filePrefix + String.format("%05d", i) + FILE_SUFFIX); } @@ -164,7 +164,7 @@ private List getFilePaths() { public List getReaders(SortBufferManager sortBufferManager) throws IoTDBException { List filePaths = getFilePaths(); - List sortReaders = new ArrayList<>(); + List sortReaders = new ArrayList<>(filePaths.size()); try { for (String filePath : filePaths) { sortReaders.add(new FileSpillerReader(filePath, sortBufferManager, serde)); diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/auth/AuthorTreePlan.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/auth/AuthorTreePlan.java index a1f5a6d3c97ad..3775e20c82438 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/auth/AuthorTreePlan.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/auth/AuthorTreePlan.java @@ -24,13 +24,13 @@ import org.apache.iotdb.commons.utils.BasicStructureSerDeUtil; import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlanType; +import com.google.common.collect.Sets; import org.apache.tsfile.utils.ReadWriteIOUtils; import java.io.DataOutputStream; import java.io.IOException; import java.nio.ByteBuffer; import java.util.ArrayList; -import java.util.HashSet; import java.util.List; import java.util.Objects; import java.util.Set; @@ -244,7 +244,7 @@ protected void deserializeImpl(ByteBuffer buffer) { this.permissions = null; } else { int permissionsSize = buffer.getInt(); - this.permissions = new HashSet<>(); + this.permissions = Sets.newHashSetWithExpectedSize(permissionsSize); for (int i = 0; i < permissionsSize; i++) { permissions.add(buffer.getInt()); } diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeDeactivateTemplatePlan.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeDeactivateTemplatePlan.java index 6b09f7c9fefc0..e71aad9d92d67 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeDeactivateTemplatePlan.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeDeactivateTemplatePlan.java @@ -25,13 +25,13 @@ import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlan; import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlanType; +import com.google.common.collect.Maps; import org.apache.tsfile.utils.ReadWriteIOUtils; import java.io.DataOutputStream; import java.io.IOException; import java.nio.ByteBuffer; import java.util.ArrayList; -import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Objects; @@ -69,7 +69,7 @@ protected void serializeImpl(final DataOutputStream stream) throws IOException { @Override protected void deserializeImpl(final ByteBuffer buffer) throws IOException { final int size = ReadWriteIOUtils.readInt(buffer); - templateSetInfo = new HashMap<>(); + templateSetInfo = Maps.newHashMapWithExpectedSize(size); for (int i = 0; i < size; i++) { final PartialPath pattern = (PartialPath) PathDeserializeUtil.deserialize(buffer); final int templateNum = ReadWriteIOUtils.readInt(buffer); diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/task/OperateMultiplePipesPlanV2.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/task/OperateMultiplePipesPlanV2.java index d41e126101be3..324d9603736a9 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/task/OperateMultiplePipesPlanV2.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/task/OperateMultiplePipesPlanV2.java @@ -77,8 +77,8 @@ protected void serializeImpl(DataOutputStream stream) throws IOException { @Override protected void deserializeImpl(ByteBuffer buffer) throws IOException { if (ReadWriteIOUtils.readBool(buffer)) { - subPlans = new ArrayList<>(); int size = ReadWriteIOUtils.readInt(buffer); + subPlans = new ArrayList<>(size); for (int i = 0; i < size; i++) { final boolean isLastSubPlan = i == size - 1; short type = ReadWriteIOUtils.readShort(buffer); diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/subscription/topic/AlterMultipleTopicsPlan.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/subscription/topic/AlterMultipleTopicsPlan.java index d3dd66439f68b..62e674b43d1d3 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/subscription/topic/AlterMultipleTopicsPlan.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/subscription/topic/AlterMultipleTopicsPlan.java @@ -65,8 +65,8 @@ protected void serializeImpl(DataOutputStream stream) throws IOException { @Override protected void deserializeImpl(ByteBuffer buffer) throws IOException { if (ReadWriteIOUtils.readBool(buffer)) { - subPlans = new ArrayList<>(); int size = ReadWriteIOUtils.readInt(buffer); + subPlans = new ArrayList<>(size); for (int i = 0; i < size; i++) { // This will read the type of the plan (AlterTopicPlan), which will be ignored ReadWriteIOUtils.readShort(buffer); diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeactivateTemplateProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeactivateTemplateProcedure.java index b2875b7fc41b2..828ec9d8d6dea 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeactivateTemplateProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeactivateTemplateProcedure.java @@ -49,6 +49,7 @@ import org.apache.iotdb.pipe.api.exception.PipeException; import org.apache.iotdb.rpc.TSStatusCode; +import com.google.common.collect.Maps; import org.apache.tsfile.utils.ReadWriteIOUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -384,7 +385,7 @@ public void deserialize(ByteBuffer byteBuffer) { super.deserialize(byteBuffer); queryId = ReadWriteIOUtils.readString(byteBuffer); int size = ReadWriteIOUtils.readInt(byteBuffer); - Map> templateSetInfo = new HashMap<>(); + Map> templateSetInfo = Maps.newHashMapWithExpectedSize(size); for (int i = 0; i < size; i++) { PartialPath pattern = (PartialPath) PathDeserializeUtil.deserialize(byteBuffer); int templateNum = ReadWriteIOUtils.readInt(byteBuffer); diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/AuthOperationProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/AuthOperationProcedure.java index e3ff2c08188bb..bf37a6de80351 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/AuthOperationProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/AuthOperationProcedure.java @@ -220,7 +220,7 @@ public void serialize(DataOutputStream stream) throws IOException { public void deserialize(ByteBuffer byteBuffer) { super.deserialize(byteBuffer); int size = ReadWriteIOUtils.readInt(byteBuffer); - this.datanodes = new ArrayList<>(); + this.datanodes = new ArrayList<>(size); for (int i = 0; i < size; i++) { TDataNodeConfiguration datanode = ThriftCommonsSerDeUtils.deserializeTDataNodeConfiguration(byteBuffer); diff --git a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionQueueRegistry.java b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionQueueRegistry.java index 0cc06eeff5278..d2de8f93fd981 100644 --- a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionQueueRegistry.java +++ b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionQueueRegistry.java @@ -88,7 +88,8 @@ public synchronized int size() { } public synchronized Collection getRetentionPolicies() { - final Collection retentionPolicies = new ArrayList<>(); + final Collection retentionPolicies = + new ArrayList<>(queues.size()); for (final SubscriptionQueueRegistration registration : queues.values()) { retentionPolicies.add(registration.retentionPolicy); } @@ -103,7 +104,7 @@ public Collection getRetainedMinVersionIds() { } } - final Collection retainedMinVersionIds = new ArrayList<>(); + final Collection retainedMinVersionIds = new ArrayList<>(suppliers.size()); for (final LongSupplier supplier : suppliers) { retainedMinVersionIds.add(supplier.getAsLong()); } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/exchange/payload/FetchCombineResultRequest.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/exchange/payload/FetchCombineResultRequest.java index 03f8721f17bb2..97d6c4503e60b 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/exchange/payload/FetchCombineResultRequest.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/exchange/payload/FetchCombineResultRequest.java @@ -91,8 +91,8 @@ private FetchCombineResultRequest convertToTPipeTransferReq( private FetchCombineResultRequest translateFromTPipeTransferReq(TPipeTransferReq transferReq) { pipeName = ReadWriteIOUtils.readString(transferReq.body); creationTime = ReadWriteIOUtils.readLong(transferReq.body); - combineIdList = new ArrayList<>(); final int combineIdListSize = ReadWriteIOUtils.readInt(transferReq.body); + combineIdList = new ArrayList<>(combineIdListSize); for (int i = 0; i < combineIdListSize; i++) { combineIdList.add(ReadWriteIOUtils.readString(transferReq.body)); } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/TimeseriesContext.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/TimeseriesContext.java index ecad26bac004c..143cdacb79877 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/TimeseriesContext.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/TimeseriesContext.java @@ -22,6 +22,7 @@ import org.apache.iotdb.db.queryengine.common.schematree.IMeasurementSchemaInfo; import org.apache.iotdb.db.schemaengine.schemaregion.utils.MetaUtils; +import com.google.common.collect.Maps; import org.apache.tsfile.utils.Pair; import org.apache.tsfile.utils.ReadWriteIOUtils; @@ -389,7 +390,8 @@ public static TimeseriesContext deserialize(ByteBuffer buffer) { int activeCountMultiplier = ReadWriteIOUtils.readInt(buffer); boolean logicalView = ReadWriteIOUtils.readBool(buffer); int activeLogicalViewContextMapSize = ReadWriteIOUtils.readInt(buffer); - Map activeLogicalViewContextMap = new HashMap<>(); + Map activeLogicalViewContextMap = + Maps.newHashMapWithExpectedSize(activeLogicalViewContextMapSize); for (int i = 0; i < activeLogicalViewContextMapSize; i++) { activeLogicalViewContextMap.put( ReadWriteIOUtils.readString(buffer), TimeseriesContext.deserialize(buffer)); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceFailureInfo.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceFailureInfo.java index 84465e4ca75de..c333e49a9a3e8 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceFailureInfo.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceFailureInfo.java @@ -166,8 +166,6 @@ public void serialize(DataOutputStream outputStream) throws IOException { public static FragmentInstanceFailureInfo deserialize(ByteBuffer byteBuffer) { final String message = ReadWriteIOUtils.readString(byteBuffer); FragmentInstanceFailureInfo cause; - List suppressed = new ArrayList<>(); - List stack = new ArrayList<>(); int flag = ReadWriteIOUtils.readInt(byteBuffer); if (flag == 0) { cause = null; @@ -175,10 +173,12 @@ public static FragmentInstanceFailureInfo deserialize(ByteBuffer byteBuffer) { cause = deserialize(byteBuffer); } int suppressedSize = ReadWriteIOUtils.readInt(byteBuffer); + List suppressed = new ArrayList<>(suppressedSize); for (int i = 0; i < suppressedSize; i++) { suppressed.add(deserialize(byteBuffer)); } int stackSize = ReadWriteIOUtils.readInt(byteBuffer); + List stack = new ArrayList<>(stackSize); for (int i = 0; i < stackSize; i++) { stack.add(ReadWriteIOUtils.readString(byteBuffer)); } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/TransformOperator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/TransformOperator.java index e2c7984b49998..9a4526c5bfe5f 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/TransformOperator.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/TransformOperator.java @@ -288,7 +288,7 @@ public TsBlock next() throws Exception { protected void prepareTsBlockBuilder(TsBlockBuilder tsBlockBuilder) { if (outputDataTypes == null) { - outputDataTypes = new ArrayList<>(); + outputDataTypes = new ArrayList<>(transformers.length); for (LayerReader reader : transformers) { outputDataTypes.add(reader.getDataTypes()[0]); } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/multi/FunctionExpression.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/multi/FunctionExpression.java index f977a24a1bb33..a1b860880dafd 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/multi/FunctionExpression.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/multi/FunctionExpression.java @@ -110,7 +110,7 @@ public FunctionExpression(ByteBuffer byteBuffer) { functionAttributes = ReadWriteIOUtils.readLinkedHashMap(byteBuffer); int expressionSize = ReadWriteIOUtils.readInt(byteBuffer); - expressions = new ArrayList<>(); + expressions = new ArrayList<>(expressionSize); for (int i = 0; i < expressionSize; i++) { expressions.add(Expression.deserialize(byteBuffer)); } @@ -305,7 +305,7 @@ public boolean isMappable(Map, TSDataType> expressionTypes) public List getPaths() { if (paths == null) { - paths = new ArrayList<>(); + paths = new ArrayList<>(expressions.size()); for (Expression expression : expressions) { paths.add( expression instanceof TimeSeriesOperand diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/ColumnTransformerVisitor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/ColumnTransformerVisitor.java index 17871eda0b15d..561358eecf5c9 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/ColumnTransformerVisitor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/ColumnTransformerVisitor.java @@ -387,8 +387,10 @@ public ColumnTransformer visitCaseWhenThenExpression( context.inputDataTypes.add(context.getType(caseWhenThenExpression)); context.cache.put(caseWhenThenExpression, identity); } else { - List whenList = new ArrayList<>(); - List thenList = new ArrayList<>(); + List whenList = + new ArrayList<>(caseWhenThenExpression.getWhenThenExpressions().size()); + List thenList = + new ArrayList<>(caseWhenThenExpression.getWhenThenExpressions().size()); for (WhenThenExpression whenThenExpression : caseWhenThenExpression.getWhenThenExpressions()) { whenList.add(this.process(whenThenExpression.getWhen(), context)); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/CompleteMeasurementSchemaVisitor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/CompleteMeasurementSchemaVisitor.java index bac3b533f0c7d..341b8eee63529 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/CompleteMeasurementSchemaVisitor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/CompleteMeasurementSchemaVisitor.java @@ -78,7 +78,7 @@ public Expression visitTernaryExpression( public Expression visitFunctionExpression( FunctionExpression functionExpression, ISchemaTree schemaTree) { List children = functionExpression.getExpressions(); - List replacedChildren = new ArrayList<>(); + List replacedChildren = new ArrayList<>(children.size()); for (Expression child : children) { replacedChildren.add(this.process(child, schemaTree)); } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/IntermediateLayerVisitor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/IntermediateLayerVisitor.java index 90109818be8f8..60d85f050e81e 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/IntermediateLayerVisitor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/IntermediateLayerVisitor.java @@ -428,7 +428,8 @@ private UDFQueryTransformer getUdfTransformer( private IntermediateLayer constructUdfInputIntermediateLayer( FunctionExpression functionExpression, IntermediateLayerVisitorContext context) { - List intermediateLayers = new ArrayList<>(); + List intermediateLayers = + new ArrayList<>(functionExpression.getExpressions().size()); for (Expression expression : functionExpression.getExpressions()) { intermediateLayers.add(this.process(expression, context)); } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/LevelTimeSeriesCountNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/LevelTimeSeriesCountNode.java index b0e1e682ad7be..073c17df26b61 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/LevelTimeSeriesCountNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/LevelTimeSeriesCountNode.java @@ -31,6 +31,7 @@ import org.apache.iotdb.commons.schema.template.Template; import org.apache.iotdb.db.i18n.DataNodeQueryMessages; +import com.google.common.collect.Maps; import org.apache.tsfile.utils.ReadWriteIOUtils; import jakarta.validation.constraints.NotNull; @@ -38,7 +39,6 @@ import java.io.DataOutputStream; import java.io.IOException; import java.nio.ByteBuffer; -import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Objects; @@ -163,7 +163,7 @@ public static PlanNode deserialize(ByteBuffer buffer) { boolean includeSystemDatabase = ReadWriteIOUtils.readBool(buffer); boolean includeAuditDatabase = ReadWriteIOUtils.readBool(buffer); int templateNum = ReadWriteIOUtils.readInt(buffer); - Map templateMap = new HashMap<>(); + Map templateMap = Maps.newHashMapWithExpectedSize(templateNum); Template template; for (int i = 0; i < templateNum; i++) { template = new Template(); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/SeriesSchemaFetchScanNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/SeriesSchemaFetchScanNode.java index 4509ebdc6f602..9b0a40636c442 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/SeriesSchemaFetchScanNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/SeriesSchemaFetchScanNode.java @@ -30,12 +30,12 @@ import org.apache.iotdb.db.queryengine.plan.planner.plan.node.PlanNodeUtil; import org.apache.iotdb.db.queryengine.plan.planner.plan.node.PlanVisitor; +import com.google.common.collect.Maps; import org.apache.tsfile.utils.ReadWriteIOUtils; import java.io.DataOutputStream; import java.io.IOException; import java.nio.ByteBuffer; -import java.util.HashMap; import java.util.Map; /** This class defines the scan task of schema fetcher. */ @@ -131,7 +131,7 @@ public static SeriesSchemaFetchScanNode deserialize(ByteBuffer byteBuffer) { PathPatternTree patternTree = PathPatternTree.deserialize(byteBuffer); int templateNum = ReadWriteIOUtils.readInt(byteBuffer); - Map templateMap = new HashMap<>(); + Map templateMap = Maps.newHashMapWithExpectedSize(templateNum); Template template; for (int i = 0; i < templateNum; i++) { template = new Template(); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/TimeSeriesCountNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/TimeSeriesCountNode.java index 2dafac1779fca..1158de6c208a1 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/TimeSeriesCountNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/TimeSeriesCountNode.java @@ -32,6 +32,7 @@ import org.apache.iotdb.commons.schema.template.Template; import org.apache.iotdb.db.i18n.DataNodeQueryMessages; +import com.google.common.collect.Maps; import org.apache.tsfile.utils.ReadWriteIOUtils; import jakarta.validation.constraints.NotNull; @@ -39,7 +40,6 @@ import java.io.DataOutputStream; import java.io.IOException; import java.nio.ByteBuffer; -import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Objects; @@ -158,7 +158,7 @@ public static PlanNode deserialize(ByteBuffer buffer) { boolean includeAuditDatabase = ReadWriteIOUtils.readBool(buffer); int templateNum = ReadWriteIOUtils.readInt(buffer); - Map templateMap = new HashMap<>(); + Map templateMap = Maps.newHashMapWithExpectedSize(templateNum); Template template; for (int i = 0; i < templateNum; i++) { template = new Template(); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/TimeSeriesSchemaScanNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/TimeSeriesSchemaScanNode.java index 5a035d31c5402..819153b7b571d 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/TimeSeriesSchemaScanNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/TimeSeriesSchemaScanNode.java @@ -32,6 +32,7 @@ import org.apache.iotdb.db.i18n.DataNodeQueryMessages; import org.apache.iotdb.db.queryengine.plan.statement.component.Ordering; +import com.google.common.collect.Maps; import org.apache.tsfile.utils.ReadWriteIOUtils; import jakarta.validation.constraints.NotNull; @@ -39,7 +40,6 @@ import java.io.DataOutputStream; import java.io.IOException; import java.nio.ByteBuffer; -import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Objects; @@ -157,7 +157,7 @@ public static TimeSeriesSchemaScanNode deserialize(ByteBuffer byteBuffer) { } int templateNum = ReadWriteIOUtils.readInt(byteBuffer); - Map templateMap = new HashMap<>(); + Map templateMap = Maps.newHashMapWithExpectedSize(templateNum); Template template; for (int i = 0; i < templateNum; i++) { template = new Template(); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/write/CreateAlignedTimeSeriesNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/write/CreateAlignedTimeSeriesNode.java index e9c5702464735..f4bc37a0cee9a 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/write/CreateAlignedTimeSeriesNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/write/CreateAlignedTimeSeriesNode.java @@ -221,30 +221,30 @@ public static CreateAlignedTimeSeriesNode deserialize(ByteBuffer byteBuffer) { DataNodeQueryMessages.CAN_NOT_DESERIALIZE_CREATEALIGNEDTIMESERIESNODE, e); } - measurements = new ArrayList<>(); int size = byteBuffer.getInt(); + measurements = new ArrayList<>(size); for (int i = 0; i < size; i++) { measurements.add(ReadWriteIOUtils.readString(byteBuffer)); } - dataTypes = new ArrayList<>(); + dataTypes = new ArrayList<>(size); for (int i = 0; i < size; i++) { dataTypes.add(TSDataType.values()[byteBuffer.get()]); } - encodings = new ArrayList<>(); + encodings = new ArrayList<>(size); for (int i = 0; i < size; i++) { encodings.add(TSEncoding.values()[byteBuffer.get()]); } - compressors = new ArrayList<>(); + compressors = new ArrayList<>(size); for (int i = 0; i < size; i++) { compressors.add(CompressionType.deserialize(byteBuffer.get())); } byte label = byteBuffer.get(); if (label >= 0) { - aliasList = new ArrayList<>(); + aliasList = new ArrayList<>(label == 1 ? size : 0); if (label == 1) { for (int i = 0; i < size; i++) { aliasList.add(ReadWriteIOUtils.readString(byteBuffer)); @@ -254,7 +254,7 @@ public static CreateAlignedTimeSeriesNode deserialize(ByteBuffer byteBuffer) { label = byteBuffer.get(); if (label >= 0) { - tagsList = new ArrayList<>(); + tagsList = new ArrayList<>(label == 1 ? size : 0); if (label == 1) { for (int i = 0; i < size; i++) { tagsList.add(ReadWriteIOUtils.readMap(byteBuffer)); @@ -264,7 +264,7 @@ public static CreateAlignedTimeSeriesNode deserialize(ByteBuffer byteBuffer) { label = byteBuffer.get(); if (label >= 0) { - attributesList = new ArrayList<>(); + attributesList = new ArrayList<>(label == 1 ? size : 0); if (label == 1) { for (int i = 0; i < size; i++) { attributesList.add(ReadWriteIOUtils.readMap(byteBuffer)); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/write/MeasurementGroup.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/write/MeasurementGroup.java index 8667f6e21e12c..699b904b6696b 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/write/MeasurementGroup.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/write/MeasurementGroup.java @@ -341,31 +341,31 @@ public void serialize(DataOutputStream stream) throws IOException { } public void deserialize(ByteBuffer byteBuffer) { - measurements = new ArrayList<>(); int size = byteBuffer.getInt(); + measurements = new ArrayList<>(size); for (int i = 0; i < size; i++) { measurements.add(ReadWriteIOUtils.readString(byteBuffer)); } measurementSet.addAll(measurements); - dataTypes = new ArrayList<>(); + dataTypes = new ArrayList<>(size); for (int i = 0; i < size; i++) { dataTypes.add(TSDataType.values()[byteBuffer.get()]); } - encodings = new ArrayList<>(); + encodings = new ArrayList<>(size); for (int i = 0; i < size; i++) { encodings.add(TSEncoding.values()[byteBuffer.get()]); } - compressors = new ArrayList<>(); + compressors = new ArrayList<>(size); for (int i = 0; i < size; i++) { compressors.add(CompressionType.deserialize(byteBuffer.get())); } byte label = byteBuffer.get(); if (label >= 0) { - aliasList = new ArrayList<>(); + aliasList = new ArrayList<>(label == 1 ? size : 0); if (label == 1) { for (int i = 0; i < size; i++) { aliasList.add(ReadWriteIOUtils.readString(byteBuffer)); @@ -375,7 +375,7 @@ public void deserialize(ByteBuffer byteBuffer) { label = byteBuffer.get(); if (label >= 0) { - tagsList = new ArrayList<>(); + tagsList = new ArrayList<>(label == 1 ? size : 0); if (label == 1) { for (int i = 0; i < size; i++) { tagsList.add(ReadWriteIOUtils.readMap(byteBuffer)); @@ -385,7 +385,7 @@ public void deserialize(ByteBuffer byteBuffer) { label = byteBuffer.get(); if (label >= 0) { - attributesList = new ArrayList<>(); + attributesList = new ArrayList<>(label == 1 ? size : 0); if (label == 1) { for (int i = 0; i < size; i++) { attributesList.add(ReadWriteIOUtils.readMap(byteBuffer)); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/sink/IdentitySinkNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/sink/IdentitySinkNode.java index 6ce7fb1e2a7b5..c59a22f7f052e 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/sink/IdentitySinkNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/sink/IdentitySinkNode.java @@ -101,7 +101,7 @@ public String toString() { public static IdentitySinkNode deserialize(ByteBuffer byteBuffer) { int size = ReadWriteIOUtils.readInt(byteBuffer); - List downStreamChannelLocationList = new ArrayList<>(); + List downStreamChannelLocationList = new ArrayList<>(size); for (int i = 0; i < size; i++) { downStreamChannelLocationList.add(DownStreamChannelLocation.deserialize(byteBuffer)); } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/sink/ShuffleSinkNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/sink/ShuffleSinkNode.java index 8348d2d4644ef..b3804b355f6b7 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/sink/ShuffleSinkNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/sink/ShuffleSinkNode.java @@ -100,7 +100,7 @@ public String toString() { public static ShuffleSinkNode deserialize(ByteBuffer byteBuffer) { int size = ReadWriteIOUtils.readInt(byteBuffer); - List downStreamChannelLocationList = new ArrayList<>(); + List downStreamChannelLocationList = new ArrayList<>(size); for (int i = 0; i < size; i++) { downStreamChannelLocationList.add(DownStreamChannelLocation.deserialize(byteBuffer)); } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/AlignedSeriesAggregationScanNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/AlignedSeriesAggregationScanNode.java index 5c783ec88e9c0..463f0375a39fd 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/AlignedSeriesAggregationScanNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/AlignedSeriesAggregationScanNode.java @@ -251,7 +251,8 @@ protected void serializeAttributes(DataOutputStream stream) throws IOException { public static AlignedSeriesAggregationScanNode deserialize(ByteBuffer byteBuffer) { AlignedPath alignedPath = (AlignedPath) PathDeserializeUtil.deserialize(byteBuffer); int aggregateDescriptorSize = ReadWriteIOUtils.readInt(byteBuffer); - List aggregationDescriptorList = new ArrayList<>(); + List aggregationDescriptorList = + new ArrayList<>(aggregateDescriptorSize); for (int i = 0; i < aggregateDescriptorSize; i++) { aggregationDescriptorList.add(AggregationDescriptor.deserialize(byteBuffer)); } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/DeviceRegionScanNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/DeviceRegionScanNode.java index af96dcc08783c..3574fa859f54a 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/DeviceRegionScanNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/DeviceRegionScanNode.java @@ -34,6 +34,7 @@ import org.apache.iotdb.db.queryengine.plan.planner.plan.node.PlanVisitor; import com.google.common.collect.ImmutableList; +import com.google.common.collect.Maps; import org.apache.tsfile.utils.ReadWriteIOUtils; import java.io.DataOutputStream; @@ -105,7 +106,7 @@ public int allowedChildCount() { public static PlanNode deserialize(ByteBuffer buffer) { int size = ReadWriteIOUtils.readInt(buffer); - Map devicePathToContextMap = new HashMap<>(); + Map devicePathToContextMap = Maps.newHashMapWithExpectedSize(size); for (int i = 0; i < size; i++) { PartialPath path = (PartialPath) PathDeserializeUtil.deserialize(buffer); devicePathToContextMap.put(path, DeviceContext.deserialize(buffer)); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/SeriesAggregationScanNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/SeriesAggregationScanNode.java index dd0fd381806dd..ac67601d8495d 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/SeriesAggregationScanNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/SeriesAggregationScanNode.java @@ -241,7 +241,8 @@ protected void serializeAttributes(DataOutputStream stream) throws IOException { public static SeriesAggregationScanNode deserialize(ByteBuffer byteBuffer) { MeasurementPath partialPath = (MeasurementPath) PathDeserializeUtil.deserialize(byteBuffer); int aggregateDescriptorSize = ReadWriteIOUtils.readInt(byteBuffer); - List aggregationDescriptorList = new ArrayList<>(); + List aggregationDescriptorList = + new ArrayList<>(aggregateDescriptorSize); for (int i = 0; i < aggregateDescriptorSize; i++) { aggregationDescriptorList.add(AggregationDescriptor.deserialize(byteBuffer)); } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/TimeseriesRegionScanNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/TimeseriesRegionScanNode.java index 24bcf28840334..397ccba0f24e0 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/TimeseriesRegionScanNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/TimeseriesRegionScanNode.java @@ -36,6 +36,7 @@ import org.apache.iotdb.db.queryengine.plan.planner.plan.node.PlanVisitor; import com.google.common.collect.ImmutableList; +import com.google.common.collect.Maps; import org.apache.tsfile.utils.ReadWriteIOUtils; import org.apache.tsfile.write.schema.IMeasurementSchema; import org.apache.tsfile.write.schema.MeasurementSchema; @@ -145,11 +146,12 @@ public static PlanNode deserialize(ByteBuffer buffer) { PartialPath devicePath = new PartialPath(nodes); int pathSize = ReadWriteIOUtils.readInt(buffer); - Map> measurementToSchemaInfo = new HashMap<>(); + Map> measurementToSchemaInfo = + Maps.newHashMapWithExpectedSize(pathSize); for (int j = 0; j < pathSize; j++) { PartialPath path = deserializePartialPath(nodes, buffer); int schemaSize = ReadWriteIOUtils.readInt(buffer); - List schemaInfos = new ArrayList<>(); + List schemaInfos = new ArrayList<>(schemaSize); for (int k = 0; k < schemaSize; k++) { schemaInfos.add(TimeseriesContext.deserialize(buffer)); } @@ -308,12 +310,12 @@ private static PartialPath deserializePartialPath(String[] deviceNodes, ByteBuff return new MeasurementPath(newNodes); } else { int size = ReadWriteIOUtils.readInt(buffer); - List measurements = new ArrayList<>(); - List schemaList = new ArrayList<>(); + List measurements = new ArrayList<>(size); for (int i = 0; i < size; i++) { measurements.add(ReadWriteIOUtils.readString(buffer)); } size = ReadWriteIOUtils.readInt(buffer); + List schemaList = new ArrayList<>(size); for (int i = 0; i < size; i++) { schemaList.add(MeasurementSchema.deserializeFrom(buffer)); } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/InsertMultiTabletsNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/InsertMultiTabletsNode.java index 8d484933e8f3d..81ec30db34f08 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/InsertMultiTabletsNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/InsertMultiTabletsNode.java @@ -228,10 +228,9 @@ public List getOutputColumnNames() { public static InsertMultiTabletsNode deserialize(ByteBuffer byteBuffer) { PlanNodeId planNodeId; - List insertTabletNodeList = new ArrayList<>(); - List parentIndex = new ArrayList<>(); - int size = byteBuffer.getInt(); + List insertTabletNodeList = new ArrayList<>(size); + List parentIndex = new ArrayList<>(size); for (int i = 0; i < size; i++) { InsertTabletNode insertTabletNode = new InsertTabletNode(new PlanNodeId("")); insertTabletNode.subDeserialize(byteBuffer); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/InsertRowsNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/InsertRowsNode.java index 7071f9927c08c..c2ba7c04791ec 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/InsertRowsNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/InsertRowsNode.java @@ -229,10 +229,9 @@ public List getOutputColumnNames() { public static InsertRowsNode deserialize(ByteBuffer byteBuffer) { PlanNodeId planNodeId; - List insertRowNodeList = new ArrayList<>(); - List insertRowNodeIndex = new ArrayList<>(); - int size = byteBuffer.getInt(); + List insertRowNodeList = new ArrayList<>(size); + List insertRowNodeIndex = new ArrayList<>(size); for (int i = 0; i < size; i++) { InsertRowNode insertRowNode = new InsertRowNode(new PlanNodeId("")); insertRowNode.subDeserialize(byteBuffer); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/RelationalInsertRowsNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/RelationalInsertRowsNode.java index c76e7f327dd27..4a98819c6487f 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/RelationalInsertRowsNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/RelationalInsertRowsNode.java @@ -115,10 +115,9 @@ public R accept(IPlanVisitor visitor, C context) { public static RelationalInsertRowsNode deserialize(ByteBuffer byteBuffer) { PlanNodeId planNodeId; - List insertRowNodeList = new ArrayList<>(); - List insertRowNodeIndex = new ArrayList<>(); - int size = byteBuffer.getInt(); + List insertRowNodeList = new ArrayList<>(size); + List insertRowNodeIndex = new ArrayList<>(size); for (int i = 0; i < size; i++) { RelationalInsertRowNode insertRowNode = new RelationalInsertRowNode(new PlanNodeId("")); insertRowNode.subDeserialize(byteBuffer); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/parameter/model/ModelInferenceDescriptor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/parameter/model/ModelInferenceDescriptor.java index 1301ec97eb32e..cb8b9deb58597 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/parameter/model/ModelInferenceDescriptor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/parameter/model/ModelInferenceDescriptor.java @@ -21,13 +21,13 @@ import org.apache.iotdb.commons.model.ModelInformation; +import com.google.common.collect.Maps; import org.apache.tsfile.utils.ReadWriteIOUtils; import java.io.DataOutputStream; import java.io.IOException; import java.nio.ByteBuffer; import java.util.ArrayList; -import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Objects; @@ -57,7 +57,7 @@ private ModelInferenceDescriptor(ByteBuffer buffer) { if (inferenceAttributesSize == 0) { this.inferenceAttributes = null; } else { - this.inferenceAttributes = new HashMap<>(); + this.inferenceAttributes = Maps.newHashMapWithExpectedSize(inferenceAttributesSize); for (int i = 0; i < inferenceAttributesSize; i++) { this.inferenceAttributes.put( ReadWriteIOUtils.readString(buffer), ReadWriteIOUtils.readString(buffer)); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/TableDeviceAttributeCommitUpdateNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/TableDeviceAttributeCommitUpdateNode.java index 14ec0fbdfc65d..188c435f2b6c8 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/TableDeviceAttributeCommitUpdateNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/TableDeviceAttributeCommitUpdateNode.java @@ -30,13 +30,13 @@ import org.apache.iotdb.db.schemaengine.schemaregion.SchemaRegionPlanVisitor; import org.apache.iotdb.db.schemaengine.schemaregion.attribute.update.DeviceAttributeCacheUpdater; +import com.google.common.collect.Sets; import org.apache.tsfile.utils.ReadWriteIOUtils; import java.io.DataOutputStream; import java.io.IOException; import java.nio.ByteBuffer; import java.util.HashMap; -import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Set; @@ -170,7 +170,7 @@ public static PlanNode deserialize(final ByteBuffer buffer) { } size = ReadWriteIOUtils.readInt(buffer); - final Set shrunkNodes = new HashSet<>(); + final Set shrunkNodes = Sets.newHashSetWithExpectedSize(size); for (int i = 0; i < size; ++i) { shrunkNodes.add( DeviceAttributeCacheUpdater.deserializeNodeLocationForAttributeUpdate(buffer)); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/logfile/visitor/SchemaRegionPlanDeserializer.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/logfile/visitor/SchemaRegionPlanDeserializer.java index 52fa864618745..326e7b1e84970 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/logfile/visitor/SchemaRegionPlanDeserializer.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/logfile/visitor/SchemaRegionPlanDeserializer.java @@ -174,31 +174,31 @@ public ISchemaRegionPlan visitCreateAlignedTimeSeries( } final int size = ReadWriteIOUtils.readInt(buffer); - final List measurements = new ArrayList<>(); + final List measurements = new ArrayList<>(size); for (int i = 0; i < size; i++) { measurements.add(ReadWriteIOUtils.readString(buffer)); } createAlignedTimeSeriesPlan.setMeasurements(measurements); - final List dataTypes = new ArrayList<>(); + final List dataTypes = new ArrayList<>(size); for (int i = 0; i < size; i++) { dataTypes.add(TSDataType.deserialize(buffer.get())); } createAlignedTimeSeriesPlan.setDataTypes(dataTypes); - final List encodings = new ArrayList<>(); + final List encodings = new ArrayList<>(size); for (int i = 0; i < size; i++) { encodings.add(TSEncoding.deserialize(buffer.get())); } createAlignedTimeSeriesPlan.setEncodings(encodings); - final List compressors = new ArrayList<>(); + final List compressors = new ArrayList<>(size); for (int i = 0; i < size; i++) { compressors.add(CompressionType.deserialize(buffer.get())); } createAlignedTimeSeriesPlan.setCompressors(compressors); - final List tagOffsets = new ArrayList<>(); + final List tagOffsets = new ArrayList<>(size); for (int i = 0; i < size; i++) { tagOffsets.add(buffer.getLong()); } @@ -206,7 +206,7 @@ public ISchemaRegionPlan visitCreateAlignedTimeSeries( // alias if (buffer.get() == 1) { - List aliasList = new ArrayList<>(); + List aliasList = new ArrayList<>(size); for (int i = 0; i < size; i++) { aliasList.add(ReadWriteIOUtils.readString(buffer)); } @@ -215,7 +215,7 @@ public ISchemaRegionPlan visitCreateAlignedTimeSeries( // tags if (buffer.get() == 1) { - List> tagsList = new ArrayList<>(); + List> tagsList = new ArrayList<>(size); for (int i = 0; i < size; i++) { tagsList.add(ReadWriteIOUtils.readMap(buffer)); } @@ -224,7 +224,7 @@ public ISchemaRegionPlan visitCreateAlignedTimeSeries( // attributes if (buffer.get() == 1) { - List> attributesList = new ArrayList<>(); + List> attributesList = new ArrayList<>(size); for (int i = 0; i < size; i++) { attributesList.add(ReadWriteIOUtils.readMap(buffer)); } @@ -287,7 +287,7 @@ public ISchemaRegionPlan visitDeleteTimeSeries( int pathNumber = buffer.getInt(); try { - List deletePathList = new ArrayList<>(); + List deletePathList = new ArrayList<>(pathNumber); for (int i = 0; i < pathNumber; i++) { deletePathList.add(new PartialPath(ReadWriteIOUtils.readString(buffer))); } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AbstractMemTable.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AbstractMemTable.java index 35a3696630e50..5095ab45fd524 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AbstractMemTable.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AbstractMemTable.java @@ -429,9 +429,9 @@ public void writeAlignedRow( } public void writeTabletNode(InsertTabletNode insertTabletNode, int start, int end) { - List schemaList = new ArrayList<>(); final int measurementSize = insertTabletNode.getMeasurements() == null ? 0 : insertTabletNode.getMeasurements().length; + List schemaList = new ArrayList<>(measurementSize); final Object[] writableColumns = new Object[measurementSize]; final BitMap[] writableBitMaps = insertTabletNode.getBitMaps() == null ? null : new BitMap[measurementSize]; @@ -475,9 +475,9 @@ public void writeAlignedTablet( int end, TSStatus[] results, List> deviceEndOffsetPairs) { - List schemaList = new ArrayList<>(); final int measurementSize = insertTabletNode.getMeasurements() == null ? 0 : insertTabletNode.getMeasurements().length; + List schemaList = new ArrayList<>(measurementSize); final Object[] writableColumns = new Object[measurementSize]; final BitMap[] writableBitMaps = insertTabletNode.getBitMaps() == null ? null : new BitMap[measurementSize]; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AlignedWritableMemChunk.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AlignedWritableMemChunk.java index a24c05899335f..1c670220f212b 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AlignedWritableMemChunk.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AlignedWritableMemChunk.java @@ -1235,7 +1235,7 @@ public static AlignedWritableMemChunk deserialize(DataInputStream stream, boolea schemaList.add(schema); } int sortedListSize = stream.readInt(); - List sortedList = new ArrayList<>(); + List sortedList = new ArrayList<>(sortedListSize); for (int i = 0; i < sortedListSize; i++) { AlignedTVList tvList = AlignedTVList.deserialize(stream); sortedList.add(tvList); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/WritableMemChunk.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/WritableMemChunk.java index 7e54296c6a8bf..bc3d91fc3f7c5 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/WritableMemChunk.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/WritableMemChunk.java @@ -470,7 +470,7 @@ public static WritableMemChunk deserialize(DataInputStream stream) throws IOExce TypeServices.StorageEngine.TV_LIST_OBJECT_WRITER_SERVICE.call( Type.fromTsDataType(memChunk.schema.getType())); int sortedListSize = stream.readInt(); - memChunk.sortedList = new ArrayList<>(); + memChunk.sortedList = new ArrayList<>(sortedListSize); for (int i = 0; i < sortedListSize; i++) { TVList tvList = TVList.deserialize(stream); memChunk.sortedList.add(tvList); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/timeindex/ArrayDeviceTimeIndex.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/timeindex/ArrayDeviceTimeIndex.java index b38bb8b8cc9e9..8af037a5924ef 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/timeindex/ArrayDeviceTimeIndex.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/timeindex/ArrayDeviceTimeIndex.java @@ -27,6 +27,7 @@ import org.apache.iotdb.db.storageengine.dataregion.tsfile.TsFileResource; import org.apache.iotdb.db.utils.CommonUtils; +import com.google.common.collect.Sets; import com.google.common.util.concurrent.RateLimiter; import org.apache.tsfile.file.metadata.IDeviceID; import org.apache.tsfile.file.metadata.IDeviceID.Deserializer; @@ -42,7 +43,6 @@ import java.io.OutputStream; import java.nio.ByteBuffer; import java.util.Arrays; -import java.util.HashSet; import java.util.Map; import java.util.Map.Entry; import java.util.Optional; @@ -200,7 +200,7 @@ public long[] getStartTimes() { public static Set getDevices(InputStream inputStream) throws IOException { int deviceNum = ReadWriteIOUtils.readInt(inputStream); ReadWriteIOUtils.skip(inputStream, 2L * deviceNum * ReadWriteIOUtils.LONG_LEN); - Set devices = new HashSet<>(); + Set devices = Sets.newHashSetWithExpectedSize(deviceNum); for (int i = 0; i < deviceNum; i++) { IDeviceID deviceID = Deserializer.DEFAULT_DESERIALIZER.deserializeFrom(inputStream); ReadWriteIOUtils.skip(inputStream, ReadWriteIOUtils.INT_LEN); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/timeindex/PlainDeviceTimeIndex.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/timeindex/PlainDeviceTimeIndex.java index 785407ca40fff..275b84e11c0d4 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/timeindex/PlainDeviceTimeIndex.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/timeindex/PlainDeviceTimeIndex.java @@ -23,13 +23,13 @@ import org.apache.iotdb.commons.path.PartialPath; import org.apache.iotdb.db.queryengine.plan.analyze.cache.schema.DataNodeDevicePathCache; +import com.google.common.collect.Sets; import org.apache.tsfile.file.metadata.IDeviceID; import org.apache.tsfile.utils.ReadWriteIOUtils; import java.io.IOException; import java.io.InputStream; import java.nio.ByteBuffer; -import java.util.HashSet; import java.util.Set; public class PlainDeviceTimeIndex extends ArrayDeviceTimeIndex implements ITimeIndex { @@ -97,7 +97,7 @@ public PlainDeviceTimeIndex deserialize(ByteBuffer buffer) { public static Set getDevices(InputStream inputStream) throws IOException { int deviceNum = ReadWriteIOUtils.readInt(inputStream); ReadWriteIOUtils.skip(inputStream, 2L * deviceNum * ReadWriteIOUtils.LONG_LEN); - Set devices = new HashSet<>(); + Set devices = Sets.newHashSetWithExpectedSize(deviceNum); for (int i = 0; i < deviceNum; i++) { String path = DataNodeDevicePathCache.getInstance() diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/AlignedChunkData.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/AlignedChunkData.java index d8a8e6adce933..2e4e51301c447 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/AlignedChunkData.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/AlignedChunkData.java @@ -399,7 +399,7 @@ public static AlignedChunkData deserialize(final InputStream stream) final long dataSize = ReadWriteIOUtils.readLong(stream); final boolean needDecodeChunk = ReadWriteIOUtils.readBool(stream); final int chunkHeaderListSize = ReadWriteIOUtils.readInt(stream); - final List chunkHeaderList = new ArrayList<>(); + final List chunkHeaderList = new ArrayList<>(chunkHeaderListSize); for (int i = 0; i < chunkHeaderListSize; i++) { final byte chunkType = ReadWriteIOUtils.readByte(stream); ChunkHeader chunkHeader = ChunkHeader.deserializeFrom(stream, chunkType); @@ -407,7 +407,7 @@ public static AlignedChunkData deserialize(final InputStream stream) chunkHeader.setMeasurementID(MEASUREMENT_ID_CACHE.get(measurementID, m -> m)); chunkHeaderList.add(chunkHeader); } - final List pageNumbers = new ArrayList<>(); + final List pageNumbers = new ArrayList<>(needDecodeChunk ? chunkHeaderListSize : 0); if (needDecodeChunk) { for (int i = 0; i < chunkHeaderListSize; i++) { pageNumbers.add(ReadWriteIOUtils.readInt(stream)); diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/Role.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/Role.java index 4c1a4baa78fe0..01f21a06e573d 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/Role.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/Role.java @@ -128,7 +128,7 @@ private DatabasePrivilege getObjectPrivilege(String objectName) { } public List getTreePrivilegeInfo() { - List privilegeList = new ArrayList<>(); + List privilegeList = new ArrayList<>(pathPrivilegeList.size()); for (PathPrivilege pathPrivilege : pathPrivilegeList) { TPathPrivilege pathPriv = new TPathPrivilege(); pathPriv.setPath(pathPrivilege.getPath().getFullPath()); diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/role/LocalFileRoleAccessor.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/role/LocalFileRoleAccessor.java index c6b20c2c1379b..abc5ea5dabf87 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/role/LocalFileRoleAccessor.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/role/LocalFileRoleAccessor.java @@ -160,7 +160,7 @@ protected void loadPrivileges(DataInputStream dataInputStream, Role role) throws IOException, IllegalPathException { role.setSysPrivilegesWithMask(dataInputStream.readInt()); int num = ReadWriteIOUtils.readInt(dataInputStream); - List pathPrivilegeList = new ArrayList<>(); + List pathPrivilegeList = new ArrayList<>(num); for (int i = 0; i < num; i++) { pathPrivilegeList.add( IOUtils.readPathPrivilege(dataInputStream, STRING_ENCODING, strBufferLocal)); diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/consensus/index/impl/StateProgressIndex.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/consensus/index/impl/StateProgressIndex.java index ed2b4d9114525..26e18a3f7dc3c 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/consensus/index/impl/StateProgressIndex.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/consensus/index/impl/StateProgressIndex.java @@ -23,6 +23,7 @@ import org.apache.iotdb.commons.consensus.index.ProgressIndexType; import com.google.common.collect.ImmutableMap; +import com.google.common.collect.Maps; import org.apache.tsfile.utils.Binary; import org.apache.tsfile.utils.RamUsageEstimator; import org.apache.tsfile.utils.ReadWriteIOUtils; @@ -213,8 +214,8 @@ public TotalOrderSumTuple getTotalOrderSumTuple() { public static StateProgressIndex deserializeFrom(ByteBuffer byteBuffer) { final long version = ReadWriteIOUtils.readLong(byteBuffer); - final Map state = new HashMap<>(); final int size = ReadWriteIOUtils.readInt(byteBuffer); + final Map state = Maps.newHashMapWithExpectedSize(size); for (int i = 0; i < size; ++i) { final String key = ReadWriteIOUtils.readString(byteBuffer); final Binary value = ReadWriteIOUtils.readBinary(byteBuffer); @@ -229,8 +230,8 @@ public static StateProgressIndex deserializeFrom(ByteBuffer byteBuffer) { public static StateProgressIndex deserializeFrom(InputStream stream) throws IOException { final long version = ReadWriteIOUtils.readLong(stream); - final Map state = new HashMap<>(); final int size = ReadWriteIOUtils.readInt(stream); + final Map state = Maps.newHashMapWithExpectedSize(size); for (int i = 0; i < size; ++i) { final String key = ReadWriteIOUtils.readString(stream); final Binary value = ReadWriteIOUtils.readBinary(stream); diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/disk/strategy/RandomOnDiskUsableSpaceStrategy.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/disk/strategy/RandomOnDiskUsableSpaceStrategy.java index 28264f142a13e..ec46043a54a9e 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/disk/strategy/RandomOnDiskUsableSpaceStrategy.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/disk/strategy/RandomOnDiskUsableSpaceStrategy.java @@ -55,7 +55,7 @@ public int nextFolderIndex() throws DiskSpaceInsufficientException { /** get space list of all folders. */ public List getFolderUsableSpaceList() { - List spaceList = new ArrayList<>(); + List spaceList = new ArrayList<>(folders.size()); for (int i = 0; i < folders.size(); i++) { String folder = folders.get(i); if (isUnavailableFolder(folder)) { diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelHyperparameter.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelHyperparameter.java index 5f06f2dcabd35..77b8b0b7aaf7b 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelHyperparameter.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelHyperparameter.java @@ -56,7 +56,7 @@ public String toString() { } public List toStringList() { - List resultList = new ArrayList<>(); + List resultList = new ArrayList<>(keyValueMap.size()); for (Map.Entry keyValuePair : keyValueMap.entrySet()) { resultList.add(keyValuePair.getKey() + "=" + keyValuePair.getValue()); } diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/path/AlignedPath.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/path/AlignedPath.java index 43502db0be84c..07a3c7721e850 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/path/AlignedPath.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/path/AlignedPath.java @@ -377,14 +377,14 @@ public static AlignedPath deserialize(ByteBuffer byteBuffer) { PartialPath partialPath = PartialPath.deserialize(byteBuffer); AlignedPath alignedPath = new AlignedPath(); int measurementSize = ReadWriteIOUtils.readInt(byteBuffer); - List measurements = new ArrayList<>(); + List measurements = new ArrayList<>(measurementSize); for (int i = 0; i < measurementSize; i++) { measurements.add(ReadWriteIOUtils.readString(byteBuffer)); } int measurementSchemaSize = ReadWriteIOUtils.readInt(byteBuffer); List measurementSchemas = null; if (measurementSchemaSize != -1) { - measurementSchemas = new ArrayList<>(); + measurementSchemas = new ArrayList<>(measurementSchemaSize); for (int i = 0; i < measurementSchemaSize; i++) { byte type = ReadWriteIOUtils.readByte(byteBuffer); if (type == 0) { diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/path/PartialPath.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/path/PartialPath.java index 9d71b0121bcc9..9041402be4677 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/path/PartialPath.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/path/PartialPath.java @@ -973,7 +973,7 @@ public Path toTSFilePath() { } public static List toStringList(List pathList) { - List ret = new ArrayList<>(); + List ret = new ArrayList<>(pathList.size()); for (PartialPath path : pathList) { ret.add(path.getFullPath()); } diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/path/PathPatternNode.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/path/PathPatternNode.java index 56240432f69a2..03b5f02e04be9 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/path/PathPatternNode.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/path/PathPatternNode.java @@ -19,6 +19,7 @@ package org.apache.iotdb.commons.path; +import com.google.common.collect.Sets; import org.apache.tsfile.utils.Accountable; import org.apache.tsfile.utils.PublicBAOS; import org.apache.tsfile.utils.RamUsageEstimator; @@ -30,7 +31,6 @@ import java.util.ArrayList; import java.util.Collection; import java.util.HashMap; -import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Objects; @@ -272,7 +272,7 @@ public static > PathPatternNode final int typeOrValueSize = ReadWriteIOUtils.readInt(buffer); if (typeOrValueSize >= 0) { // measurement node in PatternTreeMap - final Set valueSet = new HashSet<>(); + final Set valueSet = Sets.newHashSetWithExpectedSize(typeOrValueSize); for (int i = 0; i < typeOrValueSize; i++) { valueSet.add(serializer.read(buffer)); } diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/iotconsensusv2/request/IoTConsensusV2TransferFileSealWithModReq.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/iotconsensusv2/request/IoTConsensusV2TransferFileSealWithModReq.java index 188e3fbe4fc7f..67ff74b79c264 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/iotconsensusv2/request/IoTConsensusV2TransferFileSealWithModReq.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/iotconsensusv2/request/IoTConsensusV2TransferFileSealWithModReq.java @@ -24,6 +24,7 @@ import org.apache.iotdb.consensus.iotconsensusv2.thrift.TCommitId; import org.apache.iotdb.consensus.iotconsensusv2.thrift.TIoTConsensusV2TransferReq; +import com.google.common.collect.Maps; import org.apache.tsfile.utils.PublicBAOS; import org.apache.tsfile.utils.ReadWriteIOUtils; @@ -31,7 +32,6 @@ import java.io.IOException; import java.nio.ByteBuffer; import java.util.ArrayList; -import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Objects; @@ -117,26 +117,26 @@ protected IoTConsensusV2TransferFileSealWithModReq convertToTIoTConsensusV2Trans public IoTConsensusV2TransferFileSealWithModReq translateFromTIoTConsensusV2TransferReq( TIoTConsensusV2TransferReq req) { - fileNames = new ArrayList<>(); int size = ReadWriteIOUtils.readInt(req.body); + fileNames = new ArrayList<>(size); for (int i = 0; i < size; ++i) { fileNames.add(ReadWriteIOUtils.readString(req.body)); } - fileLengths = new ArrayList<>(); size = ReadWriteIOUtils.readInt(req.body); + fileLengths = new ArrayList<>(size); for (int i = 0; i < size; ++i) { fileLengths.add(ReadWriteIOUtils.readLong(req.body)); } - pointCounts = new ArrayList<>(); size = ReadWriteIOUtils.readInt(req.body); + pointCounts = new ArrayList<>(size); for (int i = 0; i < size; ++i) { pointCounts.add(ReadWriteIOUtils.readLong(req.body)); } - parameters = new HashMap<>(); size = ReadWriteIOUtils.readInt(req.body); + parameters = Maps.newHashMapWithExpectedSize(size); for (int i = 0; i < size; ++i) { final String key = ReadWriteIOUtils.readString(req.body); final String value = ReadWriteIOUtils.readString(req.body); diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/thrift/request/PipeTransferFileSealReqV2.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/thrift/request/PipeTransferFileSealReqV2.java index 227d5871d8b5c..c6d0c580cea77 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/thrift/request/PipeTransferFileSealReqV2.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/thrift/request/PipeTransferFileSealReqV2.java @@ -21,6 +21,7 @@ import org.apache.iotdb.service.rpc.thrift.TPipeTransferReq; +import com.google.common.collect.Maps; import org.apache.tsfile.utils.PublicBAOS; import org.apache.tsfile.utils.ReadWriteIOUtils; @@ -28,7 +29,6 @@ import java.io.IOException; import java.nio.ByteBuffer; import java.util.ArrayList; -import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Objects; @@ -100,20 +100,20 @@ protected PipeTransferFileSealReqV2 convertToTPipeTransferReq( } public PipeTransferFileSealReqV2 translateFromTPipeTransferReq(final TPipeTransferReq req) { - fileNames = new ArrayList<>(); int size = ReadWriteIOUtils.readInt(req.body); + fileNames = new ArrayList<>(size); for (int i = 0; i < size; ++i) { fileNames.add(ReadWriteIOUtils.readString(req.body)); } - fileLengths = new ArrayList<>(); size = ReadWriteIOUtils.readInt(req.body); + fileLengths = new ArrayList<>(size); for (int i = 0; i < size; ++i) { fileLengths.add(ReadWriteIOUtils.readLong(req.body)); } - parameters = new HashMap<>(); size = ReadWriteIOUtils.readInt(req.body); + parameters = Maps.newHashMapWithExpectedSize(size); for (int i = 0; i < size; ++i) { final String key = ReadWriteIOUtils.readString(req.body); final String value = ReadWriteIOUtils.readString(req.body); diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/thrift/request/PipeTransferHandshakeV2Req.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/thrift/request/PipeTransferHandshakeV2Req.java index 472679494729b..8152ffe43e7d4 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/thrift/request/PipeTransferHandshakeV2Req.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/thrift/request/PipeTransferHandshakeV2Req.java @@ -21,13 +21,13 @@ import org.apache.iotdb.service.rpc.thrift.TPipeTransferReq; +import com.google.common.collect.Maps; import org.apache.tsfile.utils.PublicBAOS; import org.apache.tsfile.utils.ReadWriteIOUtils; import java.io.DataOutputStream; import java.io.IOException; import java.nio.ByteBuffer; -import java.util.HashMap; import java.util.Map; import java.util.Objects; @@ -63,9 +63,9 @@ protected final PipeTransferHandshakeV2Req convertToTPipeTransferReq(Map params = new HashMap<>(); final ByteBuffer bodyBuffer = transferReq.body.duplicate(); final int size = ReadWriteIOUtils.readInt(bodyBuffer); + Map params = Maps.newHashMapWithExpectedSize(size); for (int i = 0; i < size; ++i) { final String key = ReadWriteIOUtils.readString(bodyBuffer); final String value = ReadWriteIOUtils.readString(bodyBuffer); diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/relational/planner/rowpattern/LogicalIndexPointer.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/relational/planner/rowpattern/LogicalIndexPointer.java index ac1d0d7195086..5b0e85cf3cf1c 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/relational/planner/rowpattern/LogicalIndexPointer.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/relational/planner/rowpattern/LogicalIndexPointer.java @@ -21,12 +21,12 @@ import org.apache.iotdb.commons.i18n.QueryMessages; +import com.google.common.collect.Sets; import org.apache.tsfile.utils.ReadWriteIOUtils; import java.io.DataOutputStream; import java.io.IOException; import java.nio.ByteBuffer; -import java.util.HashSet; import java.util.Objects; import java.util.Set; @@ -144,7 +144,7 @@ public static void serialize(LogicalIndexPointer pointer, DataOutputStream strea public static LogicalIndexPointer deserialize(ByteBuffer byteBuffer) { int labelCount = ReadWriteIOUtils.readInt(byteBuffer); - Set labels = new HashSet<>(); + Set labels = Sets.newHashSetWithExpectedSize(labelCount); for (int i = 0; i < labelCount; i++) { labels.add(IrLabel.deserialize(byteBuffer)); } diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/relational/sql/ast/InListExpression.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/relational/sql/ast/InListExpression.java index 24bf8976caad2..336dee747a433 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/relational/sql/ast/InListExpression.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/relational/sql/ast/InListExpression.java @@ -59,7 +59,7 @@ public InListExpression(NodeLocation location, List values) { public InListExpression(ByteBuffer byteBuffer) { super(null); int size = ReadWriteIOUtils.readInt(byteBuffer); - this.values = new ArrayList<>(); + this.values = new ArrayList<>(size); for (int i = 0; i < size; i++) { values.add(Expression.deserialize(byteBuffer)); } diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/multichildren/AbstractMultiChildrenFilter.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/multichildren/AbstractMultiChildrenFilter.java index 888f9675caa31..c3da760aec90b 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/multichildren/AbstractMultiChildrenFilter.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/multichildren/AbstractMultiChildrenFilter.java @@ -43,7 +43,7 @@ protected AbstractMultiChildrenFilter(final List children) { protected AbstractMultiChildrenFilter(final ByteBuffer byteBuffer) { final int num = ReadWriteIOUtils.readInt(byteBuffer); - children = new ArrayList<>(); + children = new ArrayList<>(num); for (int i = 0; i < num; ++i) { this.children.add(SchemaFilter.deserialize(byteBuffer)); } diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/values/InFilter.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/values/InFilter.java index 5df2993825d1c..20198bc36e9c5 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/values/InFilter.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/values/InFilter.java @@ -24,13 +24,13 @@ import org.apache.iotdb.commons.schema.filter.SchemaFilterVisitor; import org.apache.iotdb.commons.schema.filter.impl.multichildren.OrFilter; +import com.google.common.collect.Sets; import org.apache.tsfile.utils.RamUsageEstimator; import org.apache.tsfile.utils.ReadWriteIOUtils; import java.io.DataOutputStream; import java.io.IOException; import java.nio.ByteBuffer; -import java.util.HashSet; import java.util.Objects; import java.util.Set; @@ -50,7 +50,7 @@ public InFilter(Set values) { public InFilter(final ByteBuffer byteBuffer) { final int length = ReadWriteIOUtils.readInt(byteBuffer); - this.values = new HashSet<>(); + this.values = Sets.newHashSetWithExpectedSize(length); for (int i = 0; i < length; ++i) { values.add(ReadWriteIOUtils.readString(byteBuffer)); } diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/view/viewExpression/multi/FunctionViewExpression.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/view/viewExpression/multi/FunctionViewExpression.java index 1f73f59ae00f0..fcd4c1c6f97b9 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/view/viewExpression/multi/FunctionViewExpression.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/view/viewExpression/multi/FunctionViewExpression.java @@ -81,7 +81,7 @@ public FunctionViewExpression(ByteBuffer byteBuffer) { functionName = ReadWriteIOUtils.readString(byteBuffer); functionAttributesKeyValueList = ReadWriteIOUtils.readStringList(byteBuffer); int expressionSize = ReadWriteIOUtils.readInt(byteBuffer); - expressions = new ArrayList<>(); + expressions = new ArrayList<>(expressionSize); for (int i = 0; i < expressionSize; i++) { expressions.add(ViewExpression.deserialize(byteBuffer)); } @@ -92,7 +92,7 @@ public FunctionViewExpression(InputStream inputStream) { functionName = ReadWriteIOUtils.readString(inputStream); functionAttributesKeyValueList = ReadWriteIOUtils.readStringList(inputStream); int expressionSize = ReadWriteIOUtils.readInt(inputStream); - expressions = new ArrayList<>(); + expressions = new ArrayList<>(expressionSize); for (int i = 0; i < expressionSize; i++) { expressions.add(ViewExpression.deserialize(inputStream)); } diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/AuthUtils.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/AuthUtils.java index 1e01dbeaee7c5..ccd254e1d2020 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/AuthUtils.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/AuthUtils.java @@ -545,7 +545,7 @@ public static ByteBuffer serializePartialPathList(List pa public static List deserializePartialPathList(ByteBuffer buffer) { int size = buffer.getInt(); - List paths = new ArrayList<>(); + List paths = new ArrayList<>(size); for (int i = 0; i < size; i++) { paths.add((PartialPath) PathDeserializeUtil.deserialize(buffer)); } diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/BasicStructureSerDeUtil.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/BasicStructureSerDeUtil.java index e797779b832d2..79dbc0011054c 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/BasicStructureSerDeUtil.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/BasicStructureSerDeUtil.java @@ -21,11 +21,12 @@ import org.apache.iotdb.commons.i18n.UtilMessages; +import com.google.common.collect.Maps; + import java.io.DataOutputStream; import java.io.IOException; import java.nio.ByteBuffer; import java.util.ArrayList; -import java.util.HashMap; import java.util.List; import java.util.Map; @@ -54,7 +55,7 @@ public static List readStringList(ByteBuffer buffer) { if (size < 0) { return null; } - List stringList = new ArrayList<>(); + List stringList = new ArrayList<>(size); for (int i = 0; i < size; i++) { stringList.add(readString(buffer)); } @@ -217,7 +218,7 @@ public static Map readMap(ByteBuffer buffer) { if (length == -1) { return null; } - Map map = new HashMap<>(length); + Map map = Maps.newHashMapWithExpectedSize(length); for (int i = 0; i < length; i++) { // key String key = readString(buffer); @@ -263,13 +264,13 @@ public static Map> readStringMapLists(ByteBuffer buffer) { if (length == -1) { return null; } - Map> map = new HashMap<>(length); + Map> map = Maps.newHashMapWithExpectedSize(length); for (int i = 0; i < length; i++) { // key String key = readString(buffer); // value int listSize = readInt(buffer); - List valueList = new ArrayList<>(); + List valueList = new ArrayList<>(listSize); for (int j = 0; j < listSize; j++) { String value = readString(buffer); valueList.add(value); @@ -305,13 +306,13 @@ public static Map> readIntMapLists(ByteBuffer buffer) { if (length == -1) { return null; } - Map> map = new HashMap<>(length); + Map> map = Maps.newHashMapWithExpectedSize(length); for (int i = 0; i < length; i++) { // key int key = readInt(buffer); // value int listSize = readInt(buffer); - List valueList = new ArrayList<>(); + List valueList = new ArrayList<>(listSize); for (int j = 0; j < listSize; j++) { int value = readInt(buffer); valueList.add(value); diff --git a/library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFSegment.java b/library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFSegment.java index aead60e7942e9..aa0997cd7c235 100644 --- a/library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFSegment.java +++ b/library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFSegment.java @@ -104,7 +104,7 @@ public void terminate(PointCollector collector) throws Exception { } else if (method.equals("swab")) { // haven't tested yet seg = Segment.swabAlg(v, maxError, windowSize); } - ArrayList res = new ArrayList<>(); + ArrayList res = new ArrayList<>(seg.size()); for (double[] doubles : seg) { res.add(Segment.approximatedSegment(doubles)); } diff --git a/library-udf/src/main/java/org/apache/iotdb/library/match/PatternExecutor.java b/library-udf/src/main/java/org/apache/iotdb/library/match/PatternExecutor.java index 4e5e73206709e..565f24156df1b 100644 --- a/library-udf/src/main/java/org/apache/iotdb/library/match/PatternExecutor.java +++ b/library-udf/src/main/java/org/apache/iotdb/library/match/PatternExecutor.java @@ -112,7 +112,7 @@ public void setPoints(List points) { } public List scalePoint(List times, List values) { - List points = new ArrayList<>(); + List points = new ArrayList<>(times.size()); TimeScale xScale = new TimeScale(times.get(0), times.get(times.size() - 1), 0, 1000); double minY = values.stream().min(Double::compare).orElseGet(() -> 0.0); double maxY = values.stream().max(Double::compare).orElseGet(() -> 0.0); @@ -129,7 +129,7 @@ public List scalePoint(List times, List values) { } public List scalePoint(List sourcePoints) { - List points = new ArrayList<>(); + List points = new ArrayList<>(sourcePoints.size()); TimeScale xScale = new TimeScale( (long) sourcePoints.get(0).getX(), @@ -199,7 +199,7 @@ private List extractTangents(List points) { if (points.size() < 2) { return new ArrayList<>(); } - List tangents = new ArrayList<>(); + List tangents = new ArrayList<>(points.size()); tangents.add(tangent(points.get(0), points.get(1))); for (int i = 1; i < points.size(); i++) { tangents.add(tangent(points.get(i - 1), points.get(i)));