开发者社区> 问答> 正文

flink与scala api中的parseQuotedStrings相同

"我想将此jave代码转换为scala:

DataSet> lines = env.readCsvFile(""movies.csv"")

        .ignoreFirstLine()
        .parseQuotedStrings('""')
        .ignoreInvalidLines()
        .types(Long.class, String.class, String.class);

我在scala中找不到任何替代方案,"

展开
收起
flink小助手 2018-11-28 16:19:50 1838 0
1 条回答
写回答
取消 提交回答
  • flink小助手会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关flink的问题及回答。

    "这是以下代码使用flink的java api,

    import org.apache.flink.api.java._

    val env = ExecutionEnvironment.getExecutionEnvironment
    val movies = env.readCsvFile(""movies.csv"")
    .ignoreFirstLine()
    .parseQuotedStrings('""')
    .ignoreInvalidLines()
    .types(classOf[Long], classOf[String], classOf[String])
    也可以使用flink的scala api,就像这样

    import org.apache.flink.api.scala._

    val env = ExecutionEnvironment.getExecutionEnvironment
    val movies = env.readCsvFile[(Int,String,String)]
    (""movies.csv"", ignoreFirstLine = true, quoteCharacter = '""', lenient = true)
    AFAIK Scala api没有java版本的流畅api。“lenient”选项与“ignoreInvalidLines”相同,其他选项应该是自解释的。"

    2019-07-17 23:16:50
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载