This is an interview challenge for Paytm Labs. Please feel free to fork. Pull Requests will be ignored.
The challenge is to make make analytical observations about the data using the distributed tools below.
-
Sessionize the web log by IP. Sessionize = aggregrate all page hits by visitor/IP during a session. https://en.wikipedia.org/wiki/Session_(web_analytics)
-
Determine the average session time
-
Determine unique URL visits per session. To clarify, count a hit to a unique URL only once per session.
-
Find the most engaged users, ie the IPs with the longest session times
-
Predict the expected load (requests/second) in the next minute
-
Predict the session length for a given IP
-
Predict the number of unique URL visits by a given IP
- Spark (any language, but prefer Scala or Java)
- Pig
- MapReduce (Hadoop 2.x only)
- Flink
- Cascading, Cascalog, or Scalding
If you need Hadoop, we suggest HDP Sandbox: http://hortonworks.com/hdp/downloads/ or CDH QuickStart VM: http://www.cloudera.com/content/cloudera/en/downloads.html
- You are allowed to use whatever libraries/parsers/solutions you can find provided you can explain the functions you are implementing in detail.
- IP addresses do not guarantee distinct users, but this is the limitation of the data. As a bonus, consider what additional data would help make better analytical conclusions
- For this dataset, complete the sessionization by time window rather than navigation. Feel free to determine the best session window time on your own, or start with 15 minutes.
- The log file was taken from an AWS Elastic Load Balancer: http://docs.aws.amazon.com/ElasticLoadBalancing/latest/DeveloperGuide/access-log-collection.html#access-log-entry-format
A. Fork this repo in github https://github.com/PaytmLabs/WeblogChallenge
B. Complete the processing and analytics as defined first to the best of your ability with the time provided.
C. Place notes in your code to help with clarity where appropriate. Make it readable enough to present to the Paytm Labs interview team.
D. Complete your work in your own github repo and send the results to us and/or present them during your interview.
We want to see how you handle:
- New technologies and frameworks
- Messy (ie real) data
- Understanding data transformation This is not a pass or fail test, we want to hear about your challenges and your successes with this particular problem.