org.apache.avro.mapred.tether

Interface OutputProtocol

All Known Subinterfaces:

OutputProtocol.Callback

public interface OutputProtocol

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

Methods

Modifier and Type	Method and Description
void	complete() Called when a task's output has completed without error.
void	configure(int port) Configure task.
void	count(String group, String name, long amount) Increment a task/job counter.
void	fail(String message) Called by a failing task to abort.
void	output(ByteBuffer datum) Send an output datum.
void	outputPartitioned(int partition, ByteBuffer datum) Send map output datum explicitly naming its partition.
void	status(String message) Update the task's status message.

Field Detail

PROTOCOL

static final Protocol PROTOCOL

Method Detail

configure

void configure(int port)

Configure task. Sent before any other message.

output

void output(ByteBuffer datum)

Send an output datum.

outputPartitioned

void outputPartitioned(int partition,
                     ByteBuffer datum)

Send map output datum explicitly naming its partition.

status

void status(String message)

Update the task's status message. Also acts as keepalive.

count

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

Increment a task/job counter.

fail

void fail(String message)

Called by a failing task to abort.

complete

void complete()

Called when a task's output has completed without error.