public interface InputProtocol
Modifier and Type | Interface and Description |
---|---|
static interface |
InputProtocol.Callback |
Modifier and Type | Method and Description |
---|---|
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.
|
static final Protocol PROTOCOL
void configure(TaskType taskType, String inSchema, String outSchema)
void partitions(int partitions)
void input(ByteBuffer data, long count)
void abort()
void complete()
Copyright © 2009-2014 The Apache Software Foundation. All Rights Reserved.