当前位置:   article > 正文

Flink学习笔记 --- DataSet Source and Sink_flink dataset 读取 richsourcefunction

flink dataset 读取 richsourcefunction

DataSouce
InputFormat:
1.File-based:
    readTextFile(path):Read files line wise and returns them as Strings.
    readTextFileWithValue(path):Reads files line wise and returns them as StringValues(String Values are mutable strings).
    readCsvFile(path):Parses file of comma(or anthor char) delimited fiedls.Returns a DataSet of tuples, case class
        or POJOs, Supports the basic java types and their values counterparts as field types.
    readFileOfPrimitives(path, delimiter):Parses files of new-line(or anthor char sequence) delimited primitive data types
        such as String or Integer using the given delimiter.
    readHadoopFile(FileInputFormat, key, Value, path):Create a JobConf and reads file from the specified FileInputFormat,Key class and Value class and return
        them as Tuple2<key, value>.
    readSequenceFile(key, va
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/盐析白兔/article/detail/886358
推荐阅读
相关标签
  

闽ICP备14008679号