org.apache.avro.mapred.tether

Interface InputProtocol

All Known Subinterfaces:

InputProtocol.Callback

public interface InputProtocol

Transmit inputs to a map or reduce task sub-process.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	InputProtocol.Callback

Field Summary

Fields

Modifier and Type	Field and Description
static Protocol	PROTOCOL

Method Summary

Modifier and Type	Method and Description
void	abort() Transmit inputs to a map or reduce task sub-process.
void	complete() Transmit inputs to a map or reduce task sub-process.
void	configure(TaskType taskType, String inSchema, String outSchema) Transmit inputs to a map or reduce task sub-process.
void	input(ByteBuffer data, long count) Transmit inputs to a map or reduce task sub-process.
void	partitions(int partitions) Transmit inputs to a map or reduce task sub-process.

Field Detail

PROTOCOL

static final Protocol PROTOCOL

Method Detail

configure

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

Transmit inputs to a map or reduce task sub-process.

Parameters:

taskType - Whether this is a map or reduce task.

inSchema - The Avro schema for task input data.

outSchema - The Avro schema for task output data.

partitions

void partitions(int partitions)

Transmit inputs to a map or reduce task sub-process.

Parameters:

partitions - The number of map output partitions.

input

void input(ByteBuffer data,
           long count)

Transmit inputs to a map or reduce task sub-process.

Parameters:

data - A sequence of instances of the declared schema.

count - The number of instances in this block.

abort

void abort()

Transmit inputs to a map or reduce task sub-process.

complete

void complete()

Transmit inputs to a map or reduce task sub-process.