Data Processing Grouping with tuple deduplication Grouping with custom correlation Grouping with custom correlation and tuple deduplication Processing files without group processing (Variant A) Processing files with file content based group processing (Variant B) Processing files with file name based group processing (Variant C) Enabling data enrichment Using checkpointing for custom logic Cleaning up data Tapping internal data streams Rejecting tuples by using your own implementation