spark-streaming

275 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
exception: org.apache.spark.sql.delta.ConcurrentAppendException: Files were added to the root of the table by a concurrent update
user_143668880
•
4
1
3426
delta-lake spark-streaming parquet databricks
Why sort based aggregation is used instead of hash based when aggregation function over string is used
user_13158330
•
1
0
141
spark-streaming spark-structured-streaming apache-spark-sql apache-spark
With Delta Lake, how to remove original file after compaction
user_163413370
•
2
1
577
delta-lake spark-streaming databricks apache-spark
Total records processed in each micro batch spark streaming
user_123358380
•
3
1
1261
spark-streaming spark-structured-streaming pyspark
How to efficiently process backlog using Spark Streaming?
user_17583780
•
2
0
97
spark-streaming apache-spark
Streaming to BigQuery with Apache Beam Pipeline on SparkRunner
user_160424030
•
3
0
189
spark-streaming apache-beam apache-spark google-bigquery
java.lang.NoClassDefFoundError: org/apache/spark/streaming/dstream/InputDStream
user_148563820
•
2
0
308
spark-streaming apache-kafka apache-spark scala
foreachRDD to pull average number of words & characters for each RDD in J8 Spark Streaming of Twitter API
user_59236190
•
2
2
214
twitter-streaming-api spark-streaming java-8 apache-spark
Streaming data from Cosmos DB using Apache Spark 3
user_138588560
•
2
1
451
spark-streaming spark-structured-streaming azure-cosmosdb azure-databricks apache-spark
How to apply MLFlow prediction model in a stream?
user_157457510
•
3
1
470
spark-streaming spark-structured-streaming databricks python
Hot Questions