nasıl Java'da java

Question

kullanarak Spark List veya Array Bir Satır oluşturmak için ben RowFactory.create() Bir Satır oluşturmak için kullanın:

"kayıt" bir veritabanından bir kayıt olduğunu

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

, ama önceden "kayıt" uzunluğunu bilmiyorum, bu yüzden "satır" oluşturmak için bir Liste veya bir Array kullanmak istiyorum. Scala'da, bir Listeden veya bir Diziden bir Satır oluşturmak için Row.fromSeq() kullanabilirim, ancak bunu Java’da nasıl yapabilirim?

Answer 1

Sorunuzu doğru bir şekilde aldığımdan emin değilim, ancak java'da ArrayList'ten Row oluşturmak için RowFactory'yi kullanabilirsiniz.

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

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

Answer 2

Gerçek dünya uygulamalarında Datasets veya Dataframes oluşturmamız gerekir. Ben senin yöntemini kullandığınızda

// 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| 
+-----+------------+---------+