IncludeHelp_logo
Skip Navigation Links

Home » MCQs

Apache Flink MCQs

Apache Flink MCQs: This section contains multiple-choice questions on Apache Flink. All MCQs have the correct answers and explanations. These MCQs will help students and professionals to test their skills and to enhance their knowledge of Apache Flink.

List of Apache Flink MCQs

1. 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.

Discuss this Question

2. 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.

Discuss this Question

3. 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.

Discuss this Question

4. 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

Discuss this Question

5. 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.

Discuss this Question

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.

Discuss this Question

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

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question

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.

Discuss this Question



Comments and Discussions!

Load comments ↻



Top MCQs
Top Programs/Examples
Top Tutorials
About
Student's Section
Subscribe

Copyright © 2024 www.includehelp.com. All rights reserved.