Obtener el nivel de una jerarquía

Tengo una matriz de objetos, donde cada objeto tiene 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 ...

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 ...

¿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. ...

número verilog de los que están en la matriz

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 ...

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 ...

¿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 ...

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