org.apache.ignite.internal.processors.hadoop.impl.v1

Class HadoopV1OutputCollector

java.lang.Object

org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1OutputCollector

All Implemented Interfaces:

OutputCollector

public class HadoopV1OutputCollector
extends Object
implements OutputCollector

Hadoop output collector.

Method Summary

Modifier and Type	Method and Description
void	abort() Abort task.
void	closeWriter() Close writer.
void	collect(Object key, Object val)
void	commit() Commit task.
void	setup() Setup task.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

collect

public void collect(Object key,
                    Object val)
             throws IOException

Specified by:

collect in interface OutputCollector

Throws:

IOException

closeWriter

public void closeWriter()
                 throws IOException

Close writer.

Throws:

IOException - In case of IO exception.

setup

public void setup()
           throws IOException

Setup task.

Throws:

IOException - If failed.

commit

public void commit()
            throws IOException

Commit task.

Throws:

IOException - In failed.

abort

public void abort()

Abort task.