Chuyển đổi biểu Scala Java 1.8

Question

Tôi đang cố gắng để chuyển đổi biểu thức này Scala Java:

val corpus: RDD[String] = sc.wholeTextFiles("docs/*.md").map(_._2) 

Đây là những gì tôi có trong Java:

RDD<String> corpus = sc.wholeTextFiles("docs/*.md").map(a -> a._2); 

Nhưng tôi nhận được một lỗi trên a._2 :.

Nếu tôi đi đến phương pháp "siêu", đây là những gì tôi thấy:

package org.apache.spark.api.java.function; 

import java.io.Serializable; 

public interface Function<T1, R> extends Serializable { 
     R call(T1 var1) throws Exception; 
} 

Answer 1

Trong Scala PairRDD là một loại tuple và bạn có thể truy cập các thành viên của nó với _1 và _2. Tuy nhiên Java không có sẵn trong Tuples nên bạn phải sử dụng các phương thức để có được những thành viên này. Nó sẽ giống như thế này, vì Java luôn yêu cầu dấu ngoặc đơn trên bất kỳ hàm nào.

JavaRDD<String> corpus = sc.wholeTextFiles("docs/*.md").map(a -> a._2()); 

Edit: Dường như trong Scala một tham số ngầm được truyền cho phương thức map, có nghĩa là bạn phải vượt qua nó một cách rõ ràng trong Java. Xem here cho Tài liệu Java và here cho tài liệu Scala.

Chỉnh sửa 2: Sau một vài giờ dò dẫm câu trả lời được tìm thấy, nó phải là một JavaRDD.

Answer 2

Bạn sẽ có thể sử dụng values() để có được những kết quả mà bạn muốn trong Java ở đây:

JavaRDD<String> corpus = sc.wholeTextFiles("docs/*.md").values(); 

Lưu ý rằng loại ở đây là JavaRDD không RDD