We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 60803e0 commit 9f244e3Copy full SHA for 9f244e3
src/main/scala/org/apache/spark/sql/hbase/HBasePartitioner.scala
@@ -39,11 +39,11 @@ class HBasePartitioner (val splitKeys: Array[HBaseRawType]) extends Partitioner
39
// we will miss the last region's date when bulk load
40
lazy private val realSplitKeys = if (splitKeys.isEmpty) splitKeys else splitKeys.tail
41
42
- def numPartitions = if (len == 0) 1 else len
+ override def numPartitions = if (len == 0) 1 else len
43
44
@transient private lazy val binarySearch: ((Array[t], t) => Int) = CollectionsUtils.makeBinarySearch[t]
45
46
- def getPartition(key: Any): Int = {
+ override def getPartition(key: Any): Int = {
47
val k = key.asInstanceOf[t]
48
var partition = 0
49
if (len <= 128 && len > 0) {
0 commit comments