- shutdown(Configuration) - Method in class org.apache.mrql.SparkEvaluator
-
shutdown the Spark evaluator
- size(Configuration) - Method in class org.apache.mrql.RDDDataSource
-
- size - Variable in class org.apache.mrql.SparkGeneratorInputFormat.GeneratorRecordReader
-
- slideDuration() - Method in class org.apache.mrql.SparkFileInputStream.MRDataInputStream
-
- slideDuration() - Method in class org.apache.mrql.SparkSocketStream.MRDataSocketStream
-
- spark_context - Static variable in class org.apache.mrql.SparkEvaluator
-
- SparkBinaryInputFormat - Class in org.apache.mrql
-
Input format for hadoop sequence files
- SparkBinaryInputFormat() - Constructor for class org.apache.mrql.SparkBinaryInputFormat
-
- SparkBinaryInputFormat.BinaryInputRecordReader - Class in org.apache.mrql
-
- SparkEvaluator - Class in org.apache.mrql
-
Evaluates physical plans in Apache Spark mode
- SparkEvaluator() - Constructor for class org.apache.mrql.SparkEvaluator
-
- SparkFileInputStream - Class in org.apache.mrql
-
A Spark InputDStream for MRQL InputFormats
- SparkFileInputStream(JavaStreamingContext, String, boolean) - Constructor for class org.apache.mrql.SparkFileInputStream
-
- SparkFileInputStream.MRDataInputStream - Class in org.apache.mrql
-
- SparkGeneratorInputFormat - Class in org.apache.mrql
-
the FileInputFormat for data generators: it creates HDFS files, where each file contains
an (offset,size) pair that generates the range of values [offset,offset+size]
- SparkGeneratorInputFormat() - Constructor for class org.apache.mrql.SparkGeneratorInputFormat
-
- SparkGeneratorInputFormat.GeneratorRecordReader - Class in org.apache.mrql
-
- SparkMRQLFileInputFormat - Class in org.apache.mrql
-
A superclass for all MRQL FileInputFormats
- SparkMRQLFileInputFormat() - Constructor for class org.apache.mrql.SparkMRQLFileInputFormat
-
- SparkParsedInputFormat - Class in org.apache.mrql
-
A FileInputFormat for text files (CVS, XML, JSON, ...)
- SparkParsedInputFormat() - Constructor for class org.apache.mrql.SparkParsedInputFormat
-
- SparkParsedInputFormat.ParsedRecordReader - Class in org.apache.mrql
-
- SparkSocketStream - Class in org.apache.mrql
-
A Spark InputDStream for a stream socket
- SparkSocketStream(JavaStreamingContext, String, int, String, Trees) - Constructor for class org.apache.mrql.SparkSocketStream
-
- SparkSocketStream.MRDataSocketStream - Class in org.apache.mrql
-
- SparkStreaming - Class in org.apache.mrql
-
Evaluates physical plans in Apache Spark stream mode
- SparkStreaming() - Constructor for class org.apache.mrql.SparkStreaming
-
- start() - Method in class org.apache.mrql.SparkFileInputStream.MRDataInputStream
-
- start - Variable in class org.apache.mrql.SparkParsedInputFormat.ParsedRecordReader
-
- start() - Method in class org.apache.mrql.SparkSocketStream.MRDataSocketStream
-
- stop() - Method in class org.apache.mrql.SparkFileInputStream.MRDataInputStream
-
- stop() - Method in class org.apache.mrql.SparkSocketStream.MRDataSocketStream
-
- stream_context - Static variable in class org.apache.mrql.SparkEvaluator
-
- streaming(Tree, Environment, Function) - Method in class org.apache.mrql.SparkEvaluator
-
evaluate plan in stream mode: evaluate each batch of data and apply the function f