org.apache.flink.types.Row.toString()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(0.9k)|赞(0)|评价(0)|浏览(138)

本文整理了Java中org.apache.flink.types.Row.toString方法的一些代码示例,展示了Row.toString的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Row.toString方法的具体详情如下:
包路径:org.apache.flink.types.Row
类名称:Row
方法名:toString

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

相关文章