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();
  }
}

 

运行结果

f1	f2
1:2.0 2:1.0 4:0.5	1.5000
1:2.0 2:1.0 4:0.5	1.7000
1:2.0 2:1.0 4:0.5	3.6000