| Class | Description |
|---|---|
| AbstractDataset | |
| ArffHeaderSparkJob |
A Spark job for creating a unified ARFF header (including summary "meta"
attributes).
|
| ArffHeaderSparkJobBeanInfo |
BeanInfo class for the ArffHeaderSparkJob
|
| CachingStrategy |
Implements a caching strategy based on available cluster memory and size of
input on disk.
|
| CanopyClustererSparkJob |
Spark job for training a Canopy clusterer
|
| CorrelationMatrixSparkJob |
Spark job for constructing a correlation matrix.
|
| CorrelationMatrixSparkJobBeanInfo |
BeanInfo class for the CorrelationMatrixSparkJob
|
| CSVToInstanceFlatMapFunction |
A flat map function to convert CSV string data into Instances
|
| CSVToInstancePairFlatMapFunction | |
| Dataset<T> |
Class that encapsulates dataset information - i.e.
|
| DatasetManager |
Manages datasets
|
| IntegerKeyPartitioner |
A simple partitioner that partitions according to the key
|
| KMeansClustererSparkJob |
Spark job for training a k-means clusterer with or without the k-means++
(kmeans||) initialization procedure
|
| KMeansClustererSparkJobBeanInfo |
BeanInfo class for the KMeansClustererSparkJob
|
| RandomizedDataSparkJob |
Job for creating randomly shuffled (and stratified if a nominal class is set)
RDDs.
|
| RandomizedDataSparkJobBeanInfo |
BeanInfo class for the RandomizedDataSparkJob
|
| SparkJob |
Abstract base class for Spark jobs.
|
| SparkJob.NoKeyTextOutputFormat<K,V> |
Subclass of TextOutputFormat that does not write the key.
|
| SparkJobBeanInfo | |
| SparkUtils |
Some utility routines pertaining to files
|
| SparkUtils.WekaLoggingPrintWriter |
Used for hooking into Spark's log4j logging via a WriterAppender
|
| WekaClassifierEvaluationSparkJob |
Spark job for running an evaluation of a classifier or a regressor.
|
| WekaClassifierEvaluationSparkJobBeanInfo | |
| WekaClassifierSparkJob |
Job for building a classifier in Spark.
|
| WekaClassifierSparkJobBeanInfo |
BeanInfo class for the WekaClassifierSparkJob
|
| WekaScoringSparkJob |
Spark job for scoring new data using an existing Weka classifier or clusterer
model.
|
| WekaScoringSparkJobBeanInfo |