See: Description
Interface | Description |
---|---|
CentralizedService<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Basic service interface shared by both
CentralizedServiceMaster and
CentralizedServiceWorker . |
CentralizedServiceMaster<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
At most, there will be one active master at a time, but many threads can
be trying to be the active master.
|
CentralizedServiceWorker<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
All workers should have access to this centralized service to
execute the following methods.
|
Class | Description |
---|---|
BspInputFormat |
This InputFormat supports the BSP model by ensuring that the user specifies
how many splits (number of mappers) should be started simultaneously.
|
BspInputSplit |
This InputSplit will not give any ordering or location data.
|
BspOutputFormat |
This is for internal use only.
|
BspRecordWriter |
Used by
BspOutputFormat since some versions of Hadoop
require that a RecordWriter is returned from getRecordWriter. |
BspService<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Zookeeper-based implementation of
CentralizedService . |
ImmutableOutputCommitter |
This output committer doesn't do anything, meant for the case
where output isn't desired, or as a base for not using
FileOutputCommitter.
|
Enum | Description |
---|---|
ApplicationState |
State of the BSP application
|
SuperstepState |
State of a coordinated superstep
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.