Skip to content

Commit b347f4b

Browse files
authored
KAFKA-20297 move ImplicitLinkedHashCollection, ImplicitLinkedHashMultiCollection, and ByteUtils from utils to internals (#21856)
Summary: Move ImplicitLinkedHash*, ByteUtils from common.utils to common.utils.internals. Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
1 parent 7ff975d commit b347f4b

75 files changed

Lines changed: 181 additions & 205 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

clients/src/main/java/org/apache/kafka/common/compress/Lz4BlockOutputStream.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
package org.apache.kafka.common.compress;
1818

1919
import org.apache.kafka.common.record.internal.CompressionType;
20-
import org.apache.kafka.common.utils.ByteUtils;
20+
import org.apache.kafka.common.utils.internals.ByteUtils;
2121

2222
import net.jpountz.lz4.LZ4Compressor;
2323
import net.jpountz.lz4.LZ4Factory;

clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,9 @@
1919
import org.apache.kafka.common.errors.SslAuthenticationException;
2020
import org.apache.kafka.common.security.auth.KafkaPrincipal;
2121
import org.apache.kafka.common.utils.ByteBufferUnmapper;
22-
import org.apache.kafka.common.utils.ByteUtils;
2322
import org.apache.kafka.common.utils.LogContext;
2423
import org.apache.kafka.common.utils.Utils;
24+
import org.apache.kafka.common.utils.internals.ByteUtils;
2525

2626
import org.slf4j.Logger;
2727

clients/src/main/java/org/apache/kafka/common/protocol/ByteBufferAccessor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717

1818
package org.apache.kafka.common.protocol;
1919

20-
import org.apache.kafka.common.utils.ByteUtils;
20+
import org.apache.kafka.common.utils.internals.ByteUtils;
2121

2222
import java.nio.ByteBuffer;
2323

clients/src/main/java/org/apache/kafka/common/protocol/DataOutputStreamWritable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,8 @@
1717

1818
package org.apache.kafka.common.protocol;
1919

20-
import org.apache.kafka.common.utils.ByteUtils;
2120
import org.apache.kafka.common.utils.Utils;
21+
import org.apache.kafka.common.utils.internals.ByteUtils;
2222

2323
import java.io.Closeable;
2424
import java.io.DataOutputStream;

clients/src/main/java/org/apache/kafka/common/protocol/SendBuilder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
import org.apache.kafka.common.record.internal.UnalignedMemoryRecords;
2525
import org.apache.kafka.common.requests.RequestHeader;
2626
import org.apache.kafka.common.requests.ResponseHeader;
27-
import org.apache.kafka.common.utils.ByteUtils;
27+
import org.apache.kafka.common.utils.internals.ByteUtils;
2828

2929
import java.nio.ByteBuffer;
3030
import java.util.ArrayDeque;

clients/src/main/java/org/apache/kafka/common/protocol/types/CompactArrayOf.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
package org.apache.kafka.common.protocol.types;
1818

1919
import org.apache.kafka.common.protocol.types.Type.DocumentedType;
20-
import org.apache.kafka.common.utils.ByteUtils;
20+
import org.apache.kafka.common.utils.internals.ByteUtils;
2121

2222
import java.nio.ByteBuffer;
2323
import java.util.Optional;

clients/src/main/java/org/apache/kafka/common/protocol/types/TaggedFields.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
package org.apache.kafka.common.protocol.types;
1818

1919
import org.apache.kafka.common.protocol.types.Type.DocumentedType;
20-
import org.apache.kafka.common.utils.ByteUtils;
20+
import org.apache.kafka.common.utils.internals.ByteUtils;
2121

2222
import java.nio.ByteBuffer;
2323
import java.util.Collections;

clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,8 @@
1919
import org.apache.kafka.common.Uuid;
2020
import org.apache.kafka.common.record.internal.BaseRecords;
2121
import org.apache.kafka.common.record.internal.MemoryRecords;
22-
import org.apache.kafka.common.utils.ByteUtils;
2322
import org.apache.kafka.common.utils.Utils;
23+
import org.apache.kafka.common.utils.internals.ByteUtils;
2424

2525
import java.nio.ByteBuffer;
2626
import java.util.Optional;

clients/src/main/java/org/apache/kafka/common/record/internal/AbstractLegacyRecordBatch.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,9 +25,9 @@
2525
import org.apache.kafka.common.utils.AbstractIterator;
2626
import org.apache.kafka.common.utils.BufferSupplier;
2727
import org.apache.kafka.common.utils.ByteBufferOutputStream;
28-
import org.apache.kafka.common.utils.ByteUtils;
2928
import org.apache.kafka.common.utils.CloseableIterator;
3029
import org.apache.kafka.common.utils.Utils;
30+
import org.apache.kafka.common.utils.internals.ByteUtils;
3131

3232
import java.io.DataOutputStream;
3333
import java.io.IOException;

clients/src/main/java/org/apache/kafka/common/record/internal/DefaultRecord.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,8 @@
2020
import org.apache.kafka.common.header.Header;
2121
import org.apache.kafka.common.header.internals.RecordHeader;
2222
import org.apache.kafka.common.record.TimestampType;
23-
import org.apache.kafka.common.utils.ByteUtils;
2423
import org.apache.kafka.common.utils.Utils;
24+
import org.apache.kafka.common.utils.internals.ByteUtils;
2525

2626
import java.io.DataOutputStream;
2727
import java.io.IOException;

0 commit comments

Comments
 (0)