Package | Description |
---|---|
org.apache.hadoop.security.token.delegation | |
org.apache.hadoop.metrics.util | |
org.apache.hadoop.fs.local | |
org.apache.hadoop.http | |
org.apache.hadoop.yarn.factories | |
org.apache.hadoop.security.token | |
org.apache.hadoop.yarn.webapp.view | |
org.apache.hadoop.yarn.webapp.example | |
org.apache.hadoop.yarn.webapp | |
org.apache.hadoop.io.retry |
A mechanism for selectively retrying methods that throw exceptions under certain circumstances.
|
org.apache.hadoop.yarn.factory.providers | |
org.apache.hadoop.yarn.webapp.hamlet | |
org.apache.hadoop.yarn.ipc | |
org.apache.hadoop.yarn.webapp.log | |
org.apache.hadoop.classification.tools | |
org.apache.hadoop.ipc |
Tools to help define network clients and servers.
|
org.apache.hadoop.security.authorize |
Modifier and Type | Class and Description |
---|---|
class |
ConfServlet
A servlet to print out the running configuration data.
|
Modifier and Type | Class and Description |
---|---|
class |
DF
Filesystem disk space usage statistics.
|
class |
DU
Filesystem disk space usage statistics.
|
class |
FSInputChecker
This is a generic input stream for verifying checksums for
data before it is read by a user.
|
class |
FSInputStream
FSInputStream is a generic old InputStream with a little bit
of RAF-style seek ability.
|
class |
FSOutputSummer
This is a generic output stream for generating checksums for
data before it is written to the underlying stream
|
class |
LocalDirAllocator
An implementation of a round-robin scheme for disk allocation for creating
files.
|
class |
MD5MD5CRC32FileChecksum
MD5 of MD5 of CRC32.
|
class |
UnresolvedLinkException
Thrown when a symbolic link is encountered in a path.
|
Modifier and Type | Method and Description |
---|---|
Token<?>[] |
FileSystem.addDelegationTokens(String renewer,
Credentials credentials)
Obtain all delegation tokens used by this FileSystem that are not
already present in the given Credentials.
|
String |
FileSystem.getCanonicalServiceName()
Get a canonical service name for this file system.
|
FileSystem[] |
FileSystem.getChildFileSystems()
Get all the immediate child FileSystems embedded in this FileSystem.
|
List<Token<?>> |
FileContext.getDelegationTokens(Path p,
String renewer)
Get delegation tokens for the file systems accessed for a given
path.
|
List<Token<?>> |
AbstractFileSystem.getDelegationTokens(String renewer)
Get one or more delegation tokens associated with the filesystem.
|
BlockLocation[] |
FileContext.getFileBlockLocations(Path f,
long start,
long len)
Return blockLocation of the given file for the given offset and len.
|
OutputStream |
FSDataOutputStream.getWrappedStream()
Get a reference to the wrapped output stream.
|
InputStream |
FSDataInputStream.getWrappedStream()
Get a reference to the wrapped input stream.
|
Path |
Path.makeQualified(URI defaultUri,
Path workingDir)
Returns a qualified path object.
|
static void |
LocalDirAllocator.removeContext(String contextCfgItemName)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
FsAction
File system actions, e.g.
|
class |
PermissionStatus
Store permission related information.
|
Modifier and Type | Class and Description |
---|---|
class |
ZKFailoverController |
class |
ZKFCRpcServer |
Modifier and Type | Class and Description |
---|---|
class |
DistributedFileSystem
Implementation of the abstract FileSystem for the DFS system.
|
Modifier and Type | Method and Description |
---|---|
String |
DFSClient.getCanonicalServiceName()
Get a canonical token service name for this client's tokens.
|
Modifier and Type | Class and Description |
---|---|
static class |
DataNode.ShortCircuitFdsUnsupportedException |
static class |
DataNode.ShortCircuitFdsVersionException |
Modifier and Type | Class and Description |
---|---|
class |
URLUtils
Utilities for handling URLs
|
Modifier and Type | Class and Description |
---|---|
class |
HttpServer
Create a Jetty embedded server to answer http requests.
|
Modifier and Type | Class and Description |
---|---|
class |
BoundedByteArrayOutputStream
A byte array backed output stream with a limit.
|
class |
DataInputBuffer
A reusable
DataInput implementation that reads from an in-memory
buffer. |
class |
DataOutputBuffer
A reusable
DataOutput implementation that writes to an in-memory
buffer. |
class |
InputBuffer
A reusable
InputStream implementation that reads from an in-memory
buffer. |
class |
OutputBuffer
A reusable
OutputStream implementation that writes to an in-memory
buffer. |
class |
UTF8
Deprecated.
replaced by Text
|
Modifier and Type | Interface and Description |
---|---|
interface |
Deserializer<T>
Provides a facility for deserializing objects of type
InputStream . |
class |
DeserializerComparator<T>
A
RawComparator that uses a Deserializer to deserialize
the objects to be compared so that the standard Comparator can
be used to compare them. |
interface |
Serialization<T>
Encapsulates a
Serializer /Deserializer pair. |
class |
SerializationFactory
A factory for
Serialization s. |
interface |
Serializer<T>
Provides a facility for serializing objects of type
OutputStream . |
Modifier and Type | Class and Description |
---|---|
static class |
Client.ConnectionId
This class holds the address and the user ticket.
|
class |
ClientCache |
static class |
ProtobufRpcEngine.RpcRequestMessageWrapper |
static class |
ProtobufRpcEngine.RpcResponseMessageWrapper |
static class |
ProtobufRpcEngine.RpcResponseWrapper
Wrapper for Protocol Buffer Responses
Note while this wrapper is writable, the request on the wire is in
Protobuf.
|
Modifier and Type | Method and Description |
---|---|
ServiceAuthorizationManager |
Server.getServiceAuthorizationManager()
Returns a handle to the serviceAuthorizationManager (required in tests)
|
Modifier and Type | Class and Description |
---|---|
static class |
LogLevel.Servlet
A servlet implementation
|
Modifier and Type | Class and Description |
---|---|
class |
IndexRecord |
class |
JobProfile
A JobProfile is a MapReduce primitive.
|
class |
LineRecordReader
Treats keys as offset in file and value as line.
|
interface |
MapOutputCollector<K,V> |
static class |
MapOutputCollector.Context |
class |
MapTask
A Map task.
|
static class |
MapTask.MapOutputBuffer<K,V> |
interface |
ShuffleConsumerPlugin<K,V>
ShuffleConsumerPlugin for serving Reducers.
|
static class |
ShuffleConsumerPlugin.Context<K,V> |
class |
SpillRecord |
class |
Task
Base class for tasks.
|
static class |
Task.CombinerRunner<K,V> |
class |
Task.TaskReporter |
Modifier and Type | Class and Description |
---|---|
class |
LineRecordReader
Treats keys as offset in file and value as line.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ExceptionReporter
An interface for reporting exceptions to other threads
|
class |
MapHost |
class |
MapOutput<K,V> |
class |
MergeManagerImpl<K,V> |
class |
Shuffle<K,V> |
class |
ShuffleClientMetrics |
Modifier and Type | Class and Description |
---|---|
class |
ClusterInfo |
Modifier and Type | Class and Description |
---|---|
class |
ContextFactory
Factory class for creating MetricsContext objects.
|
class |
MetricsException
General-purpose, unchecked metrics exception.
|
class |
MetricsUtil
Utility class to simplify creation and reporting of hadoop metrics.
|
interface |
Updater
Call-back interface.
|
Modifier and Type | Class and Description |
---|---|
class |
MBeanUtil
This util class provides a method to register an MBean using
our standard naming convention as described in the doc
for {link
MBeanUtil.registerMBean(String, String, Object) |
class |
MetricsDynamicMBeanBase
This abstract base class facilitates creating dynamic mbeans automatically from
metrics.
|
class |
MetricsIntValue
The MetricsIntValue class is for a metric that is not time varied
but changes only when it is set.
|
class |
MetricsLongValue
The MetricsLongValue class is for a metric that is not time varied
but changes only when it is set.
|
class |
MetricsRegistry
This is the registry for metrics.
|
class |
MetricsTimeVaryingInt
The MetricsTimeVaryingInt class is for a metric that naturally
varies over time (e.g.
|
class |
MetricsTimeVaryingLong
The MetricsTimeVaryingLong class is for a metric that naturally
varies over time (e.g.
|
class |
MetricsTimeVaryingRate
The MetricsTimeVaryingRate class is for a rate based metric that
naturally varies over time (e.g.
|
Modifier and Type | Class and Description |
---|---|
class |
DNS
A class that provides direct and reverse lookup functionalities, allowing
the querying of specific network interfaces or nameservers.
|
class |
NetUtils |
class |
NetworkTopology
The class represents a cluster of computer with a tree hierarchical
network topology.
|
class |
NetworkTopologyWithNodeGroup
The class extends NetworkTopology to represents a cluster of computer with
a 4-layers hierarchical network topology.
|
interface |
Node
The interface defines a node in a network topology.
|
class |
NodeBase
A base class that implements interface Node
|
class |
SocketInputStream
This implements an input stream that can have a timeout while reading.
|
class |
SocketInputWrapper
A wrapper stream around a socket which allows setting of its timeout.
|
class |
SocketOutputStream
This implements an output stream that can have a timeout while writing.
|
Modifier and Type | Class and Description |
---|---|
class |
DomainSocket
The implementation of UNIX domain sockets in Java.
|
class |
DomainSocket.DomainChannel |
class |
DomainSocket.DomainInputStream
Input stream for UNIX domain sockets.
|
class |
DomainSocket.DomainOutputStream
Output stream for UNIX domain sockets.
|
Modifier and Type | Class and Description |
---|---|
class |
AccessControlException
An exception class for access control related issues.
|
class |
Credentials
A class that provides the facilities of reading and writing
secret keys and Tokens.
|
class |
Groups
A user-to-groups mapping service.
|
class |
HadoopKerberosName
This class implements parsing and handling of Kerberos principal names.
|
class |
JniBasedUnixGroupsMapping
A JNI-based implementation of
GroupMappingServiceProvider
that invokes libC calls to get the group
memberships of a given user. |
class |
JniBasedUnixGroupsNetgroupMapping
A JNI-based implementation of
GroupMappingServiceProvider
that invokes libC calls to get the group
memberships of a given user. |
interface |
KerberosInfo
Indicates Kerberos related information to be used
|
class |
LdapGroupsMapping
An implementation of
GroupMappingServiceProvider which
connects directly to an LDAP server for determining group membership. |
class |
NetgroupCache
Class that caches the netgroups and inverts group-to-user map
to user-to-group map, primarily intented for use with
netgroups (as returned by getent netgrgoup) which only returns
group to user mapping.
|
interface |
RefreshUserMappingsProtocol
Protocol use
|
class |
SaslInputStream
A SaslInputStream is composed of an InputStream and a SaslServer (or
SaslClient) so that read() methods return data that are read in from the
underlying InputStream but have been additionally processed by the SaslServer
(or SaslClient) object.
|
class |
SaslOutputStream
A SaslOutputStream is composed of an OutputStream and a SaslServer (or
SaslClient) so that write() methods first process the data before writing
them out to the underlying OutputStream.
|
class |
SaslRpcClient
A utility class that encapsulates SASL logic for RPC client
|
class |
SaslRpcServer
A utility class for dealing with SASL on RPC server
|
class |
SecurityInfo |
class |
SecurityUtil |
class |
ShellBasedUnixGroupsMapping
A simple shell-based implementation of
GroupMappingServiceProvider
that exec's the groups shell command to fetch the group
memberships of a given user. |
class |
ShellBasedUnixGroupsNetgroupMapping
A simple shell-based implementation of
GroupMappingServiceProvider
that exec's the groups shell command to fetch the group
memberships of a given user. |
class |
UserGroupInformation
User and group information for Hadoop.
|
Modifier and Type | Class and Description |
---|---|
class |
KerberosName
This class implements parsing and handling of Kerberos principal names.
|
Modifier and Type | Class and Description |
---|---|
class |
AccessControlList
Class representing a configured access control list.
|
class |
AuthorizationException
An exception class for authorization-related issues.
|
class |
PolicyProvider
|
interface |
RefreshAuthorizationPolicyProtocol
Protocol which is used to refresh the authorization policy in use currently.
|
class |
Service
An abstract definition of service as related to
Service Level Authorization for Hadoop.
|
class |
ServiceAuthorizationManager
An authorization manager which handles service-level authorization
for incoming service requests.
|
Modifier and Type | Interface and Description |
---|---|
interface |
RefreshAuthorizationPolicyProtocolPB |
interface |
RefreshUserMappingsProtocolPB |
Modifier and Type | Class and Description |
---|---|
class |
SecretManager<T extends TokenIdentifier>
The server-side secret manager for each token type.
|
class |
Token<T extends TokenIdentifier>
The client-side form of the token.
|
static class |
Token.TrivialRenewer
A trivial renewer for token kinds that aren't managed.
|
class |
TokenIdentifier
An identifier that identifies a token, may contain public information
about a token, including its kind (or type).
|
interface |
TokenInfo
Indicates Token related information to be used
|
class |
TokenRenewer
This is the interface for plugins that handle tokens.
|
interface |
TokenSelector<T extends TokenIdentifier>
Select token of type T from tokens for use with named service
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDelegationTokenIdentifier |
class |
AbstractDelegationTokenSecretManager<TokenIdent extends AbstractDelegationTokenIdentifier> |
class |
AbstractDelegationTokenSelector<TokenIdent extends AbstractDelegationTokenIdentifier>
Look through tokens to find the first delegation token that matches the
service and return it.
|
class |
DelegationKey
Key used for generating and verifying delegation tokens
|
Modifier and Type | Interface and Description |
---|---|
interface |
GetUserMappingsProtocol
Protocol implemented by the Name Node and Job Tracker which maps users to
groups.
|
Modifier and Type | Interface and Description |
---|---|
interface |
GetUserMappingsProtocolPB |
Modifier and Type | Class and Description |
---|---|
class |
AsyncDiskService |
class |
Daemon
A thread that has called
Thread.setDaemon(boolean) with true. |
static class |
Daemon.DaemonFactory
Provide a factory for named daemon threads,
for use in ExecutorServices constructors
|
class |
DataChecksum
This class provides inteface and utilities for processing checksums for
DFS data transfers.
|
class |
ExitUtil
Facilitates hooking process termination for tests and debugging.
|
class |
HostsFileReader |
interface |
IndexedSortable
Interface for collections capable of being sorted by
IndexedSorter
algorithms. |
interface |
IndexedSorter
Interface for sort algorithms accepting
IndexedSortable items. |
class |
LineReader
A class that provides a line reader from an input stream.
|
class |
MergeSort
An implementation of the core algorithm of MergeSort.
|
class |
PlatformName
A helper class for getting build-info of the java-vm.
|
class |
ProgramDriver
A driver that is used to run programs added to it
|
class |
Progress
Utility to assist with generation of progress reports.
|
class |
Shell
A base class for running a Unix command.
|
class |
Time
Utility methods for getting the time and computing intervals.
|
Modifier and Type | Class and Description |
---|---|
class |
Filter
Defines the general behavior of a filter.
|
class |
Key
The general behavior of a key that must be stored in a filter.
|
Modifier and Type | Method and Description |
---|---|
abstract boolean |
ApplicationSubmissionContext.getCancelTokensWhenComplete() |
abstract void |
ApplicationSubmissionContext.setCancelTokensWhenComplete(boolean cancel)
Set to false if tokens should not be canceled when the app finished else
false.
|
Modifier and Type | Class and Description |
---|---|
class |
ContainerManagementProtocolProxy
Helper class to manage container manager proxies
|
Modifier and Type | Class and Description |
---|---|
class |
YarnRuntimeException
Base Yarn Exception.
|
Modifier and Type | Interface and Description |
---|---|
interface |
RecordFactory |
interface |
RpcClientFactory |
interface |
RpcServerFactory |
Modifier and Type | Class and Description |
---|---|
class |
RecordFactoryProvider |
class |
RpcFactoryProvider
A public static get() method must be present in the Client/Server Factory implementation.
|
Modifier and Type | Class and Description |
---|---|
class |
HadoopYarnProtoRPC
This uses Hadoop RPC.
|
class |
RPCUtil |
class |
YarnRPC
Abstraction to get the RPC implementation for Yarn.
|
Modifier and Type | Method and Description |
---|---|
SecretKey |
RMAppAttempt.getClientTokenMasterKey()
The master key for client-to-AM tokens for this app attempt.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Queue |
interface |
ResourceScheduler
This interface is the one implemented by the schedulers.
|
class |
SchedulerAppReport
Represents an application attempt, and the resources that the attempt is
using.
|
Modifier and Type | Method and Description |
---|---|
SchedulerNodeReport |
YarnScheduler.getNodeReport(NodeId nodeId)
Get node resource usage report.
|
QueueMetrics |
YarnScheduler.getRootQueueMetrics()
Get the root queue for the scheduler.
|
SchedulerAppReport |
YarnScheduler.getSchedulerAppInfo(ApplicationAttemptId appAttemptId)
Get the Scheduler app for a given app attempt Id.
|
Modifier and Type | Class and Description |
---|---|
class |
CapacityScheduler |
Modifier and Type | Class and Description |
---|---|
class |
FairScheduler
A scheduler that schedules resources between a set of queues.
|
Modifier and Type | Class and Description |
---|---|
class |
FifoScheduler |
Modifier and Type | Class and Description |
---|---|
class |
FSDownload
Download a single URL to the local disk.
|
class |
RackResolver |
class |
Records
Convenient API record utils
|
class |
ResourceCalculatorPlugin
Plugin to calculate resource information on the system.
|
class |
TrackingUriPlugin
Plugin to derive a tracking URL from a Yarn Application ID
|
Modifier and Type | Class and Description |
---|---|
class |
BadRequestException |
class |
Controller |
class |
DefaultWrapperServlet |
class |
Dispatcher
The servlet that dispatch request to various controllers
according to the user defined routes in the router.
|
class |
GenericExceptionHandler
Handle webservices jersey exceptions and create json or xml response
with the ExceptionData.
|
interface |
MimeType |
class |
NotFoundException |
interface |
Params
Public static constants for webapp parameters.
|
class |
RemoteExceptionData
Contains the exception information from an exception thrown
by the web service REST API's.
|
class |
ResponseInfo
A class to help passing around request scoped info
|
interface |
SubView
Interface for SubView to avoid top-level inclusion
|
interface |
ToJSON
A light-weight JSON rendering interface
|
class |
View
Base class for all views
|
class |
WebApp |
class |
WebAppException |
class |
WebApps
Helpers to create an embedded webapp.
|
interface |
YarnWebParams |
Modifier and Type | Class and Description |
---|---|
class |
HelloWorld
The obligatory example.
|
class |
MyApp
The embedded UI serves two pages at:
http://localhost:8888/my and http://localhost:8888/my/anythingYouWant |
Modifier and Type | Class and Description |
---|---|
class |
Hamlet |
class |
HamletGen
Generates a specific hamlet implementation class from a spec class
using a generic hamlet implementation class.
|
class |
HamletSpec
HTML5 compatible HTML4 builder interfaces.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregatedLogsBlock |
class |
AggregatedLogsNavBlock |
class |
AggregatedLogsPage |
Modifier and Type | Class and Description |
---|---|
class |
DefaultPage |
class |
ErrorPage
A jquery-ui themeable error page
|
class |
FooterBlock |
class |
HeaderBlock |
class |
Html
This class holds utility functions for HTML
|
class |
HtmlBlock |
class |
HtmlPage
The parent class of all HTML pages.
|
class |
InfoBlock |
class |
JQueryUI |
class |
LipsumBlock |
class |
NavBlock |
class |
TextPage |
class |
TextView |
class |
TwoColumnCssLayout
A reusable, pure-css, cross-browser, left nav, 2 column,
supposedly liquid layout.
|
class |
TwoColumnLayout
A simpler two column layout implementation with a header, a navigation bar
on the left, content on the right, and a footer.
|
Copyright © 2013 Apache Software Foundation. All rights reserved.