Showing posts with label Azure Databricks. Show all posts
Showing posts with label Azure Databricks. Show all posts

Monday, January 26, 2026

Databricks in Early 2026: Advancements and AI-Driven Innovations

 We will the key advancements and AI-driven innovations within the Databricks Data Intelligence Platform as of late January 2026. The updates focus on unified management, AI agent extensibility, enhanced governance, and the seamless integration of transactional and analytical workloads. These releases emphasize usability improvements, security enhancements, and deeper AI capabilities, building upon the foundation laid in late 2025.

Unified Lakebase Management: A Streamlined Experience

The introduction of the Lakebase App, accessible through the apps switcher in the Databricks UI, marks a significant improvement in usability. This unified interface consolidates the management of both Lakebase Provisioned and Lakebase Autoscaling instances, streamlining the previously cumbersome workflow that required navigating through the Compute tab in the Lakehouse UI.

Lakebase, Databricks’ fully managed PostgreSQL-compatible OLTP database, now offers a more intuitive project-based structure. This enhancement simplifies the process for developers and data teams to handle transactional data alongside analytics, eliminating the need for complex ETL pipelines. Billing for Lakebase Autoscaling commenced in January 2026, following a free exploration period in late 2025. Key features include autoscaling compute, scale-to-zero functionality, database branching, and instant restore capabilities.

Databricks Runtime 18.0 Goes Generally Available

Databricks Runtime 18.0, including its Machine Learning variant, achieved general availability in January 2026. This runtime, powered by Apache Spark 4.1.0 and utilizing JDK 21 as the default (an LTS release), incorporates a range of bug fixes, security patches, performance optimizations, and library upgrades.

Notable behavioral extensions include the application of time travel and VACUUM changes to serverless compute, Databricks SQL, and Unity Catalog managed tables across supported runtimes. These updates ensure consistent data management across diverse environments.

AI/BI and Genie Enhancements for Better Collaboration

The AI/BI suite, which includes Genie (the conversational analytics tool), has received several usability enhancements designed to improve collaboration and efficiency:

  • JSON handling in tables: Objects now remain expanded during copy-paste operations, simplifying data manipulation.
  • Parameterized defaults for catalogs and schemas: This feature is available in dashboard deployments via Databricks Asset Bundles, enabling greater customization and control.
  • Multi-select filter improvements: Pasting comma- or newline-separated values is now easier, streamlining the filtering process.
  • Enhanced question categorization in Genie: The accuracy of Genie has been improved for common query patterns such as top-K queries, percentages, and distributions.
  • Default Consumer access for new users: Administrators can now set this via group cloning, granting view-only access to dashboards, Genie spaces, and apps. This is particularly useful for business users who require access to insights without the ability to create objects.

Furthermore, Databricks Assistant now supports custom agent skills for domain-specific tasks in agent mode, adhering to the open Agent Skills standard. These skills load automatically when relevant, significantly extending the Assistant’s capabilities and making it more adaptable to specific business needs.

Knowledge Assistant became generally available in select US regions (for non-enhanced security workspaces), offering connectors for popular platforms like Google Analytics, Salesforce, and ServiceNow. Row filtering has been added to managed connectors, allowing users to ingest only the necessary data via SQL-like WHERE conditions, optimizing data transfer and storage.

Security, Governance, and Model Serving Updates

Several updates have been implemented to enhance security, governance, and model serving capabilities:

  • Automatic email notifications for expiring personal access tokens are now generally available, providing proactive security measures.
  • Mosaic AI Model Serving has added support for hosted OpenAI GPT-5.1 Codex Max and Codex Mini models, which are specifically optimized for code-related tasks.
  • Delta Sharing continues to evolve with the introduction of recipient-specific URL formats and one-year token expirations, enhancing security and control over shared data.
  • AI/BI Genie and Databricks Assistant are now generally available on AWS GovCloud (including DoD environments), ensuring secure, government-compliant AI-powered workflows.

Looking Ahead in 2026

The Data + AI Summit 2026 is scheduled for June 15–18 in San Francisco, and the call for proposals is already open. Major announcements are anticipated regarding AI agents, multi-model governance, and lakehouse expansions.

Meanwhile, legacy features such as Community Edition were retired on January 1, 2026, with users being directed to the perpetual Free Edition. Legacy dashboards have been fully phased out, encouraging teams to transition to modern AI/BI tools.

These updates collectively reflect Databricks’ ongoing commitment to building a more integrated, AI-native platform. The platform aims to empower data teams to build production-grade agents, unify OLTP and OLAP workloads, and provide business users with trustworthy insights, all while maintaining centralized governance through Unity Catalog.

For the most up-to-date details, please refer to the official Databricks release notes, as rollouts are staged across AWS, Azure, and GCP.

Tuesday, November 14, 2023

PySpark— Update multiple columns in a dataframe

