com.scaleoutsoftware.soss.hserver.interop

Class PartitionWriters<K,V>

java.lang.Object

com.scaleoutsoftware.soss.hserver.interop.PartitionWriters<K,V>

Type Parameters:

K - key type

V - value type

public class PartitionWriters<K,V>
extends Object

A set of DataGridChunkedCollectionWriters used to save the mapper output.

Constructor Summary

Constructors

Constructor and Description
PartitionWriters(RunMapContext<K,V> runMapperContext) Creates the transport pool.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the transport pool and all associated data transports.
DataGridChunkedCollectionWriter<K,V>	getGridWriter(DataGridWriterParameters<K,V> params) Gets the DataGridChunkedCollectionWriter for the partition, creating one if necessary.

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionWriters

public PartitionWriters(RunMapContext<K,V> runMapperContext)
                 throws NoSuchMethodException

Creates the transport pool.

Parameters:

runMapperContext - mapper context containing job information

Throws:

NoSuchMethodException - if the method doesn't exist

Method Detail

getGridWriter

public DataGridChunkedCollectionWriter<K,V> getGridWriter(DataGridWriterParameters<K,V> params)
                                                   throws IOException

Gets the DataGridChunkedCollectionWriter for the partition, creating one if necessary.

Parameters:

params - configuration parameters for a DataGridChunkedCollectionWriter

Returns:

data transport

Throws:

IOException - If there was an error while communicating with ScaleOut StateServer

close

public void close()
           throws IOException

Closes the transport pool and all associated data transports.

Throws:

IOException - If there was an error while communicating with ScaleOut StateServer