Releases: noleme/noleme-flow
Releases · noleme/noleme-flow
v0.18: typed Input flow arguments
- new
Key
construct for referencing a flow argument, they can be constructed through the newInput.key
method Key
instances hold type information and an automatically generated UID used for indexing within theInput
registerKey
instances can be initialized with a user-defined seed for their UID, allowing for reproducible instances and back-compat with the old string-based mechanism
v0.17: interrupt and interruptIf as part of the CurrentOut contract
- interrupt and interruptIf are now part of the CurrentOut contract
- added missing nonFatal helper for Loaders
v0.16: Generic error signatures for actors
- Actors no longer require specific exception signatures (eg.
TransformationException
,LoadingException
), they didn't provide anything of value as a requirement, this change enables much better integration with third-party functions - Node-specific exceptions will remain for the time being (BC + they can still handy as a default error type)
- Added an optional
Consumer
-based handler forFlow.nonFatal
helpers
v0.15: Flow: unified FlowOut API & slice feature for defining subgraphs
- Flow: unified the
Node
inbound/outbound API under the newCurrentOut
/CurrentIn
banner - Flow:
FlowOut
/FlowIn
interfaces for standard flows - Flow:
StreamOut
/StreamIn
interfaces for unbounded flows - Flow:
Slice
as a new feature for appending segments of graphs - Runtime: added start/end timestamps to the runtime
Output
v0.14.2: Heap: consumeAll now returns an empty list if nothing was found
Heap: consumeAll now returns an empty list if nothing was found
v0.14.1: Runtime: stream-related heap optimizations
Runtime: stream-related heap optimizations
v0.14: Node: new getName() and name(String) methods for nodes, allows better identification in traces and logs
Node: new getName() and name(String) methods for nodes, allows better…
v0.13.2: Doc: javadoc upddate
Doc: javadoc upddate
v0.13.1: ParallelRuntime: critical fix for a very rare stream race condition
ParallelRuntime: critical fix for a very rare stream race condition