在pyspark中创建文件流
首先在系统中打开第一个终端(记作数据源终端),命令如下:
$ cd /usr/local/spark/mycode $ mkdir streaming $ cd streaming $ mkdir logfile $ cd logfile
其次在系统中打开第二个终端(记作流计算终端)
启动进入pyspark后,输入如下命令:
>>> from pyspark import SparkContext >>> from pyspark.streaming
在pyspark中创建文件流
首先在系统中打开第一个终端(记作数据源终端),命令如下:
$ cd /usr/local/spark/mycode $ mkdir streaming $ cd streaming $ mkdir logfile $ cd logfile
其次在系统中打开第二个终端(记作流计算终端)
启动进入pyspark后,输入如下命令:
>>> from pyspark import SparkContext >>> from pyspark.streaming
上一篇 elasticsearch 8.2 正常启动，es-head 连接不上
下一篇 报错：Error creating bean with name ‘elasticsearchRestClientBuilder‘ defined
名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
