README
¶
experimental
Code for talks, or other personal uses. No guarantees on any of it.
Directories
¶
| Path | Synopsis |
|---|---|
|
altbeams
|
|
|
allinone
package allinone is an experimental mockup of an Apache Beam Go SDK API that leverages generics, and a more opinionated construction method.
|
package allinone is an experimental mockup of an Apache Beam Go SDK API that leverages generics, and a more opinionated construction method. |
|
allinone/beam
Package beam is an experimental mockup of an Apache Beam Go SDK API that leverages generics, and a more opinionated construction method.
|
Package beam is an experimental mockup of an Apache Beam Go SDK API that leverages generics, and a more opinionated construction method. |
|
allinone2
package allinone is an experimental mockup of an Apache Beam Go SDK API that leverages generics, and a more opinionated construction method.
|
package allinone is an experimental mockup of an Apache Beam Go SDK API that leverages generics, and a more opinionated construction method. |
|
allinone2/beam
Package beam is an experimental mockup of an Apache Beam Go SDK API that leverages generics, and a more opinionated construction method.
|
Package beam is an experimental mockup of an Apache Beam Go SDK API that leverages generics, and a more opinionated construction method. |
|
allinone2/beam/internal/extworker
Package extworker provides an external worker service and related utilities.
|
Package extworker provides an external worker service and related utilities. |
|
allinone2/beam/internal/pipelinex
Package pipelinex contains utilities for manipulating Beam proto pipelines.
|
Package pipelinex contains utilities for manipulating Beam proto pipelines. |
|
lifecycle/beam
Package beam is an experimental mockup of an Apache Beam Go SDK API that leverages generics, and a more opinionated construction method.
|
Package beam is an experimental mockup of an Apache Beam Go SDK API that leverages generics, and a more opinionated construction method. |
|
gbrt is initially a quick re-write of the postcard pathtracer from c++ to Go, without the minification, as described at http://fabiensanglard.net/postcard_pathtracer/index.html
|
gbrt is initially a quick re-write of the postcard pathtracer from c++ to Go, without the minification, as described at http://fabiensanglard.net/postcard_pathtracer/index.html |
|
lib
Package grbt contains code for a ray tracer in beam.
|
Package grbt contains code for a ray tracer in beam. |
|
Package local contains the local runner for running pipelines in the current process.
|
Package local contains the local runner for running pipelines in the current process. |
|
internal/config
Package config defines and handles the parsing and provision of configurations for the runner.
|
Package config defines and handles the parsing and provision of configurations for the runner. |
|
internal/engine
Package engine handles the operational components of a runner, to track elements, watermarks, timers, triggers etc
|
Package engine handles the operational components of a runner, to track elements, watermarks, timers, triggers etc |
|
internal/jobservices
Package jobservices handles services necessary WRT handling jobs from SDKs.
|
Package jobservices handles services necessary WRT handling jobs from SDKs. |
|
internal/urns
Package urn handles extracting urns from all the protos.
|
Package urn handles extracting urns from all the protos. |
|
internal/worker
Package worker handles interactions with SDK side workers, representing the worker services, communicating with those services, and SDK environments.
|
Package worker handles interactions with SDK side workers, representing the worker services, communicating with those services, and SDK environments. |
|
talks
|
|
|
retrospective
Package retrospective contains sample code and benchmarks borrowed librally from the beam exec package benchmarks.
|
Package retrospective contains sample code and benchmarks borrowed librally from the beam exec package benchmarks. |
Click to show internal directories.
Click to hide internal directories.