org.apache.tez.runtime.api

Interface MergedInputContext

@InterfaceAudience.Public
public interface MergedInputContext

Context for MergedLogicalInput This interface is not supposed to be implemented by users

Method Summary

Modifier and Type	Method and Description
UserPayload	getUserPayload() Get the user payload for this input
String[]	getWorkDirs() Get the work directories for the Input
void	inputIsReady() Inform the framework that the specific Input is ready for consumption.
void	notifyProgress() Inform the framework that progress has been made

Method Detail

getUserPayload

UserPayload getUserPayload()

Get the user payload for this input

Returns:

UserPayload

inputIsReady

void inputIsReady()

Inform the framework that the specific Input is ready for consumption. This method can be invoked multiple times.

notifyProgress

void notifyProgress()

Inform the framework that progress has been made

getWorkDirs

String[] getWorkDirs()

Get the work directories for the Input

Returns:

an array of work dirs