流式数据打印 (PrintStreamOp)

Java 类名：com.alibaba.alink.operator.stream.utils.PrintStreamOp

Python 类名：PrintStreamOp

功能介绍

该组件打印表中数据。

参数说明

名称	中文名称	描述	类型	是否必须？	取值范围	默认值

代码示例

Python 代码

from pyalink.alink import *

import pandas as pd

useLocalEnv(1)

df = pd.DataFrame([
    [0, "abcde", "aabce"],
    [1, "aacedw", "aabbed"],
    [2, "cdefa", "bbcefa"],
    [3, "bdefh", "ddeac"],
    [4, "acedm", "aeefbc"]
])

inOp = StreamOperator.fromDataframe(df, schemaStr='id long, text1 string, text2 string')

inOp.print()

StreamOperator.execute()

Java 代码

import org.apache.flink.types.Row;

import com.alibaba.alink.operator.stream.StreamOperator;
import com.alibaba.alink.operator.stream.source.MemSourceStreamOp;
import org.junit.Test;

import java.util.Arrays;
import java.util.List;

public class PrintStreamOpTest {
	@Test
	public void testPrintStreamOp() throws Exception {
		List <Row> df = Arrays.asList(
			Row.of(0, "abcde", "aabce"),
			Row.of(1, "aacedw", "aabbed"),
			Row.of(2, "cdefa", "bbcefa"),
			Row.of(3, "bdefh", "ddeac"),
			Row.of(4, "acedm", "aeefbc")
		);
		StreamOperator <?> inOp = new MemSourceStreamOp(df, "id int, text1 string, text2 string");
		inOp.print();
		StreamOperator.execute();
	}
}

运行结果

id	text1	text2
4	acedm	aeefbc
2	cdefa	bbcefa
3	bdefh	ddeac
1	aacedw	aabbed
0	abcde	aabce