Package org.apache.beam.runners.dataflow.util

Interface MonitoringUtil.JobMessagesHandler

All Known Implementing Classes:
MonitoringUtil.LoggingHandler
Enclosing class:
MonitoringUtil
public static interface MonitoringUtil.JobMessagesHandler
An interface that can be used for defining callbacks to receive a list of JobMessages containing monitoring information.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    process(List<JobMessage> messages)
    Process the rows.

  • Method Details