Module: eclairjs/streaming/kafka
streaming kafka module
Source:
streaming/kafka/module.js
,
line 17
Classes
KafkaUtils
Home
Modules
eclairjs
eclairjs/ml
eclairjs/ml/classification
eclairjs/ml/clustering
eclairjs/ml/evaluation
eclairjs/ml/feature
eclairjs/ml/param
eclairjs/ml/recommendation
eclairjs/ml/regression
eclairjs/ml/tuning
eclairjs/mllib
eclairjs/mllib/classification
eclairjs/mllib/clustering
eclairjs/mllib/evaluation
eclairjs/mllib/feature
eclairjs/mllib/fpm
eclairjs/mllib/linalg
eclairjs/mllib/linalg/distributed
eclairjs/mllib/optimization
eclairjs/mllib/random
eclairjs/mllib/recommendation
eclairjs/mllib/regression
eclairjs/mllib/tree
eclairjs/mllib/tree/configuration
eclairjs/mllib/tree/loss
eclairjs/mllib/tree/model
eclairjs/mllib/util
eclairjs/rdd
eclairjs/sql
eclairjs/sql/streaming
eclairjs/sql/types
eclairjs/storage
eclairjs/streaming
eclairjs/streaming/dstream
eclairjs/streaming/kafka
eclairjs/streaming/twitter
Classes
_resolveRows
InputDStream
IsotonicRegressionModel
MLReader
MLWriter
Accumulable
AccumulableParam
Accumulator
FloatAccumulatorParam
IntAccumulatorParam
List
SparkConf
SparkContext
Tuple
Tuple2
Tuple3
Tuple4
Estimator
Model
Pipeline
PipelineModel
PipelineStage
PredictionModel
Predictor
Transformer
UnaryTransformer
NumericAttribute
ClassificationModel
Classifier
DecisionTreeClassifier
GBTClassifier
LogisticRegression
LogisticRegressionModel
LogisticRegressionSummary
LogisticRegressionTrainingSummary
MultilayerPerceptronClassificationModel
NaiveBayes
NaiveBayesModel
OneVsRestModel
ProbabilisticClassificationModel
ProbabilisticClassifier
RandomForestClassificationModel
RandomForestClassifier
BisectingKMeans
BisectingKMeansModel
GaussianMixture
GaussianMixtureModel
GaussianMixtureSummary
KMeans
KMeansModel
LDA
LDAModel
MulticlassClassificationEvaluator
RegressionEvaluator
ChiSqSelectorModel
ElementwiseProduct
IDFModel
IndexToString
MinMaxScaler
MinMaxScalerModel
NGram
Normalizer
OneHotEncoder
PCA
PCAModel
PolynomialExpansion
QuantileDiscretizer
RFormulaModel
StandardScalerModel
StringIndexer
StringIndexerModel
VectorIndexer
VectorIndexerModel
Word2VecModel
BooleanParam
DoubleParam
IntParam
Param
ParamMap
ParamPair
ALSModel
AFTSurvivalRegressionModel
DecisionTreeRegressionModel
DecisionTreeRegressor
GBTRegressionModel
GBTRegressor
GeneralizedLinearRegression
GeneralizedLinearRegressionModel
GeneralizedLinearRegressionSummary
GeneralizedLinearRegressionTrainingSummary
LinearRegression
LinearRegressionModel
LinearRegressionSummary
LinearRegressionTrainingSummary
RandomForestRegressionModel
RandomForestRegressor
RegressionModel
CrossValidatorModel
ParamGridBuilder
TrainValidationSplit
TrainValidationSplitModel
MLReadable
MLWritable
MLUtils
LogisticRegressionModel
LogisticRegressionWithLBFGS
LogisticRegressionWithSGD
NaiveBayes
NaiveBayesModel
SVMModel
SVMWithSGD
BisectingKMeans
BisectingKMeansModel
KMeans
KMeansModel
LDA
LDAModel
PowerIterationClustering
PowerIterationClusteringModel
BinaryClassificationMetrics
MulticlassMetrics
RankingMetrics
RegressionMetrics
Word2Vec
Word2VecModel
AssociationRules
FPGrowth
FPGrowthModel
PrefixSpan
PrefixSpanModel
DenseVector
Matrix
SingularValueDecomposition
Vector
Vectors
RowMatrix
LBFGS
LogisticGradient
SquaredL2Updater
RandomRDDs
ALS
MatrixFactorizationModel
Rating
LabeledPoint
LinearRegressionModel
LinearRegressionWithSGD
DecisionTree
GradientBoostedTrees
RandomForest
BoostingStrategy
Strategy
Loss
DecisionTreeModel
GradientBoostedTreesModel
RandomForestModel
FloatRDD
PairRDD
RDD
Column
DataFrame
DataFrameNaFunctions
DataFrameReader
DataFrameStatFunctions
DataFrameWriter
Encoder
Encoders
functions
GroupedData
RelationalGroupedDataset
Row
RowFactory
SparkSession
SQLContext
SQLContextQueryExecution
SqlDate
SqlTimestamp
DataStreamReader
DataStreamWriter
SinkStatus
SourceStatus
StreamingQuery
StreamingQueryInfo
StreamingQueryListener
StreamingQueryManager
DataTypes
Metadata
StructField
StructType
StorageLevel
Duration
StreamingContext
DStream
PairDStream
KafkaUtils
TwitterAuthorization
TwitterUtils
ReceiverInputDStream
Global
handleArguments