Table of Contents - ruby-spark-1.2.1 Documentation
Pages
- Makefile
- Digest.java
- Murmur2.java
- RubySparkExtService.java
- build.sbt
- plugins.sbt
- sbt
- Exec.scala
- MLLibAPI.scala
- Marshal.scala
- MarshalDump.scala
- MarshalLoad.scala
- RubyAccumulatorParam.scala
- RubyBroadcast.scala
- RubyConstant.scala
- RubyMLLibAPI.scala
- RubyMLLibUtilAPI.scala
- RubyPage.scala
- RubyRDD.scala
- RubySerializer.scala
- RubyTab.scala
- RubyUtils.scala
- RubyWorker.scala
- MarshalSpec.scala
Classes and Modules
- Commander
- Commander::UI
- Master
- Master::Base
- Master::Process
- Master::Thread
- Spark
- Spark::Accumulator
- Spark::Accumulator::Server
- Spark::AccumulatorError
- Spark::Broadcast
- Spark::BroadcastError
- Spark::Build
- Spark::BuildError
- Spark::CLI
- Spark::Command
- Spark::Command::Aggregate
- Spark::Command::Base
- Spark::Command::CombineByKey
- Spark::Command::CombineByKey::Base
- Spark::Command::CombineByKey::Combine
- Spark::Command::CombineByKey::CombineWithZero
- Spark::Command::CombineByKey::Merge
- Spark::Command::Compact
- Spark::Command::Filter
- Spark::Command::FlatMap
- Spark::Command::FlatMapValues
- Spark::Command::Foreach
- Spark::Command::ForeachPartition
- Spark::Command::Glom
- Spark::Command::Histogram
- Spark::Command::KeyBy
- Spark::Command::Map
- Spark::Command::MapPartitions
- Spark::Command::MapPartitionsWithIndex
- Spark::Command::MapValues
- Spark::Command::PartitionBy
- Spark::Command::PartitionBy::Base
- Spark::Command::PartitionBy::Basic
- Spark::Command::PartitionBy::Sorting
- Spark::Command::Pipe
- Spark::Command::Reduce
- Spark::Command::Sample
- Spark::Command::Shuffle
- Spark::Command::SortByKey
- Spark::Command::Stats
- Spark::Command::Take
- Spark::CommandBuilder
- Spark::CommandError
- Spark::CommandValidator
- Spark::Config
- Spark::ConfigurationError
- Spark::Constant
- Spark::Context
- Spark::ContextError
- Spark::CoreExtension
- Spark::CoreExtension::Hash
- Spark::CoreExtension::Hash::ClassMethods
- Spark::CoreExtension::Hash::InstanceMethods
- Spark::CoreExtension::IO
- Spark::CoreExtension::IO::ClassMethods
- Spark::CoreExtension::IO::InstanceMethods
- Spark::CoreExtension::IPSocket
- Spark::CoreExtension::IPSocket::ClassMethods
- Spark::CoreExtension::IPSocket::InstanceMethods
- Spark::CoreExtension::Integer
- Spark::CoreExtension::Integer::ClassMethods
- Spark::CoreExtension::Integer::InstanceMethods
- Spark::CoreExtension::Module
- Spark::CoreExtension::Object
- Spark::CoreExtension::Object::ClassMethods
- Spark::CoreExtension::Object::InstanceMethods
- Spark::CoreExtension::String
- Spark::CoreExtension::String::ClassMethods
- Spark::CoreExtension::String::InstanceMethods
- Spark::Digest
- Spark::Digest::Murmur2
- Spark::ExternalSorter
- Spark::Helper
- Spark::Helper::Logger
- Spark::Helper::Logger::Methods
- Spark::Helper::Parser
- Spark::Helper::Parser::Methods
- Spark::Helper::Serialize
- Spark::Helper::Statistic
- Spark::Helper::System
- Spark::Helper::System::Methods
- Spark::InternalSorter
- Spark::InternalSorter::Ascending
- Spark::InternalSorter::Base
- Spark::InternalSorter::Descending
- Spark::JavaBridge
- Spark::JavaBridge::Base
- Spark::JavaBridge::JRuby
- Spark::JavaBridge::RJB
- Spark::JavaBridgeError
- Spark::Logger
- Spark::Mllib
- Spark::Mllib::ClassificationMethodBase
- Spark::Mllib::ClassificationModel
- Spark::Mllib::DenseMatrix
- Spark::Mllib::DenseVector
- Spark::Mllib::GaussianMixture
- Spark::Mllib::GaussianMixtureModel
- Spark::Mllib::KMeans
- Spark::Mllib::KMeansModel
- Spark::Mllib::LabeledPoint
- Spark::Mllib::LassoModel
- Spark::Mllib::LassoWithSGD
- Spark::Mllib::LinearRegressionModel
- Spark::Mllib::LinearRegressionWithSGD
- Spark::Mllib::LogisticRegressionModel
- Spark::Mllib::LogisticRegressionWithLBFGS
- Spark::Mllib::LogisticRegressionWithSGD
- Spark::Mllib::Matrices
- Spark::Mllib::MatrixAdapter
- Spark::Mllib::MatrixBase
- Spark::Mllib::NaiveBayes
- Spark::Mllib::NaiveBayesModel
- Spark::Mllib::RegressionMethodBase
- Spark::Mllib::RegressionModel
- Spark::Mllib::RidgeRegressionModel
- Spark::Mllib::RidgeRegressionWithSGD
- Spark::Mllib::SVMModel
- Spark::Mllib::SVMWithSGD
- Spark::Mllib::SparseMatrix
- Spark::Mllib::SparseVector
- Spark::Mllib::VectorAdapter
- Spark::Mllib::VectorBase
- Spark::Mllib::Vectors
- Spark::MllibError
- Spark::NotImplemented
- Spark::ParseError
- Spark::PipelinedRDD
- Spark::RDD
- Spark::RDDError
- Spark::RandomGenerator
- Spark::RandomGenerator::Poisson
- Spark::Sampler
- Spark::Sampler::Base
- Spark::Sampler::Poisson
- Spark::Sampler::Uniform
- Spark::SerializeError
- Spark::Serializer
- Spark::Serializer::AutoBatched
- Spark::Serializer::Base
- Spark::Serializer::Batched
- Spark::Serializer::Cartesian
- Spark::Serializer::Compressed
- Spark::Serializer::Marshal
- Spark::Serializer::MessagePack
- Spark::Serializer::Oj
- Spark::Serializer::Pair
- Spark::Serializer::Text
- Spark::StatCounter
- Spark::StorageLevel
- SparkFiles
- Vector
- Worker
- Worker::Base
- Worker::Process
- Worker::Thread
Methods
- ::autoload — Spark::Mllib
- ::autoload_without_import — Spark::Mllib
- ::build — Spark::Build
- ::build — Spark::Serializer
- ::changed — Spark::Accumulator
- ::clear_config — Spark
- ::config — Spark
- ::context — Spark
- ::create — Master
- ::dense — Spark::Mllib::Matrices
- ::dense — Spark::Mllib::Vectors
- ::elements — Vector
- ::enable_paging — Commander::UI
- ::error — Spark::Command::Base
- ::find — Spark::Serializer
- ::find! — Spark::Serializer
- ::from_java — Spark::Mllib::KMeansModel
- ::from_java — Spark::Mllib::DenseMatrix
- ::from_java — Spark::Mllib::LabeledPoint
- ::from_java — Spark::Mllib::DenseVector
- ::get — SparkFiles
- ::get — Spark::InternalSorter
- ::get_content — SparkFiles
- ::home — Spark
- ::host — Spark::Accumulator::Server
- ::import — Spark::Mllib
- ::included — Spark::CoreExtension::Hash
- ::included — Spark::CoreExtension::Integer
- ::included — Spark::CoreExtension::IO
- ::included — Spark::CoreExtension::IPSocket
- ::included — Spark::CoreExtension::Object
- ::included — Spark::CoreExtension::String
- ::included — Spark::Helper::Logger
- ::included — Spark::Helper::Parser
- ::included — Spark::Helper::System
- ::init — Spark::JavaBridge
- ::init_settings — Spark::Command::Base
- ::instances — Spark::Accumulator
- ::java_bridge — Spark
- ::java_get — Spark::StorageLevel
- ::jb — Spark
- ::load_defaults — Spark
- ::load_defaults_from — Spark
- ::load_lib — Spark
- ::logger — Spark
- ::mdarray? — Spark::Mllib
- ::narray? — Spark::Mllib
- ::new — Spark::Accumulator
- ::new — Spark::Accumulator::Server
- ::new — Spark::Broadcast
- ::new — Spark::Command
- ::new — Spark::Command::Base
- ::new — Spark::CommandBuilder
- ::new — Spark::Config
- ::new — Spark::Context
- ::new — Spark::JavaBridge::Base
- ::new — Spark::JavaBridge::JRuby
- ::new — Spark::JavaBridge::RJB
- ::new — Spark::Logger
- ::new — Spark::Mllib::ClassificationModel
- ::new — Spark::Mllib::LogisticRegressionModel
- ::new — Spark::Mllib::NaiveBayesModel
- ::new — Spark::Mllib::SVMModel
- ::new — Spark::Mllib::GaussianMixtureModel
- ::new — Spark::Mllib::KMeansModel
- ::new — Spark::Mllib::DenseMatrix
- ::new — Spark::Mllib::SparseMatrix
- ::new — Spark::Mllib::RegressionModel
- ::new — Spark::Mllib::LabeledPoint
- ::new — Spark::Mllib::MatrixAdapter
- ::new — Spark::Mllib::MatrixAdapter
- ::new — Spark::Mllib::VectorAdapter
- ::new — Spark::Mllib::VectorAdapter
- ::new — Spark::Mllib::DenseVector
- ::new — Spark::Mllib::SparseVector
- ::new — Spark::RDD
- ::new — Spark::PipelinedRDD
- ::new — Spark::RandomGenerator::Poisson
- ::new — Spark::Sampler::Base
- ::new — Spark::Serializer::AutoBatched
- ::new — Spark::Serializer::Batched
- ::new — Spark::Serializer::Compressed
- ::new — Spark::Serializer::Pair
- ::new — Spark::Serializer::Text
- ::new — Spark::InternalSorter::Base
- ::new — Spark::ExternalSorter
- ::new — Spark::StatCounter
- ::new — Master::Base
- ::new — Master::Thread
- ::new — Worker::Base
- ::parse — Spark::Mllib::DenseVector
- ::parse — Spark::Mllib::SparseVector
- ::parse — Spark::Mllib::Vectors
- ::port — Spark::Accumulator::Server
- ::prepare — Spark::Mllib
- ::print_logo — Spark
- ::register — Spark::Broadcast
- ::register — Spark::Serializer
- ::reload — Spark::StorageLevel
- ::reload! — Spark::StorageLevel
- ::root — Spark
- ::ruby_spark_jar — Spark
- ::save_defaults_to — Spark
- ::sc — Spark
- ::settings — Spark::Command::Base
- ::spark_ext_dir — Spark
- ::sparse — Spark::Mllib::Matrices
- ::sparse — Spark::Mllib::Vectors
- ::start — Spark::Accumulator::Server
- ::start — Spark
- ::started? — Spark
- ::stop — Spark::Accumulator::Server
- ::stop — Spark
- ::target_dir — Spark
- ::to_matrix — Spark::Mllib::Matrices
- ::to_vector — Spark::Mllib::Vectors
- ::train — Spark::Mllib::LogisticRegressionWithSGD
- ::train — Spark::Mllib::LogisticRegressionWithLBFGS
- ::train — Spark::Mllib::NaiveBayes
- ::train — Spark::Mllib::SVMWithSGD
- ::train — Spark::Mllib::GaussianMixture
- ::train — Spark::Mllib::KMeans
- ::train — Spark::Mllib::RegressionMethodBase
- ::train — Spark::Mllib::LassoWithSGD
- ::train — Spark::Mllib::LinearRegressionWithSGD
- ::train — Spark::Mllib::RidgeRegressionWithSGD
- ::variable — Spark::Command::Base
- ::worker_dir — Spark
- #+ — Spark::Accumulator
- #+ — Spark::RDD
- #== — Spark::Serializer::Base
- #[] — Spark::Config
- #[]= — Spark::Config
- #[]= — Spark::Mllib::VectorAdapter
- #__check_array — Spark::Helper::Serialize
- #_bucket_function — Spark::Command::Histogram
- #_combine_by_key — Spark::RDD
- #_fork? — Master::Process
- #_jrdd — Spark::PipelinedRDD
- #_partition_by — Spark::RDD
- #_reduce — Spark::RDD
- #_run — Spark::Command::CombineByKey::Combine
- #_run — Spark::Command::CombineByKey::Merge
- #_run — Spark::Command::CombineByKey::CombineWithZero
- #_sampler — Spark::Command::Sample
- #accumulator — Spark::Context
- #add — Spark::Accumulator
- #addFile — Spark::Context
- #addLibrary — Spark::RDD
- #add_by_symbol — Spark::Accumulator
- #add_command — Spark::CommandBuilder
- #add_command — Spark::RDD
- #add_file — Spark::Context
- #add_library — Spark::CommandBuilder
- #add_library — Spark::RDD
- #add_memory! — Spark::ExternalSorter
- #aggregate — Spark::RDD
- #aggregate — Spark::Serializer::Cartesian
- #aggregate — Spark::Serializer::Pair
- #aggregateByKey — Spark::RDD
- #aggregate_by_key — Spark::RDD
- #basic_bucket_function — Spark::Command::Histogram
- #batched? — Spark::Serializer::AutoBatched
- #batched? — Spark::Serializer::Base
- #batched? — Spark::Serializer::Batched
- #before_end — Worker::Base
- #before_run — Spark::Command::Base
- #before_run — Spark::Command::Pipe
- #before_run — Spark::Command::SortByKey
- #before_start — Worker::Base
- #before_start — Worker::Process
- #bind — Spark::CommandBuilder
- #bind — Spark::RDD
- #bisect_right — Spark::Helper::Statistic
- #broadcast — Spark::Context
- #bucket_function — Spark::Command::Histogram
- #build — Spark::CommandBuilder
- #cache — Spark::RDD
- #cached? — Spark::RDD
- #call — Spark::JavaBridge::Base
- #camelize_with_spark — Spark::CoreExtension::String::InstanceMethods
- #cartesian — Spark::RDD
- #check_each — Spark::Serializer::Base
- #check_read_only — Spark::Config
- #checkpointed? — Spark::RDD
- #clearCallSite — Spark::Context
- #clear_call_site — Spark::Context
- #clear_threshold — Spark::Mllib::ClassificationModel
- #coalesce — Spark::RDD
- #cogroup — Spark::RDD
- #collect — Spark::RDD
- #collect_as_hash — Spark::RDD
- #collect_from_file — Spark::RDD
- #combineByKey — Spark::RDD
- #combine_by_key — Spark::RDD
- #compact — Spark::RDD
- #compute — Worker::Base
- #compute_fraction — Spark::Helper::Statistic
- #config — Spark::Context
- #config — Spark::RDD
- #contains? — Spark::Config
- #convert_to_java_int — Spark::Helper::Parser::Methods
- #count — Spark::RDD
- #counter_size — Spark::Command::Histogram
- #create_command — Spark::CommandBuilder
- #create_temp_folder — Spark::ExternalSorter
- #create_worker — Master::Process
- #create_worker — Master::Thread
- #create_writing_thread — Spark::Command::Pipe
- #debug — Spark::Logger
- #debug? — Spark::Logger
- #deep_copy — Spark::CommandBuilder
- #deep_copy_with_spark — Spark::CoreExtension::Object::InstanceMethods
- #defaultParallelism — Spark::Context
- #defaultReducePartitions — Spark::RDD
- #default_batch_size — Spark::Context
- #default_executor_command — Spark::Config
- #default_executor_options — Spark::Config
- #default_parallelism — Spark::Context
- #default_reduce_partitions — Spark::RDD
- #default_serializer — Spark::Config
- #default_serializer — Spark::Context
- #default_serializer_batch_size — Spark::Config
- #default_serializer_compress — Spark::Config
- #default_worker_type — Spark::Config
- #destroy_temp_folder — Spark::ExternalSorter
- #determine_bounds — Spark::Helper::Statistic
- #disable — Spark::Logger
- #distinct — Spark::RDD
- #dot — Spark::Mllib::VectorAdapter
- #driver? — Spark::Accumulator
- #dump — Spark::Serializer::Batched
- #dump — Spark::Serializer::Compressed
- #dump — Spark::Serializer::Marshal
- #dump — Spark::Serializer::MessagePack
- #dump — Spark::Serializer::Oj
- #dump_to_io — Spark::Serializer::AutoBatched
- #dump_to_io — Spark::Serializer::Batched
- #enabled? — Spark::Logger
- #error — Spark::Command::Base
- #error — Spark::Logger
- #error — Spark::Serializer::Base
- #error? — Spark::Logger
- #execute — Spark::Command
- #execute — Spark::Command::Base
- #fast_bucket_function — Spark::Command::Histogram
- #filter — Spark::RDD
- #first — Spark::RDD
- #flatMap — Spark::RDD
- #flat_map — Spark::RDD
- #flat_map_values — Spark::RDD
- #fold — Spark::RDD
- #foldByKey — Spark::RDD
- #fold_by_key — Spark::RDD
- #foreach — Spark::RDD
- #foreachPartition — Spark::RDD
- #foreach_partition — Spark::RDD
- #fork? — Master::Process
- #from_file — Spark::Config
- #get — Spark::Config
- #getAll — Spark::Config
- #getLocalProperty — Spark::Context
- #get_all — Spark::Config
- #get_local_property — Spark::Context
- #glom — Spark::RDD
- #groupBy — Spark::RDD
- #groupByKey — Spark::RDD
- #groupWith — Spark::RDD
- #group_by — Spark::RDD
- #group_by_key — Spark::RDD
- #group_with — Spark::RDD
- #handle_accept — Spark::Accumulator::Server
- #handle_connection — Spark::Accumulator::Server
- #histogram — Spark::RDD
- #hostname — Spark::CoreExtension::IPSocket::InstanceMethods
- #id — Spark::RDD
- #id — Worker::Process
- #id — Worker::Thread
- #import — Spark::JavaBridge::JRuby
- #import — Spark::JavaBridge::RJB
- #import_all — Spark::JavaBridge::Base
- #import_all_test — Spark::JavaBridge::Base
- #increment — Spark::Command::Histogram
- #info — Spark::Logger
- #info? — Spark::Logger
- #inspect — Spark::Accumulator
- #inspect — Spark::Broadcast
- #inspect — Spark::Context
- #inspect — Spark::RDD
- #inspect — Spark::Serializer::Base
- #intersection — Spark::RDD
- #jars — Spark::JavaBridge::Base
- #jars — Spark::JavaBridge::RJB
- #java_object? — Spark::JavaBridge::JRuby
- #java_object? — Spark::JavaBridge::RJB
- #java_objects — Spark::JavaBridge::Base
- #java_test_objects — Spark::JavaBridge::Base
- #java_to_ruby — Spark::JavaBridge::Base
- #jrdd — Spark::PipelinedRDD
- #jruby? — Spark::Helper::System::Methods
- #keyBy — Spark::RDD
- #key_by — Spark::RDD
- #keys — Spark::RDD
- #kill_worker — Master::Process
- #kill_worker — Master::Thread
- #kill_worker — Worker::Process
- #kill_worker — Worker::Thread
- #kill_worker_and_wait — Master::Base
- #last — Spark::Command
- #lazy_run — Spark::Command::Map
- #lazy_run — Spark::Command::FlatMap
- #lazy_run — Spark::Command::Filter
- #lazy_run — Spark::Command::Compact
- #lazy_run — Spark::Command::Glom
- #lazy_run — Spark::Command::PartitionBy::Base
- #lazy_run — Spark::Command::Aggregate
- #lazy_run — Spark::Command::KeyBy
- #lazy_run — Spark::Command::Pipe
- #lazy_run — Spark::Command::CombineByKey::Base
- #lazy_run — Spark::Command::MapValues
- #lazy_run — Spark::Command::Sample
- #lazy_run — Spark::Command::Stats
- #lazy_run — Spark::Command::Histogram
- #lazy_sample — Spark::Sampler::Poisson
- #lazy_sample — Spark::Sampler::Uniform
- #level_enabled? — Spark::Logger
- #level_off — Spark::Logger
- #load — Spark::Serializer::Batched
- #load — Spark::Serializer::Compressed
- #load — Spark::Serializer::Marshal
- #load — Spark::Serializer::MessagePack
- #load — Spark::Serializer::Oj
- #load — Spark::Serializer::Text
- #load_accum_param — Spark::Accumulator
- #load_command — Worker::Thread
- #load_executor_envs — Spark::Config
- #load_from_file — Spark::Serializer::Base
- #load_from_io — Spark::Serializer::Base
- #load_from_io — Spark::Serializer::Batched
- #load_from_io — Spark::Serializer::Pair
- #load_iterator — Worker::Thread
- #log — Spark::Command::Base
- #log — Worker::Base
- #logDebug — Spark::Helper::Logger::Methods
- #logError — Spark::Helper::Logger::Methods
- #logInfo — Spark::Helper::Logger::Methods
- #logTrace — Spark::Helper::Logger::Methods
- #logWarning — Spark::Helper::Logger::Methods
- #log_debug — Spark::Helper::Logger::Methods
- #log_error — Spark::Helper::Logger::Methods
- #log_info — Spark::Helper::Logger::Methods
- #log_trace — Spark::Helper::Logger::Methods
- #log_warning — Spark::Helper::Logger::Methods
- #lookup — Spark::RDD
- #make_partition_item — Spark::Command::PartitionBy::Base
- #make_parts — Spark::ExternalSorter
- #map — Spark::RDD
- #mapPartitions — Spark::RDD
- #mapPartitionsWithIndex — Spark::RDD
- #mapValues — Spark::RDD
- #map_partitions — Spark::RDD
- #map_partitions_with_index — Spark::RDD
- #map_values — Spark::RDD
- #marshal_dump — Spark::Accumulator
- #marshal_dump — Spark::Broadcast
- #marshal_dump — Spark::Command
- #marshal_dump — Spark::Mllib::LabeledPoint
- #marshal_dump — Spark::Mllib::DenseVector
- #marshal_dump — Spark::Mllib::SparseVector
- #marshal_load — Spark::Accumulator
- #marshal_load — Spark::Broadcast
- #marshal_load — Spark::Command
- #marshal_load — Spark::Mllib::LabeledPoint
- #marshal_load — Spark::Mllib::DenseVector
- #marshal_load — Spark::Mllib::SparseVector
- #max — Spark::Command::Histogram
- #max — Spark::RDD
- #mean — Spark::RDD
- #means — Spark::Mllib::GaussianMixtureModel
- #memory_multiplier_based_kb — Spark::Helper::Parser::Methods
- #memory_usage — Spark::Helper::System::Methods
- #merge — Spark::StatCounter
- #merge_array — Spark::StatCounter
- #merge_stat_counter — Spark::StatCounter
- #merge_value — Spark::StatCounter
- #method_missing — Spark::Command::Base
- #min — Spark::Command::Histogram
- #min — Spark::RDD
- #mri? — Spark::Helper::System::Methods
- #name — Spark::RDD
- #name — Spark::Serializer::AutoBatched
- #name — Spark::Serializer::Base
- #name — Spark::Serializer::Batched
- #name= — Spark::RDD
- #new_rdd_from_command — Spark::RDD
- #numeric_address — Spark::CoreExtension::IPSocket::InstanceMethods
- #objects_with_names — Spark::JavaBridge::Base
- #original_initialize — Spark::Mllib::MatrixAdapter
- #pack_double — Spark::Helper::Serialize
- #pack_doubles — Spark::Helper::Serialize
- #pack_int — Spark::Helper::Serialize
- #pack_ints — Spark::Helper::Serialize
- #pack_long — Spark::Helper::Serialize
- #pack_longs — Spark::Helper::Serialize
- #pack_unsigned_chars — Spark::Helper::Serialize
- #parallelize — Spark::Context
- #parse_boolean — Spark::Config
- #parse_integer — Spark::Config
- #partitionBy — Spark::RDD
- #partition_by — Spark::RDD
- #partitionsSize — Spark::RDD
- #partitions_size — Spark::RDD
- #patch_unless_exist — Spark::CoreExtension::Module
- #path_const_unless_exist — Spark::CoreExtension::Module
- #persist — Spark::RDD
- #pipe — Spark::RDD
- #pipelinable? — Spark::PipelinedRDD
- #port — Spark::CoreExtension::IPSocket::InstanceMethods
- #predict — Spark::Mllib::LogisticRegressionModel
- #predict — Spark::Mllib::NaiveBayesModel
- #predict — Spark::Mllib::SVMModel
- #predict — Spark::Mllib::GaussianMixtureModel
- #predict — Spark::Mllib::KMeansModel
- #predict — Spark::Mllib::RegressionModel
- #predict_soft — Spark::Mllib::GaussianMixtureModel
- #prepare — Spark::Command::Base
- #prepare — Spark::Command::PartitionBy::Base
- #prepare — Spark::Command::PartitionBy::Sorting
- #prepared? — Spark::Command::Base
- #pry? — Spark::Helper::System::Methods
- #raise_missing_class — Spark::JavaBridge::Base
- #rand — Spark::RandomGenerator::Poisson
- #read_data — Spark::CoreExtension::IO::InstanceMethods
- #read_int — Spark::CoreExtension::IO::InstanceMethods
- #read_int_or_eof — Spark::CoreExtension::IO::InstanceMethods
- #read_long — Spark::CoreExtension::IO::InstanceMethods
- #read_only? — Spark::Config
- #read_string — Spark::CoreExtension::IO::InstanceMethods
- #receive_message — Master::Base
- #reduce — Spark::RDD
- #reduceByKey — Spark::RDD
- #reduce_by_key — Spark::RDD
- #require — Spark::RDD
- #reserialize — Spark::RDD
- #rng — Spark::Command::Shuffle
- #rng — Spark::Sampler::Poisson
- #rng — Spark::Sampler::Uniform
- #ruby_to_java — Spark::JavaBridge::Base
- #run — Spark::CLI
- #run — Spark::Command::Map
- #run — Spark::Command::FlatMap
- #run — Spark::Command::MapPartitionsWithIndex
- #run — Spark::Command::MapPartitions
- #run — Spark::Command::Filter
- #run — Spark::Command::Compact
- #run — Spark::Command::Glom
- #run — Spark::Command::Shuffle
- #run — Spark::Command::PartitionBy::Base
- #run — Spark::Command::Aggregate
- #run — Spark::Command::Reduce
- #run — Spark::Command::Foreach
- #run — Spark::Command::ForeachPartition
- #run — Spark::Command::KeyBy
- #run — Spark::Command::Take
- #run — Spark::Command::Pipe
- #run — Spark::Command::CombineByKey::Base
- #run — Spark::Command::MapValues
- #run — Spark::Command::FlatMapValues
- #run — Spark::Command::SortByKey
- #run — Spark::Command::Sample
- #run — Spark::Command::Stats
- #run — Spark::Command::Histogram
- #run — Master::Base
- #run — Worker::Base
- #runJob — Spark::Context
- #runJobWithCommand — Spark::Context
- #run_job — Spark::Context
- #run_job_with_command — Spark::Context
- #run_with_enum — Spark::Command::SortByKey
- #run_with_spilling — Spark::Command::SortByKey
- #run_without_spilling — Spark::Command::SortByKey
- #sample — Spark::RDD
- #sample — Spark::Sampler::Poisson
- #sample — Spark::Sampler::Uniform
- #sampleStdev — Spark::RDD
- #sampleStdev — Spark::StatCounter
- #sampleVariance — Spark::RDD
- #sampleVariance — Spark::StatCounter
- #sample_stdev — Spark::RDD
- #sample_stdev — Spark::StatCounter
- #sample_variance — Spark::RDD
- #sample_variance — Spark::StatCounter
- #sampler — Spark::Command::Sample
- #sc — Spark::Context
- #send_error — Worker::Base
- #serialize_function — Spark::CommandBuilder
- #serialize_function_from_method — Spark::CommandBuilder
- #serialize_function_from_proc — Spark::CommandBuilder
- #serialize_function_from_string — Spark::CommandBuilder
- #serialize_function_from_symbol — Spark::CommandBuilder
- #serialized_bound_objects — Spark::Command
- #set — Spark::Config
- #setAppName — Spark::Config
- #setCallSite — Spark::Context
- #setLocalProperty — Spark::Context
- #setMaster — Spark::Config
- #setName — Spark::RDD
- #set_app_name — Spark::Config
- #set_call_site — Spark::Context
- #set_default — Spark::Config
- #set_local_property — Spark::Context
- #set_master — Spark::Config
- #set_name — Spark::RDD
- #settings — Spark::Command::Base
- #shape — Spark::Mllib::MatrixAdapter
- #shuffle — Spark::RDD
- #sigmas — Spark::Mllib::GaussianMixtureModel
- #silence_warnings — Spark::JavaBridge::RJB
- #sort — Spark::InternalSorter::Ascending
- #sort — Spark::InternalSorter::Descending
- #sortBy — Spark::RDD
- #sortByKey — Spark::RDD
- #sort_by — Spark::RDD
- #sort_by — Spark::ExternalSorter
- #sort_by_key — Spark::RDD
- #sort_by_value — Spark::RDD
- #spark_conf — Spark::Config
- #squared_distance — Spark::Mllib::VectorAdapter
- #stats — Spark::RDD
- #stdev — Spark::RDD
- #stdev — Spark::StatCounter
- #stop — Spark::Accumulator::Server
- #stop — Spark::Context
- #stringify_keys_with_spark! — Spark::CoreExtension::Hash::InstanceMethods
- #subtract — Spark::RDD
- #subtractByKey — Spark::RDD
- #subtract_by_key — Spark::RDD
- #successful_finish — Worker::Base
- #sum — Spark::RDD
- #sum — Spark::StatCounter
- #symbolize_keys_with_spark! — Spark::CoreExtension::Hash::InstanceMethods
- #take — Spark::RDD
- #takeSample — Spark::RDD
- #take_sample — Spark::RDD
- #textFile — Spark::Context
- #text_file — Spark::Context
- #threshold= — Spark::Mllib::ClassificationModel
- #to_java — Spark::JavaBridge::Base
- #to_java — Spark::Mllib::DenseMatrix
- #to_java — Spark::Mllib::DenseVector
- #to_java — Spark::RDD
- #to_java_array_list — Spark::JavaBridge::Base
- #to_java_array_list — Spark::Helper::Parser::Methods
- #to_java_hash — Spark::Helper::Parser::Methods
- #to_long — Spark::JavaBridge::Base
- #to_memory_size — Spark::Helper::Parser::Methods
- #to_ruby — Spark::JavaBridge::Base
- #to_s — Spark::Command::Base
- #to_s — Spark::Mllib::DenseVector
- #to_s — Spark::Mllib::SparseVector
- #to_s — Spark::Serializer::Base
- #to_s — Spark::Serializer::Batched
- #to_s — Spark::Serializer::Pair
- #to_s — Spark::Serializer::Text
- #to_s — Spark::StatCounter
- #trace — Spark::Logger
- #trace? — Spark::Logger
- #transform_keys_with_spark! — Spark::CoreExtension::Hash::InstanceMethods
- #ui — Spark::Context
- #unbatch! — Spark::Serializer::AutoBatched
- #unbatch! — Spark::Serializer::Base
- #unbatch! — Spark::Serializer::Batched
- #union — Spark::RDD
- #unpack_chars — Spark::Helper::Serialize
- #unpack_int — Spark::Helper::Serialize
- #unpack_long — Spark::Helper::Serialize
- #unpersist — Spark::RDD
- #upper_binomial_bound — Spark::Helper::Statistic
- #upper_poisson_bound — Spark::Helper::Statistic
- #valid! — Spark::Config
- #valid? — Spark::CommandValidator
- #valid_accum_param — Spark::Accumulator
- #validate — Spark::CommandValidator
- #validate_size — Spark::CommandValidator
- #validate_type — Spark::CommandValidator
- #value — Spark::Broadcast
- #values — Spark::Mllib::MatrixAdapter
- #values — Spark::Mllib::VectorAdapter
- #values — Spark::RDD
- #variance — Spark::RDD
- #variance — Spark::StatCounter
- #warn — Spark::Logger
- #warning — Spark::Logger
- #warning? — Spark::Logger
- #wholeTextFiles — Spark::Context
- #whole_text_files — Spark::Context
- #windows? — Spark::Helper::System::Methods
- #write_data — Spark::CoreExtension::IO::InstanceMethods
- #write_int — Spark::CoreExtension::IO::InstanceMethods
- #write_long — Spark::CoreExtension::IO::InstanceMethods
- #write_string — Spark::CoreExtension::IO::InstanceMethods