change method name

richardstartin · richardstartin · commit b8aa11188539 · 2021-12-21T05:57:11.000Z
diff --git a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/io/writer/impl/FixedByteChunkSVForwardIndexWriter.java b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/io/writer/impl/FixedByteChunkSVForwardIndexWriter.java
@@ -71,8 +71,8 @@ public class FixedByteChunkSVForwardIndexWriter extends BaseChunkSVForwardIndexW
   public FixedByteChunkSVForwardIndexWriter(File file, ChunkCompressionType compressionType, int totalDocs,
       int numDocsPerChunk, int sizeOfEntry, int writerVersion)
       throws IOException {
-    super(file, compressionType, totalDocs, normalizeChunkSize(writerVersion, numDocsPerChunk),
-        (sizeOfEntry * normalizeChunkSize(writerVersion, numDocsPerChunk)), sizeOfEntry,
+    super(file, compressionType, totalDocs, normalizeDocsPerChunk(writerVersion, numDocsPerChunk),
+        (sizeOfEntry * normalizeDocsPerChunk(writerVersion, numDocsPerChunk)), sizeOfEntry,
         writerVersion, true);
     _chunkDataOffset = 0;
   }
@@ -114,7 +114,7 @@ private void flushChunkIfNeeded() {
     }
   }
 
-  private static int normalizeChunkSize(int version, int numDocsPerChunk) {
+  private static int normalizeDocsPerChunk(int version, int numDocsPerChunk) {
     // V4 uses power of 2 chunk sizes for random access efficiency
     if (version >= 4 && (numDocsPerChunk & (numDocsPerChunk - 1)) != 0) {
       return 1 << (32 - Integer.numberOfLeadingZeros(numDocsPerChunk - 1));

Original file line number	Diff line number	Diff line change
`@@ -71,8 +71,8 @@ public class FixedByteChunkSVForwardIndexWriter extends BaseChunkSVForwardIndexW`
`71`	`71`	`public FixedByteChunkSVForwardIndexWriter(File file, ChunkCompressionType compressionType, int totalDocs,`
`72`	`72`	`int numDocsPerChunk, int sizeOfEntry, int writerVersion)`
`73`	`73`	`throws IOException {`
`74`		`- super(file, compressionType, totalDocs, normalizeChunkSize(writerVersion, numDocsPerChunk),`
`75`		`- (sizeOfEntry * normalizeChunkSize(writerVersion, numDocsPerChunk)), sizeOfEntry,`
	`74`	`+ super(file, compressionType, totalDocs, normalizeDocsPerChunk(writerVersion, numDocsPerChunk),`
	`75`	`+ (sizeOfEntry * normalizeDocsPerChunk(writerVersion, numDocsPerChunk)), sizeOfEntry,`
`76`	`76`	`writerVersion, true);`
`77`	`77`	`_chunkDataOffset = 0;`
`78`	`78`	`}`
`@@ -114,7 +114,7 @@ private void flushChunkIfNeeded() {`
`114`	`114`	`}`
`115`	`115`	`}`
`116`	`116`
`117`		`- private static int normalizeChunkSize(int version, int numDocsPerChunk) {`
	`117`	`+ private static int normalizeDocsPerChunk(int version, int numDocsPerChunk) {`
`118`	`118`	`// V4 uses power of 2 chunk sizes for random access efficiency`
`119`	`119`	`if (version >= 4 && (numDocsPerChunk & (numDocsPerChunk - 1)) != 0) {`
`120`	`120`	`return 1 << (32 - Integer.numberOfLeadingZeros(numDocsPerChunk - 1));`