DEVHIDE
Login Or Sign up

List Question

20
885
Views

Spark Structured Streaming

Published on
#apache-spark #apache-kafka #spark-structured-streaming
34.5k
Views

Why does Spark application fail with “ClassNotFoundException: Failed to find data source: kafka” as uber-jar with sbt assembly?

Published on
#scala #apache-spark #sbt #sbt-assembly #spark-structured-streaming
1.4k
Views

Spark structured steaming from kafka - last message processed again after resume from checkpoint

Published on
#scala #apache-spark #apache-kafka #spark-structured-streaming
1.8k
Views

Spark Structured Streaming using sockets, set SCHEMA, Display DATAFRAME in console

Published on
#apache-spark #pyspark #apache-spark-sql #spark-structured-streaming
11.3k
Views

TypeError: 'Builder' object is not callable Spark structured streaming

Published on
#apache-spark #apache-spark-sql #spark-structured-streaming
1.7k
Views

Is there a bug about StructField in SPARK Structured Streaming

Published on
#apache-spark #pyspark #apache-spark-sql #spark-structured-streaming
763
Views

Why do Spark DataFrames not change their schema and what to do about it?

Published on
#apache-spark #apache-spark-sql #spark-streaming #spark-structured-streaming
825
Views

How to calculate the time to fetch records from Kafka?

Published on
#apache-spark #apache-kafka #spark-structured-streaming
1.5k
Views

Converting Json string to Avro in scala results in ClassCastException

Published on
#json #scala #apache-spark #apache-kafka #spark-structured-streaming
287
Views

Select entire row based on a logic applied on 2 columns across multiple rows

Published on
#scala #apache-spark #apache-spark-sql #spark-structured-streaming
19.5k
Views

How to use from_json with schema as string (i.e. a JSON-encoded schema)?

Published on
#apache-spark #apache-spark-sql #spark-structured-streaming
4.1k
Views

Why does spark-submit fail to find kafka data source unless --packages is used?

Published on
#maven #apache-spark #apache-kafka #apache-spark-sql #spark-structured-streaming
16.9k
Views

Why does starting a streaming query lead to "ExitCodeException exitCode=-1073741515"?

Published on
#windows #apache-spark #spark-structured-streaming
889
Views

How to perform multiple time Window operation on Streaming DataFrame?

Published on
#scala #apache-spark #apache-spark-sql #spark-structured-streaming
129
Views

How to know what events were late in a streaming batch?

Published on
#apache-spark #spark-structured-streaming
7.8k
Views

Apache Spark Structured Streaming vs Apache Flink: what is the difference?

Published on
#apache-spark #apache-flink #spark-structured-streaming
907
Views

Is watermark based on processing time or event time or both?

Published on
#apache-spark #spark-structured-streaming
6.9k
Views

How to read streaming data in XML format from Kafka?

Published on
#apache-spark #xml-parsing #apache-spark-sql #spark-structured-streaming
361
Views

How to pass records from Kafka to method?

Published on
#java #apache-spark #apache-kafka #kafka-consumer-api #spark-structured-streaming
1.4k
Views

How to apply lag function on streaming dataframe?

Published on
#scala #apache-spark #apache-spark-sql #window-functions #spark-structured-streaming

Trending Questions

Popular # Hahtags

javascript python java c# php android html jquery c++ css ios sql mysql r reactjs node.js arrays c asp.net json python-3.x ruby-on-rails .net sql-server swift django angular objective-c pandas excel

Popular Questions

Copyright © 2021 Jogjafile Inc.