ALINK(十二)：加载数据集 (五)内存数据读入 (MemSourceBatchOp)

Java 类名：com.alibaba.alink.operator.batch.source.MemSourceBatchOp

Python 类名：MemSourceBatchOp

功能介绍

从内存中读取数据生成表

参数说明

代码示例

Python 代码

无，仅在Java中使用

Java 代码

import org.apache.flink.types.Row;
import com.alibaba.alink.operator.batch.BatchOperator;
import com.alibaba.alink.operator.batch.source.MemSourceBatchOp;
import org.junit.Test;
import java.util.Arrays;
import java.util.List;
public class MemSourceBatchOpTest {
  @Test
  public void testMemSourceBatchOp() throws Exception {
    List<Row> df = Arrays.asList(
      Row.of("1:2.0 2:1.0 4:0.5", 1.5),
      Row.of("1:2.0 2:1.0 4:0.5", 1.7),
      Row.of("1:2.0 2:1.0 4:0.5", 3.6)
    );
    BatchOperator<?> batchData = new MemSourceBatchOp(df, "f1 string, f2  double");
    batchData.print();
  }
}

运行结果

标签：MemSourceBatchOp,1.0,ALINK,0.5,读入,import,2.0,Row
来源： https://www.cnblogs.com/qiu-hua/p/14887437.html