Skip to content

Commit 88a042e

Browse files
committed
Fixed method visibility and removed dead code
1 parent 001f2e5 commit 88a042e

File tree

3 files changed

+1
-18
lines changed

3 files changed

+1
-18
lines changed

sql/core/src/main/scala/org/apache/spark/sql/columnar/NullableColumnBuilder.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ private[sql] trait NullableColumnBuilder extends ColumnBuilder {
7979
buffer
8080
}
8181

82-
def buildNonNulls(): ByteBuffer = {
82+
protected def buildNonNulls(): ByteBuffer = {
8383
nulls.limit(nulls.position()).rewind()
8484
super.build()
8585
}

sql/core/src/main/scala/org/apache/spark/sql/columnar/compression/CompressionScheme.scala

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -67,22 +67,6 @@ private[sql] object CompressionScheme {
6767
s"Unrecognized compression scheme type ID: $typeId"))
6868
}
6969

70-
def copyColumnHeader(from: ByteBuffer, to: ByteBuffer) {
71-
// Writes column type ID
72-
to.putInt(from.getInt())
73-
74-
// Writes null count
75-
val nullCount = from.getInt()
76-
to.putInt(nullCount)
77-
78-
// Writes null positions
79-
var i = 0
80-
while (i < nullCount) {
81-
to.putInt(from.getInt())
82-
i += 1
83-
}
84-
}
85-
8670
def columnHeaderSize(columnBuffer: ByteBuffer): Int = {
8771
val header = columnBuffer.duplicate().order(ByteOrder.nativeOrder)
8872
val nullCount = header.getInt(4)

sql/core/src/test/scala/org/apache/spark/sql/columnar/compression/TestCompressibleColumnBuilder.scala

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,4 +42,3 @@ object TestCompressibleColumnBuilder {
4242
builder
4343
}
4444
}
45-

0 commit comments

Comments
 (0)