Realtidsläge i strukturerad direktuppspelning

Realtidsläge är en utlösartyp för Structured Streaming med en latens från början till slut på så lite som fem millisekunder. Använd det för operativa arbetsbelastningar som måste svara omedelbart på strömmande data, såsom bedrägeridetektion och personalisering i realtid.

Realtidsläget använder samma strukturerade streaming-API:er som mikrobatchbearbetning. Du aktiverar det genom att ställa in realtidstriggern på en strömningsfråga. För att jämföra med andra Structured Streaming-triggertyper, se Konfigurera Structured Streaming-triggerintervaller.

Realtidsläge är också tillgängligt i Lakeflow-pipelines. Se Använda realtidsläge i Lakeflow-pipelines.

Get started

Sida Description
Konfigurera realtidsläge Konfigurera klassisk beräkning, aktivera realtidstriggern och storlek på ditt kluster.
Realtidslägeskoncept Lär dig hur realtidsläget fungerar och när du ska använda det istället för mikrobatchläge.
Handledning: Köra ett strömningsjobb i realtid Kör din första streaming-sökning med realtidstriggern och en hastighetskälla.

Bygg realtidsapplikationer

Sida Description
Optimera och övervaka frågeprestanda i realtidsläge Justera beräkningar, minska end-to-end-latens och övervaka frågeprestanda med inbyggda mätvärden.
Begränsningar i realtidsläge Förstå kända begränsningar för källor, fackföreningar och mapPartitions.
Referens för realtidsläge Granska stödda miljöer, språk, beräkningstyper, källor, sänkor och operatörer.
Exempel på realtidsläge Utforska kodexempel för Kafka, Kinesis, Lakebase, stateful queries och anpassade sänkor.

Ytterligare resurser