| Class | Description |
|---|---|
| ApplicationLauncherUtils |
A utility class for the application launcher.
|
| AutoCloseableLock |
An auto-closeable
Lock that can be used with try-with-resources. |
| AutoReturnableObject<T> |
Borrow an object from a
GenericObjectPool and returns it automatically on close. |
| AvroFlattener |
This class provides methods to flatten an Avro Schema to make it more optimal for ORC
(Hive does not support predicate pushdown for ORC with nested fields: ETL-7214)
The behavior of Avro Schema un-nesting is listed below:
1.
|
| AvroUtils |
A Utils class for dealing with Avro objects
|
| AvroUtils.AvroPathFilter | |
| AzkabanTags |
Utility class for collecting metadata specific to a Azkaban runtime environment.
|
| CLIPasswordEncryptor |
A command line tool for encrypting password.
|
| ClusterNameTags |
Utility class for collecting metadata specific to the current Hadoop cluster.
|
| ClustersNames |
Allows conversion of URLs identifying a Hadoop cluster (e.g.
|
| ConfigUtils |
Utility class for dealing with
Config objects. |
| DatasetFilterUtils |
A utility class for filtering datasets through blacklist and whitelist.
|
| Either<S,T> |
Represents a value of one of two possible types.
|
| Either.Left<S,T> |
An instance of
Either with value of type S. |
| Either.Right<S,T> |
An instance of
Either with value of type T. |
| EmailUtils |
A utility class for sending emails.
|
| EmptyIterable<T> |
A type of
Iterables corresponding to empty Collections. |
| ExecutorsUtils |
A utility class to use with
Executors in cases such as when creating new thread pools. |
| ExponentialBackoff |
Utility class for exponential backoff.
|
| FileListUtils |
Utility class for listing files on a
FileSystem. |
| ForkOperatorUtils |
Utility class for use with the
ForkOperator class. |
| HadoopUtils |
A utility class for working with Hadoop.
|
| HeapDumpForTaskUtils |
A utility class for generating script to move the heap dump .prof files to HDFS for hadoop tasks, when Java heap out of memory error is thrown.
|
| HiveJdbcConnector |
A class for managing a Hive JDBC connection.
|
| HostUtils | |
| Id | |
| Id.Job | |
| Id.MultiTask | |
| Id.Task | |
| ImmutableProperties |
Immutable wrapper for
Properties. |
| JobConfigurationUtils |
A utility class for working with job configurations.
|
| JobLauncherUtils |
Utility class for the job scheduler and job launchers.
|
| JvmUtils | |
| LoggingUncaughtExceptionHandler |
A type of
Thread.UncaughtExceptionHandler that logs uncaught exceptions. |
| NoopCloseable |
A
Closeable that does nothing. |
| ParallelRunner |
A class that is responsible for running certain methods in parallel.
|
| ParallelRunner.NamedFuture |
A future with a name / message for reporting.
|
| PathUtils | |
| PortUtils | |
| PropertiesUtils |
A utility class for
Properties objects. |
| ProxiedFileSystemCache |
A cache for storing a mapping between Hadoop users and user
FileSystem objects. |
| ProxiedFileSystemUtils |
Utility class for creating
FileSystem objects while proxied as another user. |
| ProxiedFileSystemWrapper | Deprecated |
| PublisherUtils |
Utility class for
DataPublisher. |
| PublisherUtils.SplitExtractsResult | |
| PublisherUtils.WorkUnitStateSuccess |
Implementation of
Predicate that checks if a given WorkUnitState has a WorkUnitState.WorkingState equal
to WorkUnitState.WorkingState.SUCCESSFUL. |
| PullFileLoader |
Used to load pull files from the file system.
|
| RateControlledFileSystem | Deprecated |
| SerializationUtils |
A utility class for serializing and deserializing Objects to/from Strings.
|
| StringParsingUtils | |
| TemplateUtils | |
| TimeRangeChecker |
Utility class to check if a given time is in a pre-defined range.
|
| WritableShimSerialization |
A serializer that understands how to write objects that implement
WritableShim out to a Hadoop
stream. |
| WriterUtils |
Utility class for use with the
DataWriter class. |
| Enum | Description |
|---|---|
| DatePartitionType |
Temporal granularity types for writing (
partitioner.TimeBasedWriterPartitioner) and reading
(DatePartitionedAvroFileSource) date partitioned data. |
| Id.Parts | |
| ParallelRunner.FailPolicy |
Policies indicating how
ParallelRunner should handle failure of tasks. |
| ProxiedFileSystemUtils.AuthType | |
| ProxiedFileSystemWrapper.AuthType | Deprecated |
| WriterUtils.WriterFilePathType |
TABLENAME should be used for jobs that pull from multiple tables/topics and intend to write the records
in each table/topic to a separate folder.
|
| Exception | Description |
|---|---|
| ExponentialBackoff.NoMoreRetriesException |
Thrown if no more retries are available for
ExponentialBackoff. |
| StringParsingUtils.FormatException |