Working as a PySpark developer, data engineer, data analyst, or data scientist for any organisation requires you to be familiar with dataframes because data manipulation is the act of transforming, cleansing, and organising raw data into a format that can be used for analysis and decision making.

 

Note: We are using Databricks environment to articulate this example.


We understand, we can add a column to a dataframe and update its values to the values returned from a function or other dataframe column’s values as given below -

## importing sparksession from  
## pyspark.sql module
from pyspark.sql import SparkSession
from pyspark.sql.functions import col

# Create a Spark session and giving an app name
spark = SparkSession.builder.appName("UpdateMutliColumns"
).getOrCreate()

When you see data in a list in PySpark, it signifies you have a collection of data in a PySpark driver. This collection will be parallelized when you construct a DataFrame. Here, we have 5 elements in a list and let’s convert this to a DataFrame as given below —

### Create a list of data
MyData=[("Finance"
,2), ("Marketing",4), ("Sales",6), ("IT",8),("Admin",9) ]

#### convert above list to a DataFrame
sdf =  spark.createDataFrame(data=MyData, schema=['Dept'
,'Code'])

### show the schema of the dataframe
sdf.printSchema()

## Show the DataFrame
sdf.show(10
, False)


The most important aspect of Spark SQL & DataFrame is PySpark UDF (User Defined Function), which is used to enhance the PySpark built-in capabilities.

 

Note — UDFs are the costliest procedures, therefore use them only when you have no other option and when absolutely necessary. In the next part, I will explain in detail why utilising UDFs is a costly activity.

 

User-defined scalar functions — Python : This page covers examples of Python user-defined functions (UDFs). It demonstrates how to register and invoke UDFs.

 

#create square() function to return single value 
#passing variable is x
#return single value
def square(x):
  
return x*x
  
#create Cube function to return single value
#passing variable is x
#return cubes
def Cube(x):
  
return x*x*x

 

Register a function as a UDF — In PySpark, you can add custom UDFs in PySpark spark context as given below-

 

## Register the function as a UDF (User-Defined Function)
spark.udf.register("square_udf"
, square)
spark.udf.register("Cube_udf"
, Cube)

 

Add and Update multiple columns in a dataframe — If you want to update multiple columns in dataframe then you should make sure that these columns must be present in your dataframe. In case, updated columns are not in your dataframe, you must create them as given below — 

 

### Lets add a new column in the dataframe as SalesAmount
sdf2=sdf.withColumn("Square"
, expr("square_udf(Code)"))
sdf2=sdf2.withColumn("Cube"
, expr("Cube_udf(Code)"))

## Show the DataFrame
sdf2.show(10
, False)



Based on the official documentationwithColumn returns a new DataFrame by adding a column or replacing the existing column that has the same name.

 

Now, the above example shows you how to update multiple columns inside your dataframe in PySpark. By using withColumn, you can only create or modify one column at each time.



 

To learn more, please follow us -
http://www.sql-datatools.com

To Learn more, please visit our YouTube channel at —
http://www.youtube.com/c/Sql-datatools

To Learn more, please visit our Instagram account at -
https://www.instagram.com/asp.mukesh/

To Learn more, please visit our twitter account at -
https://twitter.com/macxima

To Learn more, please visit our medium account at -
https://macxima.medium.com/

Saturday, November 19, 2022

User Experience — Databricks Vs Snowflake

 Cloud is the fuel that drives today’s digital organisations, where businesses pay only for those selective services or resources that they use over a period of time.

  • Snowflake clusters run within the snowflake plane, that’s the reason it can repurpose VMs instantaneously for its customers whereas in Databricks, clusters run in the customer plane (customer VPC or VNet), so acquiring a VM and starting the cluster takes time.
  • There’s a serverless option in Databricks also, which runs within no time. It’s a new offering where the VMs run in the Databricks plane. Databricks SQL warehouse has simplified cluster sizing similar to snowflake(t-shirt sizing).
  • Databricks compute is customer-managed and takes a long time to start-up unless you have EC2 nodes waiting in hot mode, which costs money. Snowflake compute is pretty much serverless and will start in most cases in less than 1 second.
  • Databricks compute will not auto-start, which means you have to leave the clusters running to be able to allow users to query DB data. Snowflake compute is fully automated and will auto start in less than a second when a query comes in without any manual effort.
Databricks is generally cheaper (cost for X performance), so it’s easier to keep a shared autoscaling cluster running in Databricks than in Snowflake. Same for warm-start pools. It’s not a 1:1 comparison with regard to cost over time for the same performance.
Last but not least, you can use any platform you feel is best for the job, but be aware of the maintenance, cost, and performance factors for anything you implement. Snowflake is especially essential for applications involving advanced analytics and data science. Data scientists primarily utilize R and Python to handle large datasets. Databricks provides a platform for integrated data science and advanced analysis, as well as secure connectivity for these domains.