org.apache.avro.mapred.tether
Interface OutputProtocol

All Known Subinterfaces:

OutputProtocol.Callback

public interface OutputProtocol

Nested Class Summary

static interface

OutputProtocol.Callback

Field Summary

static Protocol

PROTOCOL

Method Summary

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.