зеркало из https://github.com/microsoft/spark.git
Removed Logging trait from CoalescedRDD since we don't log anything
This commit is contained in:
Родитель
4a74e8635c
Коммит
5718cef2a4
|
@ -11,8 +11,7 @@ private class CoalescedRDDSplit(val index: Int, val parents: Array[Split]) exten
|
||||||
* or to avoid having a large number of small tasks when processing a directory with many files.
|
* or to avoid having a large number of small tasks when processing a directory with many files.
|
||||||
*/
|
*/
|
||||||
class CoalescedRDD[T: ClassManifest](prev: RDD[T], maxPartitions: Int)
|
class CoalescedRDD[T: ClassManifest](prev: RDD[T], maxPartitions: Int)
|
||||||
extends RDD[T](prev.context)
|
extends RDD[T](prev.context) {
|
||||||
with Logging {
|
|
||||||
|
|
||||||
@transient val splits_ : Array[Split] = {
|
@transient val splits_ : Array[Split] = {
|
||||||
val prevSplits = prev.splits
|
val prevSplits = prev.splits
|
||||||
|
|
Загрузка…
Ссылка в новой задаче