Madhura Limaye

David Dieruf

John Allwright

DataStax and Decodable <a href="https://www.datastax.com/press-release/datastax-and-decodable-partner-to-remove-the-complexity-and-cost-of-delivering-real-time-applications-and-data-services-at-scale">announced</a> a new partnership to help application developers delight customers with instantaneous real-time features and deliver streaming data services in minutes, not months, without specialist skills.
The two companies will connect their cloud services to deliver the benefits of three powerful open source technologies: <a href="https://pulsar.apache.org/">Apache Pulsar</a>, <a href="https://flink.apache.org/">Apache Flink</a>, and <a href="https://cassandra.apache.org/_/index.html">Apache Cassandra&reg;</a>.&nbsp;
The solution offers fully-managed services available on any cloud through DataStax&rsquo;s Cassandra-based <a href="https://www.globenewswire.com/Tracker?data=TbqobqcTH8qzI6rXIqIl3vZ4spwHdAaogMeFn17yFhB7jvpq8hm1PjhTN8il_YJ95DiyA4lEdi9HlPPPBzaVg8vbtCs9ZbACqo6rVksxyYg=">Astra DB</a>, Pulsar-based <a href="https://www.globenewswire.com/Tracker?data=TbqobqcTH8qzI6rXIqIl3oOLWqDm5G5VjJAPCJuaWHToXP0sqE68_2_hHpDeMrklgMS3xe_BaXTS2ZC3OeqJBR88-wiIAbYMql9ObQyQyYR7sDUDhwO36NVs8pZz1i0F">Astra Streaming</a>, and Decodable&rsquo;s SQL-based stream processing platform powered by <a href="https://flink.apache.org/flink-architecture.html">Apache Flink</a>&trade;. The combination of Decodable&rsquo;s open source, stream processing capabilities connected to DataStax&rsquo;s open stack for real-time applications enables developer and data engineering teams to:
<ul>
<li style="font-weight: 400;" aria-level="1">Connect to legacy operational, analytic, and streaming systems in minutes using Decodable and Astra Streaming.</li>
<li style="font-weight: 400;" aria-level="1">Process data in SQL with Decodable and feed it to applications in real-time with Astra Streaming.</li>
<li style="font-weight: 400;" aria-level="1">Deliver data from DataStax&rsquo;s multi-cloud Database as a Service (DBaaS), Astra DB, and advanced unified event streaming Astra Streaming service to power modern, real-time, applications and machine learning.</li>
</ul>
In this blog, we&rsquo;ll dig into why real-time matters, what&rsquo;s stopping adoption, and how DataStax + Decodable unlocks streaming for any organization. The blog will also highlight a real-world use-case of the DataStax + Decodable solution.
<h2>Real-time customer experiences matter</h2>
To understand the rationale behind the DataStax and Decodable partnership and the push for real-time data, let&rsquo;s step back for a moment. How do you convert a standard app user to a delighted advocate that&rsquo;s moved to socialize how much they love the experience?&nbsp;
It&rsquo;s that moment when their streaming service recommends a playlist that fits the mood perfectly. It&rsquo;s when a fraud notification lets the user know an incident has already been prevented - no canceled cards, no further action needed. It&rsquo;s when an order gets filled earlier than planned, and they get an unexpected notification that it&rsquo;s on the way!
Capitalizing on the immediacy of these key customer experience moments is made possible by real-time data and automated decisions. It&rsquo;s not an overstatement to say that these moments can define industry leaders. Just consider, how would Uber or Lyft possibly operate in batch mode?
Put simply, developers make data work for their customers. They find insights to create enhanced customer experiences, gain competitive advantage, and drive intelligent features.
<h2>So why isn&rsquo;t everything real-time already?</h2>
Real-time customer experiences rely on data platforms that can provide access to real-time data. Fully realizing the value of real-time data means processing continuous stream(s) of data records, not just a single event. Performing pattern matching &amp; aggregation, joining multiple streams, and analyzing a sliding window of records provide context to individual records that feed the end experience, ML model, or analytical database.
Open source streaming data platforms that provide these capabilities have been available for some time, but deploying, configuring, and operating them requires deep skills and a significant investment of time and money. Even then, teams can lose data or real-time performance through a misunderstanding of Apache Flink <a href="https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/checkpointing/">checkpointing</a>, inadequate capacity planning, or integration issues. It&rsquo;s a serious undertaking and, as a result, gives streaming data a reputation that many organizations consider out of reach. So many projects ripe for real-time never see the light of day out of this fearful perception. The significant challenges perceived by many organizations in achieving continuous streaming are as follows:&nbsp;
<ul>
<li style="font-weight: 400;" aria-level="1">They&rsquo;re not used to dealing with huge recordsets of changing data types at millisecond latencies.&nbsp;</li>
<li style="font-weight: 400;" aria-level="1">Joining multiple data sources bottlenecks select operations and impacts performance.</li>
<li style="font-weight: 400;" aria-level="1">Data is ingested and accessed via a complex and fragile web of connections where any format change breaks a dozen different things.</li>
<li style="font-weight: 400;" aria-level="1">Middleware technologies have strict integration requirements that span multiple languages, and these technologies cannot cope with the scale of real-time performance.</li>
<li style="font-weight: 400;" aria-level="1">Maintaining the technologies to make real-time decisions is incredibly complex, requiring specific skills, tooling, and data conforming to very specific requirements.</li>
<li style="font-weight: 400;" aria-level="1">The cost! Ooh, the cost of running all these technologies!</li>
</ul>
Having the right data to make the right decisions at the right time is priceless. Excuses like &ldquo;it&rsquo;s too complex&rdquo; or &ldquo;that data isn&rsquo;t accessible here&rdquo; are reasons for a lost customer connection. Whether it&rsquo;s on the application&rsquo;s time-to-value or time-to-scale or the eventual customer experience, increased time means lost revenue, lost customers, and damaged relationships.&nbsp;
<h2>DataStax &amp; Decodable: making real-time simple</h2>
Decodable and DataStax free your data from traditional silos and make it consumable by applications and services, enabling them to make real-time decisions. Developers&rsquo; applications can connect to and consume data as a continuous stream.
<ul>
<li style="font-weight: 400;" aria-level="1">DataStax provides an open stack for real-time data, with Astra Streaming (based on Apache Pulsar) for data in motion and Astra DB (based on Apache Cassandra) for data at rest, available as a service on any cloud, exposing standard APIs.</li>
<li style="font-weight: 400;" aria-level="1">Decodable completes the stack with its stream processing and capabilities and library of connectors for a wide range of sources and sinks.</li>
<li style="font-weight: 400;" aria-level="1">Decodable and DataStax Astra Streaming are available as fully managed services, optimally deployed and configured, so that organizations can focus on building the applications that drive their business forward and not spend cycles on the day-to-day operations and maintenance of the data platform.&nbsp;</li>
</ul>
<h3>Set up continuous data streams in a few simple steps</h3>
<ul>
<li style="font-weight: 400;" aria-level="1">Use Decodable&rsquo;s built-in connectors to integrate with data sources and sinks.&nbsp;</li>
<li style="font-weight: 400;" aria-level="1">Build Decodable pipelines using industry-standard SQL to ingest, enhance, and normalize data.&nbsp;</li>
<li style="font-weight: 400;" aria-level="1">Sink the data to an Apache Pulsar messaging system powered by DataStax Astra Streaming.</li>
<li style="font-weight: 400;" aria-level="1">If needed, persist data in Astra DB through a simple connector. Make it available to other messaging systems, database engines, analytics systems, or buckets if required.</li>
<li style="font-weight: 400;" aria-level="1">Consume data from Astra Streaming &amp; Astra DB via standard APIs like Pulsar, JMS, Kafka and REST, Document, GraphQL, and gRPC.</li>
<li style="font-weight: 400;" aria-level="1">DataStax and Decodable make all the data and the real-time data processing easy, and it is available at your fingertips with a few clicks.</li>
</ul>
<h3>Scale on any cloud</h3>
DataStax uses serverless architectures available on any cloud (AWS, GCP, Azure) and ensures flexibility where consumers can start small and scale without limits. The serverless architectures scale with application needs automatically - needing no management. Consistent single-digit processing time ensures low latency for rapid events and data processing.
<h3>It&rsquo;s your data; we take care of the rest</h3>
The fully managed services from DataStax and Decodable eliminate the operational burden related to data management while keeping full visibility and control via standard orchestration and observability tools. Data is as easy to operate as applications. What would have taken months now only takes minutes, and all the management &amp; operations are taken care of for you, with a reduced TCO.
<ul>
<li style="font-weight: 400;" aria-level="1">Fully-managed DBaaS with Astra DB</li>
<li style="font-weight: 400;" aria-level="1">Fully-managed Streaming-aaS with Astra Streaming</li>
<li style="font-weight: 400;" aria-level="1">Fully managed SaaS to build and deploy real-time data pipelines with Decodable</li>
</ul>
<h2>Click streams with DataStax and Decodable - A real-world example</h2>
Telemetry data is all the rage today. It&rsquo;s driving feedback loops and data-driven decision-making and is a core piece of product-led growth. The data is usually transmitted in the background of a website or mobile app when the user takes action. The action could be a simple click or something more meaningful like adding an item to their shopping cart.
This type of click data is typically very minimal. As a background task, it should be invisible to the user&rsquo;s experience. So the data can&rsquo;t carry much context to keep response time very low. It&rsquo;s just simply a collection of key/value pairs. The client (in the web browser) is gathering this minimal click data without much validation or knowledge of what&rsquo;s happening.
Once all this data is available in a processing pipeline, it needs to be normalized. An example of normalization would be taking the browser&rsquo;s `user agent` click data and breaking the interesting pieces out - like the operating system, browser type, and browser version.
The following flow is an example of all this processing in action: 
<img src="https://cdn.sanity.io/images/bbnkhnhl/production/0714e8d4b6cf471b25e2e736a9ddca446f2fc222-1361x586.png" alt="" width="1000" height="430" />
 Using Decodable&rsquo;s HTTP connector, the click data can be posted in the web browser to the generated connector endpoint. From there, everything about the connection and its payload are managed on the server side. Decodable processing pipelines do all this work at almost no cost to latency. How? All processing is SQL based and in-memory.
