Class NativeCollectorOnlyHandler<K,V>
java.lang.Object
org.apache.hadoop.mapred.nativetask.handlers.NativeCollectorOnlyHandler<K,V>
- All Implemented Interfaces:
Closeable,AutoCloseable,CommandDispatcher
@Private
public class NativeCollectorOnlyHandler<K,V>
extends Object
implements CommandDispatcher, Closeable
Java Record Reader + Java Mapper + Native Collector
-
Field Summary
Fields -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedNativeCollectorOnlyHandler(TaskContext context, INativeHandler nativeHandler, BufferPusher<K, V> kvPusher, ICombineHandler combiner) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()voidstatic <K,V> NativeCollectorOnlyHandler<K, V> create(TaskContext context) voidflush()onCall(Command command, ReadWriteBuffer parameter)
-
Field Details
-
NAME
- See Also:
-
GET_OUTPUT_PATH
-
GET_OUTPUT_INDEX_PATH
-
GET_SPILL_PATH
-
GET_COMBINE_HANDLER
-
-
Constructor Details
-
NativeCollectorOnlyHandler
protected NativeCollectorOnlyHandler(TaskContext context, INativeHandler nativeHandler, BufferPusher<K, V> kvPusher, ICombineHandler combiner) throws IOException- Throws:
IOException
-
-
Method Details
-
create
- Throws:
IOException
-
collect
- Throws:
IOException
-
flush
- Throws:
IOException
-
close
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Throws:
IOException
-
onCall
- Specified by:
onCallin interfaceCommandDispatcher- Throws:
IOException
-