hazelcast-jet

0La chaleur

1Répondre

Ajouter du code avec AddJar() lors de l'utilisation de l'API des flux?

Comment puis-je utiliser la méthode addJar() lorsque j'implémente un flux? Le newJob() utilise un DAG: JobConfig config = new JobConfig(); config.addJar(".."); jet.newJob(dag, config).execute().get(

0La chaleur

2Répondre

Comment formuler un sommet élégant pour Hazelcast Jet pour obtenir le minimum?

J'essaie d'envelopper ma tête autour de l'utilisation de bifonctions dans le processeur d'accumulation de jets de Hazelcast. La première tentative est une comparaison minime simple, mais ce que j'ai t

0La chaleur

1Répondre

Comment obtenir un simple DAG pour travailler dans Hazelcast Jet?

Pendant que je travaillais sur mon DAG dans Jet Noisette, je suis tombé sur un problème étrange. Pour vérifier l'erreur, j'ai descendu mon approche complètement et: il semble que les bords ne fonction

2La chaleur

1Répondre

`` processeurs 'coopératifs et non coopératifs dans un seul sommet

Est-ce que Processor peut être à la fois coopératif et non coopératif dans un seul sommet? Parce que la coopérativité est une propriété de Processor, et le ProcessorSupplier n'est pas nécessaire pour

0La chaleur

1Répondre

Comment ouvrir une socket tcp et traiter les informations continues obtenues à travers elle dans Hazelcast Jet

J'essaie d'analyser les données de capteur en utilisant Hazelcast jet.Pour cela, j'ai besoin d'ouvrir une socket Tcp et traiter les informations obtenues à travers elle.

1La chaleur

1Répondre

Utilisez Hazelcast IMap à Hazelcast Jet Processor

Je commence tout juste à apprendre le Hazelcast Jet. Ma source est des datagrammes UDP. Je veux le traiter en parallèle à certains nœuds de Jet et les renvoyer à d'autres adresses par 'domaine'. Je ve

2La chaleur

1Répondre

Comment obtenir un emploi au nouveau nœud du cluster Jet Hazelcast

Quelqu'un peut-il dire comment une nouvelle instance de cluster Jet devrait commencer à travailler? Cas d'utilisation 1: début cluster de jet par 3 noeud soumettre le job à regrouper les 3 noeuds de d