org.apache.giraph.block_app.framework.output

Class BlockOutputHandle

java.lang.Object

org.apache.giraph.block_app.framework.output.BlockOutputHandle

All Implemented Interfaces:

BlockOutputApi

public class BlockOutputHandle
extends Object
implements BlockOutputApi

Handler for blocks output - keeps track of outputs and writers created

Constructor Summary

Constructors

Constructor and Description
BlockOutputHandle()
BlockOutputHandle(String jobIdentifier, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.util.Progressable hadoopProgressable)

Method Summary

Modifier and Type	Method and Description
void	closeAllWriters()
<OW extends BlockOutputWriter,OD extends BlockOutputDesc<OW>> OD	getOutputDesc(String confOption)
<OW extends BlockOutputWriter> OW	getWriter(String confOption)
void	initialize(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.util.Progressable progressable)
void	returnAllWriters()

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockOutputHandle

public BlockOutputHandle()

BlockOutputHandle

public BlockOutputHandle(String jobIdentifier,
                         org.apache.hadoop.conf.Configuration conf,
                         org.apache.hadoop.util.Progressable hadoopProgressable)

Method Detail

initialize

public void initialize(org.apache.hadoop.conf.Configuration conf,
                       org.apache.hadoop.util.Progressable progressable)

getOutputDesc

public <OW extends BlockOutputWriter,OD extends BlockOutputDesc<OW>> OD getOutputDesc(String confOption)

Specified by:

getOutputDesc in interface BlockOutputApi

getWriter

public <OW extends BlockOutputWriter> OW getWriter(String confOption)

Specified by:

getWriter in interface BlockOutputApi

returnAllWriters

public void returnAllWriters()

closeAllWriters

public void closeAllWriters()