Logo Questions Linux Laravel Mysql Ubuntu Git Menu
HTML CSS JAVASCRIPT SQL PYTHON PHP BOOTSTRAP JAVA JQUERY R React Kotlin
 

New posts in spark-streaming

Can a model be created on Spark batch and use it in Spark streaming?

apache-spark machine-learning spark-streaming

Spark Streaming from Kafka Consumer

apache-spark apache-kafka pyspark spark-streaming kafka-consumer-api

Kafka with Spark 2.1 Structured Streaming - cannot deserialize

apache-spark pyspark deserialization apache-spark-sql spark-streaming

NoClassDefFoundError: Could not initialize XXX class after deploying on spark standalone cluster

scala apache-spark deployment spark-streaming spark-submit

How to parse JSON data in Scala?

scala spark-streaming

Spark Streaming on a S3 Directory

scala amazon-web-services amazon-s3 apache-spark spark-streaming

Is it possible to get the first n elements of every RDD in Spark Streaming?

spark-streaming

Direct Kafka Stream with PySpark (Apache Spark 1.6)

apache-spark apache-kafka pyspark spark-streaming

Kafka topic partition and Spark executor mapping

java apache-spark apache-kafka spark-streaming kafka-consumer-api

get topic from kafka message in spark

apache-spark apache-kafka spark-streaming

In Spark Streaming, is there a way to detect when a batch has finished?

scala apache-spark spark-streaming cloudera

Streaming data store in hive using spark

scala hadoop apache-spark hive spark-streaming

java.lang.IllegalArgumentException: Invalid lambda deserialization

java apache-spark apache-kafka spark-streaming

How to achieve dynamic load-balancing of tasks in Apache Spark

apache-spark spark-streaming load-balancing job-scheduling

java.lang.UnsupportedOperationException: 'Writing to a non-empty Cassandra Table is not allowed

apache-spark cassandra apache-spark-sql spark-streaming datastax-enterprise

Read json from Kafka and write json to other Kafka topic

scala apache-spark apache-kafka spark-streaming

Increase Kafka Streams Consumer Throughput

spark-streaming kafka-consumer-api apache-kafka-streams spark-streaming-kafka

Spark Structured Streaming with Hbase integration

scala apache-spark apache-kafka hbase spark-streaming

Stream-Static Join: How to refresh (unpersist/persist) static Dataframe periodically

scala apache-spark apache-spark-sql spark-streaming spark-structured-streaming

Idiomatic way to use Spark DStream as Source for an Akka stream

scala spark-streaming akka-stream akka-http
« Newer Entries Older Entries »