org.apache.ignite.internal.processors.hadoop.shuffle.direct

Class HadoopDirectDataOutputContext

java.lang.Object

org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutputContext

public class HadoopDirectDataOutputContext
extends Object

Hadoop data output context for direct communication.

Constructor Summary

Constructors

Constructor and Description
HadoopDirectDataOutputContext(int flushSize, boolean gzip, HadoopTaskContext taskCtx) Constructor.

Method Summary

Modifier and Type	Method and Description
int	count()
void	reset() Reset buffer.
HadoopDirectDataOutputState	state()
boolean	write(Object key, Object val) Write key-value pair.

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopDirectDataOutputContext

public HadoopDirectDataOutputContext(int flushSize,
                                     boolean gzip,
                                     HadoopTaskContext taskCtx)
                              throws IgniteCheckedException

Constructor.

Parameters:

flushSize - Flush size.

gzip - Whether to perform GZIP.

taskCtx - Task context.

Throws:

IgniteCheckedException - If failed.

Method Detail

write

public boolean write(Object key,
                     Object val)
              throws IgniteCheckedException

Write key-value pair.

Parameters:

key - Key.

val - Value.

Returns:

Whether flush is needed.

Throws:

IgniteCheckedException - If failed.

count

public int count()

Returns:

Key-value pairs count.

state

public HadoopDirectDataOutputState state()

Returns:

State.

reset

public void reset()

Reset buffer.