Développement d'applications de Flink

10 0 0 0

Flink est un cadre informatique unifié qui prend en charge à la fois le traitement par lots et le traitement de flux. Il fournit un moteur de traitement de données en flux qui prend en charge la distribution de données et le calcul parallèle. Flink propose un traitement de flux et est l'un des meilleurs moteurs de traitement de flux open source de l'industrie.

Flink fournit un traitement de données de pipeline à concurrence élevée, une latence de niveau milliseconde et une grande fiabilité, ce qui le rend approprié pour le traitement de données à faible latence.


Cette photo montre la pile technologique de Flink.

Flink


La liste suivante répertorie les principales fonctionnalités de Flink dans la version actuelle:

  • Flux de données

  • Point de contrôle

  • Fenêtre

  • Pipeline des travaux

  • Tableau de configuration

Pour plus de détails sur les autres fonctionnalités de Flink, voir https://ci.apache.org/projects/flink/flink-docs-stable/.


Architecture Flink:

architecture de Flink

  • Client

    Le client Flink est utilisé pour soumettre des travaux (travaux de streaming) à Flink.

  • Gestionnaire des tâches

    TaskManager (également appelé travailleur) est un nœud d'exécution de service de Flink. Il exécute des tâches spécifiques. Un système Flink peut avoir plusieurs TaskManagers. Ces TaskManagers sont équivalents les uns aux autres.

  • JobManager

    JobManager (également appelé maître) est un nœud de gestion de Flink. Il gère tous les TaskManagers et planifie les tâches soumises par les utilisateurs à des TaskManagers spécifiques. En mode haute disponibilité (HA), plusieurs JobManagers sont déployés. Parmi ces JobManagers, l'un est sélectionné comme leader et les autres sont en attente.

Flink offre les fonctionnalités suivantes:

  • Faible latence

    Capacité de traitement au niveau de la milliseconde.

  • Exactement une fois

    Mécanisme d'instantané asynchrone, garantissant que toutes les données ne sont traitées qu'une seule fois.

  • La haute disponibilité

    JobManagers Leader / Standby, empêchant le point de défaillance unique (SPOF).

  • Échelle

    Mise à l'échelle manuelle prise en charge par les gestionnaires de tâches.



Voir plus: https://forum.huawei.com/enterprise/en/online-courses-flink-application-development/thread/438885-899


  • x
  • Standard:

Commentaire

envoyer
Connectez-vous pour répondre. Se connecter | Enregistrer

Remarque Remarque : Afin de protéger vos droits et intérêts légitimes, ceux de la communauté et des tiers, ne divulguez aucun contenu qui pourrait présenter des risques juridiques pour toutes les parties. Le contenu interdit comprend, sans toutefois s'y limiter, le contenu politiquement sensible, le contenu lié à la pornographie, aux jeux d'argent, à l'abus et au trafic de drogues, le contenu qui peut divulguer ou enfreindre la propriété intellectuelle d'autrui, y compris les secrets professionnels, les marques commerciales, les droits d'auteur et les brevets, ainsi que la vie privée personnelle. Ne partagez pas votre nom d'utilisateur ou votre mot de passe avec d'autres personnes. Toutes les opérations effectuées à partir de votre compte seront considérées comme vos propres actions, et toutes les conséquences en découlant vous seront imputées. Pour plus de détails, voir « Politique de confidentialité ».
Si le bouton de la pièce-jointe n'est pas disponible, mettez à jour Adobe Flash Player à la dernière version.
Connectez-vous pour participer à la communication et au partage

Connectez-vous pour participer à la communication et au partage

S'identifier