Filter interviews by
I applied via Recruitment Consulltant and was interviewed in Jun 2024. There was 1 interview round.
Map applies a function to each element in a collection and returns a new collection. Flat map applies a function that returns a collection for each element and flattens the result.
Map transforms each element in a collection using a function and returns a new collection of the same size.
Flat map applies a function to each element in a collection and returns a new collection by concatenating the results.
Example: Map - [1...
Partitioning is the process of dividing a large dataset into smaller, more manageable parts based on certain criteria.
Partitioning helps in improving query performance by reducing the amount of data that needs to be scanned.
It can be done based on columns like date, region, or any other relevant criteria.
Examples include partitioning a sales dataset by year or partitioning a customer database by region.
Top trending discussions
I applied via Naukri.com and was interviewed in Oct 2024. There were 2 interview rounds.
Optimizing SQL queries involves using indexes, avoiding unnecessary joins, and optimizing the query structure.
Use indexes on columns frequently used in WHERE clauses
Avoid using SELECT * and only retrieve necessary columns
Optimize joins by using INNER JOIN instead of OUTER JOIN when possible
Use EXPLAIN to analyze query performance and make necessary adjustments
Performance optimization in Spark involves tuning configurations, optimizing code, and utilizing caching.
Tune Spark configurations such as executor memory, number of executors, and shuffle partitions.
Optimize code by reducing unnecessary shuffles, using efficient transformations, and avoiding unnecessary data movements.
Utilize caching to store intermediate results in memory and avoid recomputation.
Example: In my projec...
SparkContext is the main entry point for Spark functionality, while SparkSession is the entry point for Spark SQL.
SparkContext is the entry point for low-level API functionality in Spark.
SparkSession is the entry point for Spark SQL functionality.
SparkContext is used to create RDDs (Resilient Distributed Datasets) in Spark.
SparkSession provides a unified entry point for reading data from various sources and performing
When a spark job is submitted, various steps are executed at the backend to process the job.
The job is submitted to the Spark driver program.
The driver program communicates with the cluster manager to request resources.
The cluster manager allocates resources (CPU, memory) to the job.
The driver program creates DAG (Directed Acyclic Graph) of the job stages and tasks.
Tasks are then scheduled and executed on worker nodes ...
Calculate second highest salary using SQL and pyspark
Use SQL query with ORDER BY and LIMIT to get the second highest salary
In pyspark, use orderBy() and take() functions to achieve the same result
The two types of modes for Spark architecture are standalone mode and cluster mode.
Standalone mode: Spark runs on a single machine with a single JVM and is suitable for development and testing.
Cluster mode: Spark runs on a cluster of machines managed by a cluster manager like YARN or Mesos for production workloads.
Client mode is better for very less latency due to direct communication with the cluster.
Client mode allows direct communication with the cluster, reducing latency.
Standalone mode requires an additional layer of communication, increasing latency.
Client mode is preferred for real-time applications where low latency is crucial.
I applied via Recruitment Consulltant and was interviewed in Nov 2024. There was 1 interview round.
Bigtable is a NoSQL database for real-time analytics, while BigQuery is a fully managed data warehouse for running SQL queries.
Bigtable is a NoSQL database designed for real-time analytics and high throughput, while BigQuery is a fully managed data warehouse for running SQL queries.
Bigtable is used for storing large amounts of semi-structured data, while BigQuery is used for analyzing structured data using SQL queries.
...
To remove duplicate rows from BigQuery, use the DISTINCT keyword. To find the month of a given date, use the EXTRACT function.
To remove duplicate rows, use SELECT DISTINCT * FROM table_name;
To find the month of a given date, use SELECT EXTRACT(MONTH FROM date_column) AS month_name FROM table_name;
Make sure to replace 'table_name' and 'date_column' with the appropriate values in your query.
The operator used in Composer to move data from GCS to BigQuery is the GCS to BigQuery operator.
The GCS to BigQuery operator is used in Apache Airflow, which is the underlying technology of Composer.
This operator allows you to transfer data from Google Cloud Storage (GCS) to BigQuery.
You can specify the source and destination parameters in the operator to define the data transfer process.
Code to square each element in the input array.
Iterate through the input array and square each element.
Store the squared values in a new array to get the desired output.
Dataflow is a fully managed stream and batch processing service, while Dataproc is a managed Apache Spark and Hadoop service.
Dataflow is a serverless data processing service that automatically scales to handle your data, while Dataproc is a managed Spark and Hadoop service that requires you to provision and manage clusters.
Dataflow is designed for both batch and stream processing, allowing you to process data in real-t...
BigQuery architecture includes storage, execution, and optimization components for efficient query processing.
BigQuery stores data in Capacitor storage system for fast access.
Query execution is distributed across multiple nodes for parallel processing.
Query optimization techniques include partitioning tables, clustering tables, and using query cache.
Using partitioned tables can help eliminate scanning unnecessary data.
...
RDD vs dataframe vs dataset in PySpark
RDD (Resilient Distributed Dataset) is the basic abstraction in PySpark, representing a distributed collection of objects
Dataframe is a distributed collection of data organized into named columns, similar to a table in a relational database
Dataset is a distributed collection of data with the ability to use custom classes for type safety and user-defined functions
Dataframes and Data...
Aptitude test involved with quantative aptitude, logical reasoning and reading comprehensions.
I have strong skills in data processing, ETL, data modeling, and programming languages like Python and SQL.
Proficient in data processing and ETL techniques
Strong knowledge of data modeling and database design
Experience with programming languages like Python and SQL
Familiarity with big data technologies such as Hadoop and Spark
Yes, I am open to relocating for the right opportunity.
I am willing to relocate for the right job opportunity.
I have experience moving for previous roles.
I am flexible and adaptable to new locations.
I am excited about the possibility of exploring a new city or country.
I applied via Naukri.com and was interviewed in Sep 2024. There were 2 interview rounds.
Round 1 was online Test where one basic coding question was there and few aptitiude , verbal ability and python based question.
A Data Warehouse is a centralized repository that stores integrated data from multiple sources for analysis and reporting.
Data Warehouses are designed for query and analysis rather than transaction processing.
They often contain historical data and are used for decision-making purposes.
Data Warehouses typically use a dimensional model with facts and dimensions.
Examples of Data Warehouse tools include Amazon Redshift, Sn
Nested queries in BigQuery allow for querying data from within another query, enabling complex data analysis.
Nested queries are queries that are embedded within another query
They can be used to perform subqueries to filter, aggregate, or manipulate data
Nested queries can be used in SELECT, FROM, WHERE, and HAVING clauses
select is used to select specific columns from a DataFrame, while withColumn is used to add or update columns in a DataFrame.
select is used to select specific columns from a DataFrame
withColumn is used to add or update columns in a DataFrame
select does not modify the original DataFrame, while withColumn returns a new DataFrame with the added/updated column
Example: df.select('col1', 'col2') - selects columns col1 and co...
Variables are used to store values that can be changed, while parameters are used to pass values into activities in ADF.
Variables can be modified within a pipeline, while parameters are set at runtime and cannot be changed within the pipeline.
Variables are defined within a pipeline, while parameters are defined at the pipeline level.
Variables can be used to store intermediate values or results, while parameters are use...
Types of joins in SQL include inner, outer, left, right, and cross join.
Inner join: Returns rows when there is a match in both tables
Outer join: Returns all rows when there is a match in one of the tables
Left join: Returns all rows from the left table and the matched rows from the right table
Right join: Returns all rows from the right table and the matched rows from the left table
Cross join: Returns the Cartesian produ
I applied via Walk-in
Spark optimization techniques aim to improve performance and efficiency of Spark jobs.
Use partitioning to distribute data evenly
Cache intermediate results to avoid recomputation
Optimize shuffle operations by reducing data shuffling
Use broadcast variables for small lookup tables
Tune memory and executor settings for better performance
based on 1 review
Rating in categories
Softwaretest Engineer
13
salaries
| ₹5.6 L/yr - ₹7 L/yr |
Software Engineer
9
salaries
| ₹3.8 L/yr - ₹10.5 L/yr |
Power BI Developer
6
salaries
| ₹5.1 L/yr - ₹7.5 L/yr |
Network Security Engineer
6
salaries
| ₹5.6 L/yr - ₹6.2 L/yr |
Data Engineer
5
salaries
| ₹4.8 L/yr - ₹6 L/yr |
TCS
Accenture
Infosys
Wipro