0
Spark Structured Streamingでストリーミングデータフレームとバッチデータフレームを組み合わせるにはどうすればよいですか？Spark Structured Streamingにおけるストリーミングデータフレームとバッチデータフレームの結合
A
答えて
1
あなたが行うことができ、通常の加入：
val stream = spark.readStream(....)
val batch = spark.read....
val joinSandB = stream.join(batch, "someColumn")
をすべて見るdocumentation
で関連する問題
- 1. Hbase統合によるSpark Structured Streaming
- 2. Spark Structured Streamingでバイナリデータを処理する
- 3. Spark Structured Streamingでの複数の集計
- 4. Apache Spark（Structured Streaming）：S3チェックポイントのサポート
- 5. Spark Structured StreamingはElasticSearchと統合します
- 6. kafka connect 0.10とSpark Structured Streamingでfrom_jsonを使用するには？
- 7. トピック内の複数のパーティションに対するSpark Structured Streaming
- 8. Spark Structured StreamingエグゼキュータとKafkaパーティション間のマッピングの説明
- 9. ClojureでSpark Structured Streamingの例を書き込むときのエラー
- 10. Spark Structured Streamingでの書き込み時のKafkaオフセットのキャプチャ
- 11. Spark Structured Streamingが背圧を処理する方法は？
- 12. Spark Structured Streamingの日付列のウィンドウ操作
- 13. Spark Structured Streaming Window（）関数 - GeneratedIteratorが64 KBを超えて拡大
- 14. spark structured streaming（java）：タスクがシリアライズできない
- 15. Spark Structured Streamingを使用してディレクトリを継続的に監視する方法
- 16. データセット<Row>をSpark Structured Streaming - Java8のkafka出力トピックに書く方法
- 17. Spark Structured Streaming用のTCPソケットを使用してデータを送信する方法
- 18. Spark Streaming - updateStateByKeyとキャッシュデータ
- 19. Spark Structured Streamingで新しいデータがS3から取得されない
- 20. RowInemptyを送信するときにSpark Structured StreamingでArrayIndexOutOfBounds例外が発生する
- 21. Spark Structured StreamingのCassandraのような外部店舗からKafkaとクエリを読み取る方法は？
- 22. Spark Streaming Kafka backpressure
- 23. Spark Streaming with wholeTextFiles
- 24. Spark Cassandra Streaming
- 25. KafkaUtils java.lang.NoClassDefFoundError Spark Streaming
- 26. spark streaming fileStream
- 27. Spark Streaming Kafka Consumer
- 28. Spark Streaming StatisticsのAPI
- 29. ElasticSearchにおける結合のシミュレーション
- 30. スパークにおけるIDの行の結合/結合