org.apache.giraph.block_app.framework.output

Interface BlockOutputDesc<OW extends BlockOutputWriter>

Type Parameters:

OW - Writer type

public interface BlockOutputDesc<OW extends BlockOutputWriter>

Output description

Method Summary

Modifier and Type	Method and Description
void	commit() Commit everything
OW	createOutputWriter(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.util.Progressable hadoopProgressable) Create writer
void	initializeAndCheck(String jobIdentifier, org.apache.hadoop.conf.Configuration conf) Initialize output and perform any necessary checks
default void	postWriting() This method will be called after all writers are closed
default void	preWriting() This method will be called before creating any writers

Method Detail

initializeAndCheck

void initializeAndCheck(String jobIdentifier,
                        org.apache.hadoop.conf.Configuration conf)

Initialize output and perform any necessary checks

Parameters:

jobIdentifier - Unique identifier of the job

conf - Configuration

createOutputWriter

OW createOutputWriter(org.apache.hadoop.conf.Configuration conf,
                      org.apache.hadoop.util.Progressable hadoopProgressable)

Create writer

Parameters:

conf - Configuration

hadoopProgressable - Progressable to call progress on

Returns:

Writer

preWriting

default void preWriting()

This method will be called before creating any writers

postWriting

default void postWriting()

This method will be called after all writers are closed

commit

void commit()

Commit everything