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.