스트리밍 싱크에 DataSourceStreamWriter 데이터를 쓰는 인스턴스를 반환합니다.
이 구현은 쓰기 가능한 스트리밍 데이터 원본에 필요합니다.
문법
streamWriter(schema: StructType, overwrite: bool)
매개 변수
| 매개 변수 | 유형 | 설명 |
|---|---|---|
schema |
구조형 타입 | 쓸 데이터의 스키마입니다. |
overwrite |
bool | 현재 마이크로배치를 작성할 때 기존 데이터를 덮어쓸지 여부를 나타내는 플래그입니다. |
Returns
DataSourceStreamWriter
스트리밍 싱크에 데이터를 쓰기 위한 기록기 인스턴스입니다.