stream-processing

1La chaleur

1Répondre

Comment faire un flux de session avec Apache Flink?

Je veux mettre en forme ce flux: 1,1,1,2,2,2,2,2,3,3,3,3,3,3,3,0,3,3,3,5,. .. à ces séances: 1,1,1 2,2,2,2,2 3,3,3,3,3,3,3 0 3,3,3 5 J'ai écrit CustomTrigger pour détecter lorsque les éléments

0La chaleur

1Répondre

Flink ou Spark pour les données incrémentales

Je n'ai aucune expérience avec Flink ou Spark, et j'aimerais utiliser l'une d'entre elles pour mon cas d'utilisation. J'aimerais présenter mon cas d'utilisation et, espérons-le, avoir une idée de ce q

1La chaleur

1Répondre

Partager l'état parmi les opérateurs dans Flink

Je me demande s'il est possible dans Flink de partager l'état entre les opérateurs. Supposons, par exemple, que j'ai un partitionnement par clé sur un opérateur et que j'ai besoin d'un état de partiti

2La chaleur

1Répondre

Recommandation du cadre de traitement des événements

Je suis nouveau dans le domaine du traitement des événements. Je suis à la recherche d'un cadre de traitement d'événements basé sur Java pour mes besoins. J'ai parcouru un labyrinthe de documentation

0La chaleur

1Répondre

Qu'arrive-t-il aux messages qui parviennent à un serveur implémente le traitement de flux après que la source a atteint sa limite?

flux AKKA d'apprentissage Im, mais de toute évidence son rapport avec tout cadre de streaming :) citant akka documentation: réactifs Streams est juste pour définir un mécanisme commun de la façon de d

1La chaleur

1Répondre

Quelles sont les différences entre l'architecture kappa et l'architecture lambda

Si l'architecture Kappa effectue directement l'analyse sur le flux au lieu de diviser les données en deux flux, où se trouve alors le datastored dans un système messagin comme Kafka? ou peut-il être d

0La chaleur

1Répondre

Traitement de flux de données (tempête) et traitement d'événements complexes

Je fais des recherches sur le traitement de flux combiné avec le traitement d'événements complexes.Je veux utiliser un logiciel open source pour travailler sur Apache Storm.J'ai trouvé des moteurs CEP

1La chaleur

1Répondre

différences entre les classes dans backtype.storm & org.apache.storm & com.twitter.heron packages

Je veux écrire des ordonnanceurs personnalisés pour apache héron, et je plonge un peu dans le code source. J'ai remarqué que dans le code source du héron, il y a quelques paquets avec des classes simi

2La chaleur

2Répondre

Composant Camel-Kafka ne fonctionne pas pour l'erreur: "en raison de courtiers doivent être configurés"

Vous avez une erreur en utilisant le composant kafka pour Apache Camel (version 2.19.1), j'essaie juste d'imprimer les messages entrants dans le sujet, mon pipeline est ainsi composé: ... context.add

1La chaleur

1Répondre

Comment compter le nombre de "clients" dans un état avec flink de manière distribuée en fonction des événements de changement d'état? J'aurais besoin d'objets avec état

Je travaille sur le projet poc en java en utilisant kafka -> flink -> recherche élastique. Sur kafka sera produit un nombre imprévisible d'événements de 0 jusqu'à des milliers d'événements/sec comme s