本文整理了Java中org.apache.flink.types.Row.toString
方法的一些代码示例,展示了Row.toString
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Row.toString
方法的具体详情如下:
包路径:org.apache.flink.types.Row
类名称:Row
方法名:toString
暂无
代码示例来源:origin: apache/flink
@Override
public String map(Row value) throws Exception {
return value == null ? "null" : value.toString();
}
};
代码示例来源:origin: apache/flink
.forRowFormat(new Path(outputPath), (Encoder<Row>) (element, stream) -> {
PrintStream out = new PrintStream(stream);
out.println(element.toString());
})
.withBucketAssigner(new KeyBucketAssigner())
代码示例来源:origin: apache/flink
@Test
public void testRowToString() {
Row row = new Row(5);
row.setField(0, 1);
row.setField(1, "hello");
row.setField(2, null);
row.setField(3, new Tuple2<>(2, "hi"));
row.setField(4, "hello world");
assertEquals("1,hello,null,(2,hi),hello world", row.toString());
}
内容来源于网络,如有侵权,请联系作者删除!