org.apache.avro.mapred.tether
Interface InputProtocol

All Known Subinterfaces:

InputProtocol.Callback

public interface InputProtocol

Nested Class Summary

static interface

InputProtocol.Callback

Field Summary

static Protocol

PROTOCOL

Method Summary

void	abort() Called to abort the task.
void	complete() Called when a task's input is complete.
void	configure(TaskType taskType, String inSchema, String outSchema) Configure the task.
void	input(ByteBuffer data, long count) Send a block of input data to a task.
void	partitions(int partitions) Set the number of map output partitions.

Field Detail

PROTOCOL

static final Protocol PROTOCOL

Method Detail

configure

void configure(TaskType taskType,
               String inSchema,
               String outSchema)

Configure the task. Sent before any other message.

partitions

void partitions(int partitions)

Set the number of map output partitions.

input

void input(ByteBuffer data,
           long count)

Send a block of input data to a task.

abort

void abort()

Called to abort the task.

complete

void complete()

Called when a task's input is complete.