Lenguajes de programación de flujo de datos [cerrado]

¿Qué es un lenguaje de programación de flujo de datos? ¿Por qué usarlo? y hay algún beneficio para ello?

API de programación de flujo de datos para Java? [cerrado]

Estoy buscando un flujo de datos / API de programación concurrente para Java.Sé que hayDataRush, pero no es gratis. Lo que me interesa específicamente es el ...

Flujos de datos persistentes con dask

Estoy interesado en trabajar con flujos de datos distribuidos persistentes con características similares a las del proyecto Pegasus:https://pegasus.isi.edu/ [https://pegasus.isi.edu/]por ejemplo. ¿Crees que hay una manera de hacerlo ...

¿Cómo se puede crear un gráfico de flujo de datos (DFG / SDFG) para cualquier aplicación a partir de su código fuente?

He investigado mucho para descubrir cómo se puede crear un DFG para una aplicación a partir de su código fuente. Hay DFG disponibles en línea para ciertas aplicaciones, como MP3 Decoder, compresión JPEG y H.263 Decoder. No he podido averiguar ...

TPL Dataflow vs Semaphore simple

Tengo el requisito de hacer un proceso escalable. El proceso tiene principalmente operaciones de E / S con algunas operaciones menores de CPU (principalmente cadenas de deserialización). El proceso consulta la base de datos para obtener una ...

Cómo crear grupos de elementos N desde una PCollection Apache Beam Python

Estoy tratando de lograr algo como esto:Batch PCollection en Beam / Dataflow [https://stackoverflow.com/questions/44348085/batch-pcollection-in-beam-dataflow] La respuesta en el enlace anterior está en Java, mientras que el lenguaje con el que ...

¿Por qué los bloques se ejecutan en este orden?

Este es un ejemplo breve de código para presentarle rápidamente cuál es mi pregunta: using System; using System.Linq; using System.Threading.Tasks; using System.Threading.Tasks.Dataflow; namespace DataflowTest { class Program { static void ...

Propiedades de flujo de datos lento (como hoja de cálculo) con dependencias en Python

Mi problema es el siguiente: tengo algunas clases de python que tienen propiedades derivadas de otras propiedades; y esos deben almacenarse en caché una vez que se calculan, y los resultados almacenados en caché deben invalidarse cada vez que se ...

Confusión entre los programas del modelo de comportamiento y flujo de datos en VHDL

¿Se puede procesar la entrada del almacén de datos en la tubería de flujo de datos de Google en un lote de N entradas a la vez?

Estoy tratando de ejecutar un trabajo de canalización de flujo de datos que ejecutaría una función enN entradas a la vezdel almacén de datos. En mi caso, esta función está enviando un lote de 100 entradas a algún servicio REST como carga útil. ...