300+ TOP Apache Flink MCQ Questions and Answers

Apache Flink Multiple Choice Questions

1. In the Kappa architecture, data is ingested as ____.

  1. Batches
  2. Continuous stream
  3. Both
  4. None

Answer: B Continuous stream

Explanation: Instead of being processed in batches, data is consumed in the Kappa architecture as a continuous stream.

2. Kappa architecture consisted of how many main components?

  1. 5
  2. 4
  3. 3
  4. 2

Answer: C 3

Explanation: The architecture consists of three main components:

  • Ingestion layer
  • Processing layer
  • Storage layer

3. Is Apache Flink scalable?

  1. Yes
  2. No

Answer: A Yes

Explanation: Apache Flink is extremely scalable, with applications spread across several containers in a cluster.

4. Which of the following is True about Apache Flink?

  1. Apache Flink is a real-time processing framework.
  2. Apache Flink is a stream-processing and batch-processing framework
  3. Both
  4. None

Answer: C Both

Explanation: Apache Flink is a real-time processing framework, which can process both stream data and batch data.

5. Apache Flink works on which of the following architecture?

  1. Kappa
  2. Event-driven architecture
  3. Peer-to-peer architecture
  4. Lambda architecture

Answer: A Kappa

Explanation: Apache Flink works on Kappa architecture.

6. What is a bounded stream?

  1. Bounded streams are datasets with a specified beginning and end point.
  2. Bounded streams are datasets with a specified start but no defined finish.

Answer: A Bounded streams are datasets with a specified beginning and end point.

Explanation: Bounded streams are datasets with a specified beginning and end point.

7. Which of the following is considered a building block of streaming applications?

  1. Stream
  2. State
  3. Time
  4. All of the above

Answer: D All of the above

Explanation: There are three building blocks of streaming applications:

  • Stream
  • State
  • Time

8. What is an unbounded stream?

  1. Unbounded streams are datasets with a specified beginning and end point.
  2. Unbounded streams are datasets with a specified start but no defined finish.

Answer: B Unbounded streams are datasets with a specified start but no defined finish.

Explanation: Unbounded streams are datasets with a specified start but no defined finish.

9. Which of the following APIs handles data in a continuous stream?

  1. Dataset API
  2. DataStream API
  3. Table API
  4. CEP API

Answer: B DataStream API

Explanation: DataStream API handles data in a continuous stream.

10. Does Java and Scala programming languages support DataStream API?

  1. Yes
  2. No

Answer: A Yes

Explanation: Yes, Both java and Scala support DataStream API.

11. Which of the following API is used to conduct batch actions on data over time?

  1. Dataset API
  2. DataStream API
  3. Table API
  4. CEP API

Answer: A Dataset API

Explanation: The Apache Flink Dataset API is used to conduct batch actions on data over time.

12. Which of the following API is a relational API with SQL-like expression language?

  1. Database API
  2. Relation API
  3. Table API
  4. SQL-like API

Answer: C Table API

Explanation: Table API is a relational API with SQL-like expression language.

13. Table API can do both batch and stream processing?

  1. Yes
  2. No

Answer: A Yes

Explanation: Yes, Table API can do both batch and stream processing.

14. What do you mean by CEP?

  1. Complex engine processing
  2. Complex event processing
  3. Clear engine processing
  4. Complex engine program

Answer: B Complex event processing

Explanation: CEP stands for Complex event processing.

15. Which of the following API for analyzing event patterns in continuous streaming data?

  1. Dataset API
  2. Stream API
  3. Gelly API
  4. CEP API

Answer: D CEP API

Explanation: CEP API is for analyzing event patterns in continuous streaming data.

16. Which of the following is Apache Flink’s Graph API?

  1. Graph QL API
  2. Graphy API
  3. Gelly API
  4. All

Answer: C Gelly API

Explanation: Gelly is Apache Flink’s Graph API. Gelly is a suite of techniques and tools that is used to do graph analysis on Flink applications.

17. Apache Flink’s Machine Learning library is called ____.

  1. Apache ML
  2. Apache machine
  3. Flink Learning
  4. FlinkML

Answer: D FlinkML

Explanation: Apache Flink’s Machine Learning library is called FlinkML.

18. Which of the following processes makes use of a bounded data stream?

  1. Stream
  2. Batch

Answer: B Batch

Explanation: Batch processing makes use of a bounded data stream.

19. Flink’s support of how many notions of time?

  1. 5
  2. 4
  3. 3
  4. 2

Answer: C 3

Explanation: Flink explicitly supports three different notions of time:

  • event time
  • ingestion time
  • processing time

20. Which of the following method is used to convert one data stream into another by applying a function to each stream element?

  1. Stream()
  2. Transform()
  3. Filter()
  4. Map()

Answer: D Map()

Explanation: The map() method is used to convert one data stream into another by applying a function to each stream element.

21. Which of the following function removes undesired components from a data stream depending on a criterion?

  1. Clear()
  2. Filter()
  3. PassBy()
  4. Intersect()

Answer: B Filter()

Explanation: The filter() function removes undesired components from a data stream depending on a criterion.

22. Which of the following architectural component of Apache Flink is in charge of accepting code (software) and creating a job dataflow graph, which is subsequently passed to JobManager?

  1. Client
  2. TaskManager
  3. ConfigManager

Answer: A Client

Explanation: The client component is in charge of accepting code (software) and creating a job dataflow graph, which is subsequently passed to JobManager.

23. Which of the following method is used to aggregate data in a stream by merging several components based on a supplied function into a single element?

  1. Minimise()
  2. Lower()
  3. Dec()
  4. Reduce()

Answer: D Reduce()

Explanation: The reduce() method is used to aggregate data in a stream by merging several components based on a supplied function into a single element.

24. Each element of a data stream is transformed into zero, one, or many items of another stream using the ____ function.

  1. Map()
  2. Element()
  3. flatMap()
  4. StreamMap()

Answer: C flatMap()

Explanation: Each element of a data stream is transformed into zero, one, or many items of another stream using the flatMap() function.

25. Which of the following architectural component of Apache Flink is responsible for building the execution graph after receiving the Job Dataflow Graph from the Client?

  1. JobManager
  2. TaskManager
  3. Preschedule

Answer: A JobManager

Explanation: JobManager is responsible for building the execution graph after receiving the Job Dataflow Graph from the Client.

26. Which method writes data to an external system, such as a database or file system?

  1. Write()
  2. DB_Write()
  3. Sink()
  4. Faucet()

Answer: C Sink()

Explanation: Sink() writes data to an external system, such as a database or file system.

27. Which of the following method is used to build custom data processing logic on a stream?

  1. Stream()
  2. Process()
  3. Handler()
  4. Transform()

Answer: B Process()

Explanation: To build custom data processing logic on a stream, use the process() function.

28. Apache Flink is written in which of the following language?

  1. Java
  2. Scala
  3. Both
  4. None

Answer: C Both

Explanation: Apache Flink is written in Java and Scala language.

29. The Task Manager is in charge of carrying out the dataflow task and reporting the results to the ____.

  1. Client
  2. JobManager
  3. Program

Answer: B JobManager

Explanation: The Task Manager is in charge of carrying out the dataflow task and reporting the results to the JobManager.

30. The ____ function partitions a data stream based on a given key or key field.

  1. Key()
  2. KeyStream()
  3. KeyBy()
  4. KeyField()

Answer: C KeyBy()

Explanation: The keyBy() function partitions a data stream based on a given key or key field.

Apache Flink objective questions with answers pdf download online exam test

Leave a Reply

Your email address will not be published. Required fields are marked *