Rubric for Lab 1

Course Learning Objectives

For your convenience, we repeat the course learning objectives.

By the end of this course, you will be able to:

IDDescription
L1Use basic big data processing systems like Hadoop and MapReduce.
L2Implement parallel algorithms using the in-memory Spark framework, and streaming using Kafka.
L3Use libraries to simplify implementing more complex algorithms.
L4Identify the relevant characteristics of a given computational platform to solve big data problems.
L5Utilize knowledge of hardware and software tools to produce an efficient implementation of the application.

Criteria

Lab 1 is graded by five criteria:

We list indicators for specific grades below. Please note these are indicators only. Under specific unexpected circumstances, TA's may use other indicators, that are not written down here, to modify the grade. This means that these indicators should not be used as an exhaustive check-list for the grade, but do provide a strong recommendation for a specific grade.

Functionality

  • Weight: (40%)
  • Related Learning Objectives: L1, L2, L3

The program functions correctly according to the requirements described in the assignment for at least an "adequate" application.

GradeIndicators
0 (fail)The program does not compile.
The program exits with errors not due to the user.
The program does not adhere to all requirements of an "adequate application".
6 (adequate)The program compiles.
The program exits without errors, unless the user does something wrong.
The program adheres to all requirements of an "adequate application".
8 (good)The program compiles.
The program exits without errors. When the user does something wrong, a descriptive text of how to correct their input is returned.
The program adheres to all requirements of an "good application".
10 (excellent)The program compiles.
The program exits without errors. When the user does something wrong, a descriptive text of how to correct their input is returned.
The program adheres to all requirements of an "excellent application".

Scalability

  • Weight: (20%)
  • Related Learning Objectives: L1, L2

The program is constructed in such a way that in the case multiple computational nodes (e.g. more Spark workers) work on the problem concurrently, there is potential for the performance of the program to increase.

An example when this is not the case is where a map() is not applied to a distributed dataset (e.g. an RDD or a DataSet), but perhaps by mistake the student has first used dataset.collect() (taking the data out of the Spark context) follow by a plain Scala .map(). The map is now applied on a locally collected dataset, preventing other nodes from performing useful work.

GradeIndicators
0 (fail)More than one step is implemented in a non-scalable fashion, where it could have been implemented in a scalable fashion.
6 (adequate)There is at most one step implemented in a non-scalable fashion, where it could have been implemented in a scalable fashion.
8 (good)All steps are implemented in a scalable fashion where applicable.
10 (excellent)As with (good), in addition to comments in the code describing for each step that causes a shuffle, that it does so and why.

Libraries

  • Weight: (10%)
  • Related Learning objectives: L1, L3

The program is constructed by using Spark SQL.

GradeIndicators
0 (fail)The student has not used Spark SQL to implement the specified functionality.
6 (adequate)The student has used Spark SQL to implement the specified functionality.
8 (good)The student has used Spark SQL and does not construct compute paths by combining more primitive Spark functions into functions that already exist in the Spark (SQL) API.
10 (excellent)The student has introduced abstractions for re-usability. E.g. they have developed a library on top of the Spark libraries providing an easier-to-use API to make similar queries.

Measurements

  • Weight: (5%)
  • Related Learning Objectives: L5

The run-time of various computational steps of the program are profiled (this functionality exists in Spark). The run-time of the specified computational steps is reported.

GradeIndicators
0 (fail)The student has not reported any measurements.
10 (excellent)The student has reported the run-time of the specified computational steps exposed by Spark's profiling functionality.

Analysis

  • Weight: (25%)
  • Related Learning Objectives: L1, L2, L3, L5

The student shows a thorough understanding of the produced code and its behavior in the context of Apache Spark. This is conveyed through the code, comments in the code, and the report.

GradeIndicators
0 (fail)The student shows a lack of understanding of the constructs used in the solution.
The code does not contain any descriptive comments.
There report provided cannot be considered a reasonable attempt.
6 (adequate)The student shows a decent understanding of the constructs used in their solution, but often makes minor mistakes.
The student has explained most non-trivial constructs in their solution.
The student explains the measurement results, but gives no hypotheses for anomalies.
8 (good)The student shows a decent understanding of the constructs used in their solution, and only makes minor to negligible mistakes in their analysis.
The student has explained all non-trivial constructs in their solution.
The student explains all aspects of the measurement results, and gives acceptable hypotheses for anomalies.
10 (excellent)The student shows a thorough understanding of the constructs used in their solution, without making any mistakes.
The student has explained all non-trivial constructs in their solution.
The student explains all aspects of the measurement results, and gives a correct thorough explanation for anomalies.