Interested to Buy Any Domain ? << Click Here >> for more details...
Explain different transformations in DStream in Apache Spark Streaming?
- 1 Answers
- 345 Views
- I also Faced
- E-Mail Answers
Answer / Awanish Kumar Dwivedi
{"transformations":[n "map": maps each element of a DStream to a new value using a user-defined function.n "filter": selects and returns elements from the input DStream based on a given condition.n "reduceByKey": aggregates values associated with the same key across partitions.n "join": combines two DStreams or a DStream and an RDD on a common key.n "updateStateByKey": updates an accumulator value associated with each key in a DStream.n ]}
| Is This Answer Correct ? | 0 Yes | 0 No |
Can you explain accumulators in apache spark?
Explain the filter transformation?
Define partitions in apache spark.
When was spark introduced?
Can you run spark without hadoop?
Can you define parquet file?
Why is there a need for broadcast variables when working with Apache Spark?
What are the types of Apache Spark transformation?
What is the use of spark in big data?
Explain the flatMap() transformation in Apache Spark?
What is spark sqlcontext?
How apache spark works?
-
Apache Hadoop (394) - MapReduce (354)
- Apache Hive (345)
- Apache Pig (225)
- Apache Spark (991)
- Apache HBase (164)
- Apache Flume (95)
- Apache Impala (72)
- Apache Cassandra (392)
- Apache Mahout (35)
- Apache Sqoop (82)
- Apache ZooKeeper (65)
- Apache Ambari (93)
- Apache HCatalog (34)
- Apache HDFS Hadoop Distributed File System (214)
- Apache Kafka (189)
- Apache Avro (26)
- Apache Presto (15)
- Apache Tajo (26)
- Hadoop General (407)
