Interface NonPartitionedContext<OUT>

    • Method Detail

      • applyToAllPartitions

        void applyToAllPartitions​(ApplyPartitionFunction<OUT> applyPartitionFunction)
                           throws Exception
        Apply a function to all partitions. For keyed stream, it will apply to all keys. For non-keyed stream, it will apply to single partition.
        Throws:
        Exception