org.apache.ignite.internal.processors.hadoop

Interface HadoopMapperAwareTaskOutput

All Superinterfaces:

AutoCloseable, HadoopTaskOutput

public interface HadoopMapperAwareTaskOutput
extends HadoopTaskOutput

Special output type with callback invoked when mapper finished writing data.

Method Summary

Modifier and Type	Method and Description
void	onMapperFinished() Callback invoked when mapper finished writing data.

Methods inherited from interface org.apache.ignite.internal.processors.hadoop.HadoopTaskOutput

close, write

Method Detail

onMapperFinished

void onMapperFinished()
               throws IgniteCheckedException

Callback invoked when mapper finished writing data.

Throws:

IgniteCheckedException - If failed.