Ir al contenido principal

Modo en tiempo real en Apache Spark Structured Streaming

Procese datos en milisegundos en las API de Spark sin mantener un segundo motor especializado

Data pipeline running 2 Kafka sinks, 404K records.

Procesa datos en streaming en milisegundos en un cómputo sin servidor

El Modo en tiempo real (RTM) ofrece una latencia de milisegundos con las API de Spark familiares, lo que elimina la necesidad de tener motores separados, como Apache Flink. Al admitir el procesamiento continuo, el RTM logra una latencia de tan solo 5 ms para las cargas de trabajo más urgentes. Integrado de forma nativa en los Declarative Pipelines de Apache Spark™, garantiza que los equipos de datos logren un rendimiento extremo y los beneficios de los servicios totalmente administrados, que incluyen ejecución sin versiones, actualizaciones de infraestructura automatizadas y un mantenimiento con tiempo de inactividad bajo o nulo.

Potencie las cargas de trabajo operativas con un motor de ejecución unificado

Minimize logic drift and codebase duplication

Minimiza la desviación de la lógica y la duplicación de la base de código

Usa la misma API de Spark para el entrenamiento por lotes a gran escala y la inferencia en tiempo real de latencia ultrabaja. RTM permite una escalabilidad sin fisuras, lo que le permite cambiar las canalizaciones de lotes por hora a una transmisión continua con un solo cambio en el código, lo que elimina por completo la necesidad de arquitecturas complejas de doble motor.

Spark RTM mostly has lower latency than Flink.

Procesa eventos hasta un 92 % más rápido que Flink

RTM está diseñado para la toma de decisiones en menos de un segundo, lo que genera un impacto en casos de uso como la detección de fraudes en tiempo real y la personalización en tiempo real. Mediante un flujo de datos continuo, la programación de pipelines y los shuffles de streaming, RTM logra latencias P99 estrictas de entre 40 y 300 ms en cargas de trabajo operativas exigentes.

PROFUNDIZA MÁS

Obtén más información sobre el Modo en tiempo real

Productos relacionados

Descubre más

Explora otras ofertas integradas e inteligentes en la plataforma de inteligencia de datos.

Pipelines declarativos de Apache Spark™

Simplifica el ETL por lotes y de transmisión con calidad de datos automatizada, captura de datos modificados (CDC), ingesta de datos, transformación y gobernanza unificada.

GENIE CODE

Cree y mantenga flujos de datos con IA automatizada que comprenda sus datos.

Ingesta de Zerobus

Envía datos de eventos directamente a tu lakehouse en tiempo casi real. La API de escritura directa reduce tu carga operativa con un alto rendimiento y capacidad de procesamiento a escala.

Unity Catalog

Controla sin problemas todos tus activos de datos con la única solución de gobernanza abierta y unificada de la industria para datos e IA, integrada en la plataforma de inteligencia de datos de Databricks.

¿Estás listo para convertirte en una
empresa de datos e IA?

Da los primeros pasos en tu transformación