Skip to content

Commit

Permalink
Fixed deprecated things which cause build error with sbt.
Browse files Browse the repository at this point in the history
  • Loading branch information
sarutak committed Sep 14, 2020
1 parent 1e85eec commit d1f9c3c
Show file tree
Hide file tree
Showing 6 changed files with 10 additions and 10 deletions.
6 changes: 3 additions & 3 deletions mllib/src/main/scala/org/apache/spark/mllib/feature/PCA.scala
Original file line number Diff line number Diff line change
Expand Up @@ -124,9 +124,9 @@ private[feature] object PCAUtil {
// 6e541be066d547a097f5089165cd7c38c3ca276d/math/src/main/scala/breeze/linalg/
// functions/svd.scala#L87
def memoryCost(k: Int, numFeatures: Int): Long = {
3L * math.min(k, numFeatures) * math.min(k, numFeatures)
+ math.max(math.max(k, numFeatures), 4L * math.min(k, numFeatures)
* math.min(k, numFeatures) + 4L * math.min(k, numFeatures))
3L * math.min(k, numFeatures) * math.min(k, numFeatures) +
math.max(math.max(k, numFeatures), 4L * math.min(k, numFeatures) *
math.min(k, numFeatures) + 4L * math.min(k, numFeatures))
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -984,7 +984,7 @@ class SparseVector @Since("1.0.0") (

override def hasNext: Boolean = i < localSize

override def next: (Int, Double) = {
override def next(): (Int, Double) = {
val v = if (i == k) {
j += 1
k = if (j < localNumActives) localIndices(j) else -1
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ case class ExecutedCommandExec(cmd: RunnableCommand) extends LeafExecNode {

override def executeCollect(): Array[InternalRow] = sideEffectResult.toArray

override def executeToIterator: Iterator[InternalRow] = sideEffectResult.toIterator
override def executeToIterator(): Iterator[InternalRow] = sideEffectResult.toIterator

override def executeTake(limit: Int): Array[InternalRow] = sideEffectResult.take(limit).toArray

Expand Down Expand Up @@ -119,7 +119,7 @@ case class DataWritingCommandExec(cmd: DataWritingCommand, child: SparkPlan)

override def executeCollect(): Array[InternalRow] = sideEffectResult.toArray

override def executeToIterator: Iterator[InternalRow] = sideEffectResult.toIterator
override def executeToIterator(): Iterator[InternalRow] = sideEffectResult.toIterator

override def executeTake(limit: Int): Array[InternalRow] = sideEffectResult.take(limit).toArray

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ abstract class V2CommandExec extends SparkPlan {
*/
override def executeCollect(): Array[InternalRow] = result.toArray

override def executeToIterator: Iterator[InternalRow] = result.toIterator
override def executeToIterator(): Iterator[InternalRow] = result.toIterator

override def executeTake(limit: Int): Array[InternalRow] = result.take(limit).toArray

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ class JDBCTableCatalog extends TableCatalog with Logging {
.getTables(null, schemaPattern, "%", Array("TABLE"));
new Iterator[Identifier] {
def hasNext = rs.next()
def next = Identifier.of(namespace, rs.getString("TABLE_NAME"))
def next() = Identifier.of(namespace, rs.getString("TABLE_NAME"))
}.toArray
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -171,7 +171,7 @@ class SymmetricHashJoinStateManager(
return null
}

override def close: Unit = {}
override def close(): Unit = {}
}
}

Expand Down Expand Up @@ -280,7 +280,7 @@ class SymmetricHashJoinStateManager(
return reusedRet.withNew(currentKey, currentValue.value, currentValue.matched)
}

override def close: Unit = {}
override def close(): Unit = {}
}
}

Expand Down

0 comments on commit d1f9c3c

Please sign in to comment.