CPEN 221 / Machine Problem 5

This machine problem is designed to allow you to explore multiple aspects of software construction:

• managing complex ADTs;
• multithreading and the client-server pattern;
• query parsing and execution.

In addition to these aspects, the problem also touches upon rudimentary methods for statistical inference and learning.

Read this document carefully before you start.

• You should complete this assignment in pairs.
• The submission deadline is December 1, 11:59pm Vancouver time.
• To get your Github repositories set up, using this link.

For this machine problem, you will work with an excerpt from the Yelp Academic Dataset. Specifically, you will work with data (in JSON format) on restaurants, and this data includes information about some restaurants, reviews of the restaurants, and user information (for those contributing reviews).

You will use the dataset to create and maintain a simple in-memory database with restaurants, users and reviews. (Since the Yelp Academic Dataset does not contain details of business near UBC we are using information for restaurants near UC Berkeley or UCB!)

The given dataset is in the JSON format and you can use the JSON Processing project implementation of a framework for working with JSON in Java 8. Using such a framework requires that the Java compiler knows where to find the relevant files. A build manager like Gradle helps you indicate the JSON processing library as a dependency (for example, see mvnrepository.) You may also want to read: Gradle Dependency Management.

The first part of this machine problem is to build a datatype (YelpDB) that represents Yelp's restaurant dataset.

At the minimum:

• This datatype must implement the MP5Db interface, and
• This datatype should have a constructor that takes three Strings as arguments: these Strings represent filenames. The first file is the list of restaurants, the second file is the list of reviews and the third file is the user list.

You should design this datatype to support a variety of useful operations. You have to decide on the representation for this datatype keeping extensibility (the ability to add new features and operations) in mind.

