com.scaleoutsoftware.soss.hserver.interop

Class DataGridChunkedCollectionWriter<K,V>

java.lang.Object

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

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

Type Parameters:

K - key type

V - value type

All Implemented Interfaces:

Closeable, AutoCloseable

public class DataGridChunkedCollectionWriter<K,V>
extends ChunkedCollectionWriter<K,V>

A ChunkedCollectionWriter implementation used by a mapper to output chunks of key-value pairs.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the chunk writer.
static DataGridChunkedCollectionWriter	getGridWriter(DataGridWriterParameters params) Instantiates a grid writer with the specified DataGridWriterParameters.

Methods inherited from class com.scaleoutsoftware.soss.hserver.interop.ChunkedCollectionWriter

cleanup, getNumberOfChunks, put

Methods inherited from class java.lang.Object

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

Method Detail

close

public void close()
           throws IOException

Description copied from class: ChunkedCollectionWriter

Closes the chunk writer. This will cause the assembling chunk to be written to the distributed in-memory data grid. This method will block until all writes are complete.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class ChunkedCollectionWriter<K,V>

Throws:

IOException - if an error occurred while writing chunks out

getGridWriter

public static DataGridChunkedCollectionWriter getGridWriter(DataGridWriterParameters params)
                                                     throws IOException

Instantiates a grid writer with the specified DataGridWriterParameters.

Parameters:

params - parameters for this data grid writer

Returns:

a DataGridChunkedCollectionWriter

Throws:

IOException - If an error occurred while creating the writer