From the connector, the data feeds into a processing pipeline. The pipeline parses the click data into something structured (and useful). Then the normalized data is sent to an Astra Streaming topic and forwarded to another pipeline that filters for only &ldquo;product clicks.&rdquo; That filtered click data forwards to a second Astra Streaming Pulsar topic.
Once the data is available on a topic within Astra, there is the option to persist to a Cassandra table in Astra DB. There&rsquo;s no code required to do this, just add a &ldquo;sink&rdquo; connector and point it to an existing table. A development team could also use a Pulsar client to subscribe to the topic and receive the click data as it arrives. It&rsquo;s at this point that the application context kicks in. The identifier in the click data can look up further information and decide how to provide a better experience.
The combination of pipeline processing in Decodable and messaging topics in Astra Streaming are the core of real-time data. They create a new world of possibilities. The consumers (your applications) use a Pulsar client to subscribe to the topic and receive data as it arrives. Astra Streaming takes care of the schema, message semantics, and availability. Decodable provides the ingest, normalization, and processing pipelines with ease.&nbsp;
<h2>Get started today</h2>
To learn more about the above example, <a href="https://www.datastax.com/resources/webinar/stream-processing-is-the-secret-to-transforming-your-business">watch the on-demand recording</a> of a live session discussing the solution specifics. Create a free account with both <a href="https://astra.datastax.com/register">DataStax Astra </a>and <a href="https://app.decodable.co/-/accounts/create">Decodable</a>. It&rsquo;s quite easy to create a connection between the two, and with that, you can begin creating meaningful business solutions.
The combination of DataStax and Decodable could be the catalyst to the next level of your business. Try the example and discover what possibilities lie ahead!

Build and scale cloud native apps

Discover the benefits of DBaaS and why your apps deserve an upgrade.

Learn about NoSQL Databases

Learn about NoSQL databases with Apache Cassandra and Astra DB.

2022 Recap: A Year for Customers, Community, and Real-Time Data

Highlights from 2022 and a glimpse into the year ahead.

ViewingCompany

DataStax & Decodable: The Fast Path To Real-Time Apps

Sign up for our Developer Newsletter