org.apache.avro.mapred.tether

Interface OutputProtocol

All Known Subinterfaces:

OutputProtocol.Callback

public interface OutputProtocol

Transmit outputs from a map or reduce task to parent.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	OutputProtocol.Callback

Field Summary

Fields

Modifier and Type	Field and Description
static Protocol	PROTOCOL

Method Summary

Modifier and Type	Method and Description
void	complete() Transmit outputs from a map or reduce task to parent.
void	configure(int port) Transmit outputs from a map or reduce task to parent.
void	count(String group, String name, long amount) Transmit outputs from a map or reduce task to parent.
void	fail(String message) Transmit outputs from a map or reduce task to parent.
void	output(ByteBuffer datum) Transmit outputs from a map or reduce task to parent.
void	outputPartitioned(int partition, ByteBuffer datum) Transmit outputs from a map or reduce task to parent.
void	status(String message) Transmit outputs from a map or reduce task to parent.

Field Detail

PROTOCOL

static final Protocol PROTOCOL

Method Detail

configure

void configure(int port)

Transmit outputs from a map or reduce task to parent.

Parameters:

port - The port to transmit inputs to this task on.

output

void output(ByteBuffer datum)

Transmit outputs from a map or reduce task to parent.

Parameters:

datum - A binary-encoded instance of the declared schema.

outputPartitioned

void outputPartitioned(int partition,
                       ByteBuffer datum)

Transmit outputs from a map or reduce task to parent.

Parameters:

partition - The map output partition for this datum.

datum - A binary-encoded instance of the declared schema.

status

void status(String message)

Transmit outputs from a map or reduce task to parent.

Parameters:

message - The new status message for the task.

count

void count(String group,
           String name,
           long amount)

Transmit outputs from a map or reduce task to parent.

Parameters:

group - The name of the counter group.

name - The name of the counter to increment.

amount - The amount to incrment the counter.

fail

void fail(String message)

Transmit outputs from a map or reduce task to parent.

Parameters:

message - The new status message for the task.

complete

void complete()

Transmit outputs from a map or reduce task to parent.