Informazioni sul servizio
TradottoCostruisco pipeline di streaming di produzione su Apache Flink che trasformano flussi di eventi in analisi istantanee e affidabili. Se i dati arrivano in batch ora e le intuizioni ritardano la realtà di ore, colmo quel divario. Progetto lavori attorno al tempo degli eventi e ai watermark, in modo che eventi in ritardo e fuori ordine siano gestiti correttamente, senza rompere silenziosamente le metriche. Ottimizzo backend di stato, checkpoint e savepoint per un'elevata capacità e un rapido recupero da guasti.
La massima priorità è la correttezza sotto carico. Implemento semantiche esattamente una volta end-to-end: sink transazionali dove supportati, scritture idempotenti altrove, in modo che il failover non raddoppi le addebiti e non perda ordini. Costruisco join di streaming attraverso più fonti, arricchisco eventi con dati di riferimento e catturo catene di frode, abbandoni di funnel e violazioni SLA nel momento in cui accadono tramite Flink CEP. Ottieni codice pulito, distribuzione testata e documentazione per il tuo team; lavoro con Kafka, Kinesis, Pulsar, JDBC e storage a oggetti.
— Tempo degli eventi e aggregazione delle finestre
— Esattamente una volta, checkpoint e savepoint
— Join, arricchimento e modelli Flink CEP
— Analisi in tempo reale, allerta e monitoraggio
La massima priorità è la correttezza sotto carico. Implemento semantiche esattamente una volta end-to-end: sink transazionali dove supportati, scritture idempotenti altrove, in modo che il failover non raddoppi le addebiti e non perda ordini. Costruisco join di streaming attraverso più fonti, arricchisco eventi con dati di riferimento e catturo catene di frode, abbandoni di funnel e violazioni SLA nel momento in cui accadono tramite Flink CEP. Ottieni codice pulito, distribuzione testata e documentazione per il tuo team; lavoro con Kafka, Kinesis, Pulsar, JDBC e storage a oggetti.
— Tempo degli eventi e aggregazione delle finestre
— Esattamente una volta, checkpoint e savepoint
— Join, arricchimento e modelli Flink CEP
— Analisi in tempo reale, allerta e monitoraggio
