The Wayback Machine - https://web.archive.org/web/20210929035748/https://github.com/topics/beam
Skip to content
#

beam

Here are 246 public repositories matching this topic...

jto
jto commented Mar 25, 2021

The problem

The current implementation of processElement

  1. Check if cache existence for input
  2. If the cache returns value return it
  3. otherwise, aquire a semaphore
  4. call asyncLookup and pass it input. It return a future: F
  5. Maintain a list of the currently executing futures
  6. release a semaphore at the end each future execution
  7. make sure all the future are com

Improve this page

Add a description, image, and links to the beam topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the beam topic, visit your repo's landing page and select "manage topics."

Learn more