text(DataStreamReader)

텍스트 파일 스트림을 로드하고 스키마가 명명 value된 문자열 열과 분할된 열로 시작하는 DataFrame을 반환합니다. 텍스트 파일은 UTF-8로 인코딩되어야 합니다. 텍스트 파일의 각 줄은 기본적으로 결과 DataFrame의 새 행입니다.

문법

text(path, **options)

매개 변수

매개 변수	유형	설명
path	str	텍스트 입력의 경로입니다.

Returns

DataFrame

예제

임시 텍스트 파일에서 스트림을 로드합니다.

import tempfile
import time
with tempfile.TemporaryDirectory(prefix="text") as d:
    spark.createDataFrame(
        [("hello",), ("this",)]).write.mode("overwrite").format("text").save(d)
    q = spark.readStream.text(d).writeStream.format("console").start()
    time.sleep(3)
    q.stop()