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.