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 and Description
void	process(java.util.List<JobMessage> messages) Process the rows.

Method Detail

process

void process(java.util.List<JobMessage> messages)

Process the rows.