Am implementat un operator pentru a deserializa de la avro byte[] la Object. După aceea am trimis obiectul la ConsoleOutputOperator. public final transient DefaultInputPort<byte[]> input = new DefaultInputPort<byte[]>() {...

Am o aplicație Apache Apex DAG care citește mesajul RabbitMQ dintr-o coadă. Ce operator Apache Apex Malhar ar trebui să folosesc? Există mai mulți operatori, dar nu este clar pe care să folosești și cum să-l folosești.

Oh, și dacă acest lucru se face pe un thread de fundal (cu excepția actualizării interfeței noastre de utilizare) am un întârziere urât când tast...

Este posibil să adăugați operator de intrare pentru surse diferite în aplicația Apex care rulează? De exemplu: Într-un mediu de producție, rulez o aplicație Apex pentru a citi fișierul text din sursa de intrare și vreau să adaug sursa Kafka cu...