CreateAsyncErrorChannel produces a channel for errors.

FormatMultiError formats multierrors for logging.

GetTrace produces the string representation of a stack trace.

KeyColumns is a shortcut for defining a KeyingOperation which uses multiple source column values to produce a compound key.

SafeFilterOperation wraps a FilterOperation such that panics are recovered and nice error messages are constructed.

SafeFlatMapOperation wraps a FlatMapOperation such that panics are recovered and nice error messages are constructed.

SafeKeyingOperation wraps a KeyingOperation such that panics are recovered and nice error messages are constructed.

SafeMapOperation wraps a MapOperation such that panics are recovered and nice error messages are constructed.

SafeReductionOperation wraps a ReductionOperation such that panics are recovered and nice error messages are constructed.

WaitAndFetchError attempts to fetch an error from an async goroutine.

SerializedPartitionDataType indicates that serialized partition data is being transferred.