Posts

Showing posts with the label Spark SQL

Featured Post

Claude Code for Beginners: Step-by-Step AI Coding Tutorial

Image
 Artificial Intelligence is changing how developers write software. From generating code to fixing bugs and explaining complex logic, AI tools are becoming everyday companions for programmers. One such powerful tool is Claude Code , powered by Anthropic’s Claude AI model. If you’re a beginner or  an experienced developer looking to improve productivity, this guide will help you understand  what Claude Code is, how it works, and how to use it step-by-step . Let’s get started. What is Claude Code? Claude Code is an AI-powered coding assistant built on top of Anthropic’s Claude models. It helps developers by: Writing code from natural language prompts Explaining existing code Debugging errors Refactoring code for better readability Generating tests and documentation In simple words, you describe what you want in plain English, and Claude Code helps turn that into working code. It supports multiple programming languages, such as: Python JavaScri...

Spark SQL Query how to write it in Ten steps

Image
Spark SQL example The post tells how to write SQL query in Spark and explained in ten steps.This example demonstrates how to use sqlContext.sql to create and load two tables and select rows from the tables into two DataFrames. The next steps use the DataFrame API to filter the rows for salaries greater than 150,000 from one of the tables and shows the resulting DataFrame. Then the two DataFrames are joined to create a third DataFrame. Finally the new DataFrame is saved to a Hive table. 1. At the command line, copy the Hue sample_07 and sample_08 CSV files to HDFS: $ hdfs dfs -put HUE_HOME/apps/beeswax/data/sample_07.csv /user/hdfs $ hdfs dfs -put HUE_HOME/apps/beeswax/data/sample_08.csv /user/hdfs where HUE_HOME defaultsto /opt/cloudera/parcels/CDH/lib/hue (parcel installation) or /usr/lib/hue (package installation). 2. Start spark-shell: $ spark-shell 3. Create Hive tables sample_07 and sample_08: scala> sqlContext.sql("CREATE TABLE sample_07 (code string...