Directories
¶
| Path | Synopsis |
|---|---|
|
Package funcx contains functions and types used to perform type analysis of Beam functions.
|
Package funcx contains functions and types used to perform type analysis of Beam functions. |
|
Package graph is the internal representation of the Beam execution plan.
|
Package graph is the internal representation of the Beam execution plan. |
|
coder
Package coder contains coder representation and utilities.
|
Package coder contains coder representation and utilities. |
|
mtime
Package mtime contains a millisecond representation of time.
|
Package mtime contains a millisecond representation of time. |
|
window
Package window contains window representation, windowing strategies and utilities.
|
Package window contains window representation, windowing strategies and utilities. |
|
Package metrics implements the Beam metrics API, described at http://s.apache.org/beam-metrics-api Metrics in the Beam model are uniquely identified by a namespace, a name, and the PTransform context in which they are used.
|
Package metrics implements the Beam metrics API, described at http://s.apache.org/beam-metrics-api Metrics in the Beam model are uniquely identified by a namespace, a name, and the PTransform context in which they are used. |
|
Package runtime contains runtime hooks and utilities for pipeline options and type registration.
|
Package runtime contains runtime hooks and utilities for pipeline options and type registration. |
|
coderx
Package coderx contains primitive coders.
|
Package coderx contains primitive coders. |
|
exec
Package exec contains runtime plan representation and execution.
|
Package exec contains runtime plan representation and execution. |
|
exec/optimized
Package optimized contains type-specialized shims for faster execution.
|
Package optimized contains type-specialized shims for faster execution. |
|
graphx
Package graphx provides facilities to help with the serialization of pipelines into a serializable graph structure suitable for the worker.
|
Package graphx provides facilities to help with the serialization of pipelines into a serializable graph structure suitable for the worker. |
|
graphx/v1
Package v1 is a generated protocol buffer package.
|
Package v1 is a generated protocol buffer package. |
|
harness
Package harness implements the SDK side of the Beam FnAPI.
|
Package harness implements the SDK side of the Beam FnAPI. |
|
harness/init
Package init contains the harness initialization code defined by the FnAPI.
|
Package init contains the harness initialization code defined by the FnAPI. |
|
harness/session
Package session is a generated protocol buffer package.
|
Package session is a generated protocol buffer package. |
|
Package typex contains full type representation and utilities for type checking.
|
Package typex contains full type representation and utilities for type checking. |
|
util
|
|
|
dot
Package dot produces DOT graphs from Beam graph representations.
|
Package dot produces DOT graphs from Beam graph representations. |
|
hooks
Package hooks allows runners to tailor execution of the worker harness.
|
Package hooks allows runners to tailor execution of the worker harness. |
|
ioutilx
Package ioutilx contains additional io utilities.
|
Package ioutilx contains additional io utilities. |
|
protox
Package protox contains utilities for working with protobufs.
|
Package protox contains utilities for working with protobufs. |
|
reflectx
Package reflectx contains a set of reflection utilities and well-known types.
|
Package reflectx contains a set of reflection utilities and well-known types. |
|
stringx
Package stringx contains utilities for working with strings.
|
Package stringx contains utilities for working with strings. |
|
symtab
Package symtab allows reading low-level symbol information from the symbol table.
|
Package symtab allows reading low-level symbol information from the symbol table. |
Click to show internal directories.
Click to hide internal directories.