はどのように、JavaではJavaの

Question

を使用してスパークで一覧またはArrayから行を作成するために、私はRowFactory.createは（）の行を作成するために使用します。

「レコードは」データベースからレコードをある

Row row = RowFactory.create(record.getLong(1), record.getInt(2), record.getString(3)); 

、しかし、私は事前に "レコード"の長さを知ることができないので、私はリストまたは配列を使用して "行"を作成したい。 Scalaでは、Row.fromSeq（）を使用してリストまたは配列から行を作成できますが、Javaでどのように実現できますか？

Answer 1

質問が正しく出るかどうかはわかりませんが、RowFactoryを使用してJavaのArrayListからRowを作成できます。

List<MyData> mlist = new ArrayList<MyData>(); 
    mlist.add(d1); 
    mlist.add(d2); 

Row row = RowFactory.create(mlist.toArray()); 

Answer 2

実際のアプリケーションでは、データセットまたはデータフレームを作成する必要があります。ここで、Javaアプリケーションの行とデータセットを作成する方法の例である：私はあなたの方法を使用する場合

// initialize first SQLContext 
SQLContext sqlContext = ... 
StructType schemata = DataTypes.createStructType(
     new StructField[]{ 
       createStructField("NAME", StringType, false), 
       createStructField("STRING_VALUE", StringType, false), 
       createStructField("NUM_VALUE", IntegerType, false), 
     }); 
Row r1 = RowFactory.create("name1", "value1", 1); 
Row r2 = RowFactory.create("name2", "value2", 2); 
List<Row> rowList = ImmutableList.of(r1, r2); 
Dataset<Row> data = sqlContext.createDataFrame(rowList, schemata); 

+-----+------------+---------+ 
| NAME|STRING_VALUE|NUM_VALUE| 
+-----+------------+---------+ 
|name1|  value1|  1| 
|name2|  value2|  2| 
+-----+------------+---------+