/MiniHive

A mini model of Hive using MapReduce on HDFS which implements functionalities such as SELECT, WHERE, MAX, MIN, COUNT and AVERAGE, generally required by an SQL query engine.

Primary LanguageJava

MiniHive

Steps to execute

  1. javac shell.java
  2. java shell

SQL Queries Syntax

LOAD <filename.csv> as (col1=int, col2=str, col3=int, ........)

SELECT col1,col2 from filename where col2 = value

SELECT <AGGREGATE_FUNC>(col_name) from filename where some_column = "some_value" (for strings)

SELECT <AGGREGATE_FUNC>(col_name) from filename where some_column == some_value (for integers)

SELECT <AGGREGATE_FUNC>(col_name) from filename where some_column some_value (where can be >,<,>=,<=,!=)

AGGREGATE_FUNC can be COUNT, MIN, SUM