2열
2답변
mapGroupsWithState에서 stateSnapshot에 액세스하거나 스트림간에 GroupState를 공유하는 방법은 무엇입니까?
1열
2답변
적어도 N 개의 행이있을 때만 스트림 처리를 실행하는 방법?
2열
1답변
1열
1답변
사용자 정의 스트리밍 데이터 소스를 만드는 방법은 무엇입니까?
1열
1답변
readStream kafka는 아무런 값도 얻지 못합니다.
1열
1답변
MapType (StringType, StringType)의 열을 StringType으로 변환하는 방법은 무엇입니까?
1열
1답변
카프카에서 메시지 스트림을 읽는 중 Avro 메시지를 처리하는 방법은 무엇입니까?
1열
1답변
flatMapGroupsWithState를 사용하여 상태 저장 집계를 수행하는 방법은 무엇입니까?
0열
1답변
하이브에 spark.writeStream 결과를 저장하려면 어떻게해야합니까?
1열
1답변
Spark Structured Streaming은 ElasticSearch와 통합합니다.