Skip to content

Singular() method to force operation to be not partitioned #97

@asubb

Description

@asubb

Sometimes it is really needed to have a stateful map (or any other) operation, in this case, it can't be partitioned (automatically), and needed to be marked as SinglePartitionBean. Right now you may use flatMap() returning singleton list, but that way is hacky and non-consistent.

Proposed signature:

stream.map { }.singular()

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions