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

本文主要是介绍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();
  }
}

运行结果

这篇关于ALINK(十二)：加载数据集 (五)内存数据读入 (MemSourceBatchOp)的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！