To enable a reusable design, you many also want to examine some of the Amazon datasets (see http://jmcauley.ucsd.edu/data/amazon/) and determine all the other datatypes you may need as well as useful subtype relationships. Think of simple types that can fit a variety of database situations and then subtype them to specialize for YelpDB.

Before you start writing a lot of code, you should design the datatypes you want to create: what operations could these types support, what is a suitable representation and what are the rep invariants and abstraction functions. (You will have to document your design and discuss this with the instructor or a TA.) Think about enabling useful operations for your database and do not implement only the methods dictated by the MP5Db interface.

For this part, complete a document called Design.md and place it in the main folder for your repository (where you would find this README.md file.) In this document, you should describe the choices you have made or plan on making. This document should be available to the TAs and the instructor 12 hours ahead of your meeting with them.

In this part of the machine problem you will implement two approaches to statistical machine learning: one is an instance of unsupervised learning and the second is an instance of supervised learning. Statistical learning is an exciting area for computing today!

The two operations that you have to support are also part of the MP5Db interface.

Suppose you are given a set of (x, y) coordinates, you may sometimes want to group the points into k clusters such that no point is closer to the center point (centroid) of a cluster other than the one to which it is assigned. In the case of restaurants, this approach may allow us to group restaurants that are in the same neighbourhood even without knowing anything about the neighbourhoods in a city. A similar approach is used to group similar products on online shopping services such as Amazon.

The k-means algorithm finds k centroids within a dataset that each correspond to a cluster of inputs. To do so, k-means clustering begins by choosing k centroids at random, then alternates between the following two steps:

1. Group the restaurants into clusters, where each cluster contains all restaurants that are closest to the same centroid.
2. Compute a new centroid (average position) for each non-empty cluster.

This visualization is a good way to understand how the algorithm works.

For the k-means clustering algorithm, you should implement a method that returns a List of Sets: each Set represents a cluster of restaurants. You should also implement a method that converts such a List to JSON format as illustrated by the JSON file voronoi.json in the directory visualize. (In this format, the field weight denotes the size of the dot used in the visualization. You can use the same weight for all restaurants.)

You can run the provided visualization method using python (Python 3) and the visualization is called a Voronoi tesselation.

One can visualize the tessalation produced by k-means clustering by writing the JSON formatted cluster information to voronoi.json in the visualize directory and then launch visualize.py as follows: python3 visualize.py For the curious, you can also see some Javascript in action here.

As an instance of supervised learning, you will implement an algorithm for predicting the rating that a user may give to a restaurant.

By analyzing a user's past ratings, we can try to predict what rating the user might give to a new restaurant.

To predict ratings, you will implement simple least-squares linear regression, a widely used statistical method that approximates a relationship between some input feature (such as price) and an output value (the rating) with a line. The algorithm takes a sequence of input-output pairs and computes the slope and intercept of the line that minimizes the mean of the squared difference between the line and the outputs.

Implement the getPredictorFunction method, which takes a user and returns a function that predicts the users ratings. Use the restaurant's priciness as the feature (x values in the regression) to predict the user's rating (y values in the regression).

One method of computing these values is by calculating the sums of squares, S_xx, S_yy, and S_xy:

• S_xx = Σ_i (x_i - mean(x))²
• S_yy = Σ_i (y_i - mean(y))²
• S_xy = Σ_i (x_i - mean(x))(y_i - mean(y))

After calculating the sums of squares, the regression coefficients, and R² (r_squared), which is an estimate of the quality of the predictor, are defined as follows:

• b = S_xy / S_xx
• a = mean(y) - b * mean(x)
• R² = S_xy² / (S_xx S_yy)

In this machine problem, we will use a functional interface to return functions.

In the next part of this machine problem, you should implement a multi-threaded server application, YelpDBServer that wraps a YelpDB instance.

One should be able to start the server from the command line using

java ca.ece.ubc.cpen221.mp5.YelpDBServer 4949

where 4949 is the port number at which the server should listen for connection requests. The server should use the command line argument to decide which port number to bind to.

The server should be able to handle more than one connection at the same time (and hence the need for multithreading).

The server should be able to handle some simple requests from a client that connects to it.

Here are five simple requests that you should implement:

• GETRESTAURANT <business id>: To this request, the server should respond with the restaurant details in JSON format for the restaurant that has the provided business identifier. If there is no such restaurant then one should use the error message as above. (Note that the business is is not wrapped in < >. The use of < > is to indicate that the command should be followed by a required argument. So the request will look like this: GETRESTAURANT h_we4E3zofRTf4G0JTEF0A and this example refers to the restaurant Fondue Fred in the provided dataset.)
• ADDUSER <user information>: This request is a string that begins with the keyword (in our protocol), ADDUSER, followed by user details in JSON, formatted as suited for the Yelp dataset. Since we are adding a new user the JSON formatted information will contain only the user's name. So the JSON string may look like this {"name": "Sathish G."}. The server should interact with the RestaurantDB to create a new user, generate a new userid (it does not have to be in the Yelp userid format, you can use your own format for new users), generate a new URL (although it is a dummy URL) and then acknowledge that the user was created by responding with a more complete JSON string such as: {"url": "http://www.yelp.com/user_details?userid=42", "votes": {}, "review_count": 0, "type": "user", "user_id": "42", "name": "Sathish G.", "average_stars": 0}. If the argument to the ADDUSER command is invalid (not JSON format, missing name, etc.) then the server would respond with the message ERR: INVALID_USER_STRING. Note that the server can create a new user if the argument to this command is a valid JSON string and has a field called name but also has other information (which can be ignored).
• ADDRESTAURANT <restaurant information>: This command has structure similar to the ADDUSER command in that the JSON string representing a restaurant should have all the necessary details to create a new restaurant except for details such as business_id and stars. If the provided string is incomplete or erroneous , the error message should ERR: INVALID_RESTAURANT_STRING.
• ADDREVIEW <review information>: The last simple command to implement is an ADDREVIEW command which has the same principle as the other commands. The possible error codes are ERR: INVALID_REVIEW_STRING, ERR: NO_SUCH_USER and ERR: NO_SUCH_RESTAURANT.

Remember that when multiple clients are making such requests to change the database you will need to deal with potential data races and other concurrency-related conflicts.

For any other errors in the requests, you can send an ERR: ILLEGAL_REQUEST.

The final part of this machine problem is to support structured queries over the database you have constructed. The request-response pattern will be handled by the RestaurantDBServer as was the case with "simple" requests earlier.

We would like to process queries such as "list all restaurants in a neighbourhood that serve Chinese food and have moderate ($$) price."

In our request-response model, the request would begin with the keyword QUERY followed by a string that represents the query.

A query string may be: in(Telegraph Ave) && (category(Chinese) || category(Italian)) && price <= 2. This query string represents a query to obtain a list of Chinese and Italian restaurants in the Telegraph Avenue neighbourhood that have a price range of 1-2.

For the query string above, the server would respond with a list of restaurants in JSON notation. If no restaurants match the query (for any reason) then the server should respond with ERR: NO_MATCH. If no query string is sent or if the query is ill-formed then the response should be ERR: INVALID_QUERY.

The grammar for the query language looks something like this:

<orExpr> ::= <andExpr>(<or><andExpr>)*
<andExpr> ::= <atom>(<and><atom>)*
<atom> ::= <in>|<category>|<rating>|<price>|<name>|<LParen><orExpr><RParen>
<or> ::= "||"
<and> ::= "&&"
ineq ::= <gt>|<gte>|<lt>|<lte>|<eq>
<gt> ::= ">"
<gte> ::= ">="
<lt> ::= "<"
<lte> ::= "<="
<eq> ::= "="
<num> ::= [1-5]
<in> ::= "in" <LParen><string><RParen>
<category> ::= "category" <LParen><string><RParen>
<name> ::= "name" <LParen><string><RParen>
<rating> ::= "rating" <ineq><num>
<price> ::= "price" <ineq><num>
<LParen> ::= "("
<RParen> ::= ")"

We will grade your work using the following approximate breakdown of the aspects of required.

We will use the following approximate rubric to grade your work:

Functionality apart, we will evaluate your submissions carefully along the following dimensions:

• code style (e.g., an A on Codacy);
• clear specifications for methods;
• implementation of unit tests (high test coverage and integration with Coveralls.io);
• code-level comments as appropriate;
• comments the indicate clearly what the representation invariants and abstraction functions are for the datatypes you create.

• Use example code we have provided to implement a multi-threaded server.
• You can use a parser generator (such as ANTLR) for parsing queries (or roll your own).
• Consider using streams and parallel streams for some of the tasks.
• There are several easier tasks you can accomplish before focusing on structured queries. Use your time wisely.
• It is critical that your build.gradle file reflect any dependencies that your work may have (external libraries such as JSON parsers.) (You work will not be graded otherwise.)
• When you complete this assignment, you would have implemented an approximation of a relational database. In the relational database world, a row is analogous to an instance of a datatype while a table definition is analogous to a datatype definition.
• Ensure that you have Codacy and Coveralls set up early.
• Your Github repo should reflect contributions from both team members.

1. Commit and push your work to Github.
2. Include a Team.md document where you indicate who worked on this assignment and how the work was divided up.
3. Add a comment in the text box on Canvas indicating that you have submitted the work and the names of the students in the pair.