All Classes and Interfaces
Class
Description
Performs the construction and initialization of ErrorHandler instances, implementations of which may be provided
by third parties.
Defines the constants for determining the type of authentication to Elasticsearch we will be using.
Base implementation for converting failure events into ECS documents
Provides a basic implementation of an exceptional event to be passed between error handlers.
Provides a composite view of configurations, using a hierarchical model for property lookup as well as immutable
treatment of the underlying configurations.
Class providing the various Configuration parameters used by the Elasticsearch Hadoop integration.
Enum used for representing the stats inside Hadoop.
Generic Error Handler that converts error events into JSON documents, and stores them in an Elasticsearch index.
An interface for accepting modified information to be retried in the event of a recoverable failure.
Handler interface to be notified of and handle recoverable errors during connector execution.
Denotes that a handler has decided to abort the job on a potentially retryable value.
Base class for Elasticsearch Hadoop exceptions.
Denotes an operation that is not allowed to be performed, often due to the feature support of
the version of Elasticsearch being used.
ElasticSearch
InputFormat for streaming data (typically based on a query) from ElasticSearch.Utility functions for setting up Map Reduce Jobs to read and write from Elasticsearch.
ElasticSearch
OutputFormat (old and new API) for adding data to an index inside ElasticSearch.Stores token authentication information for an Elasticsearch user.
The Hadoop Token Identifier for any generic token that contains an EsToken within it.
Given a failure event that extends Exceptional, provide a mechanism for transforming its fields into an ECS document.
Any object that carries with it an internal Exception that details some kind of faulty operation or data.
Filtered settings are used for masking and hiding configuration values by key prefix.
Class which handles the various Hadoop properties, aware of the changes between YARN (Hadoop 2) and 1.
When queried for a user object, this provider will obtain the currently logged in user,
returning it if it is a regular user, or if it is a PROXY user, will retrieve the lowest
level real user from it that has actual credentials.
Factory for loading settings based on various configuration objects, such as Properties or Hadoop configuration.
Provides access to user operations from Hadoop's UserGroupInformation class.
Retrieves the currently logged in Hadoop UGI.
Any object that can produce a list of error handlers of a given type.
Values that denote the result of an action taken by an
ErrorHandler.Property names for internal framework use.
Operates by retrieving the currently set subject in a way that ES-Hadoop understands, or
a blank subject if there isn't currently one available.
Similar to
MapWritable expect that it uses a LinkedHashMap underneath to preserve insertion order (and thus its structure).Returns the specified handlers as the loaded handlers.
Properties-based settings - used for testing or local environments (including Cascading-local).
Loads a keystore to retrieve secure settings, falling back to the settings object if the
keystore is not configured or the property cannot be found.
Holder class containing the various configuration bits used by ElasticSearch Hadoop.
Provides the main logic for obtaining Hadoop specific Tokens containing Elasticsearch authentication
info, caching them in User objects (Subjects or Hadoop UGI), and adding them to jobs and job configurations.
Provides a platform independent way of accessing user information.
Provides a platform independent way of retrieving the currently running user.
Utility handling the difference in built-in Writable between Hadoop 1 and 2.