[09/51] [partial] spark-website git commit: Add 2.1.2 docs
http://git-wip-us.apache.org/repos/asf/spark-website/blob/a6155a89/site/docs/2.1.2/api/java/org/apache/spark/api/java/JavaRDD.html -- diff --git a/site/docs/2.1.2/api/java/org/apache/spark/api/java/JavaRDD.html b/site/docs/2.1.2/api/java/org/apache/spark/api/java/JavaRDD.html new file mode 100644 index 000..a7004a5 --- /dev/null +++ b/site/docs/2.1.2/api/java/org/apache/spark/api/java/JavaRDD.html @@ -0,0 +1,1854 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + + + +JavaRDD (Spark 2.1.2 JavaDoc) + + + + + + + +JavaScript is disabled on your browser. + + + + + + + + +Overview +Package +Class +Tree +Deprecated +Index +Help + + + + +Prev Class +Next Class + + +Frames +No Frames + + +All Classes + + + + + + + +Summary: +Nested| +Field| +Constr| +Method + + +Detail: +Field| +Constr| +Method + + + + + + + + +org.apache.spark.api.java +Class JavaRDDT + + + +Object + + +org.apache.spark.api.java.JavaRDDT + + + + + + + +All Implemented Interfaces: +java.io.Serializable, JavaRDDLikeT,JavaRDDT + + + +public class JavaRDDT +extends Object +See Also:Serialized Form + + + + + + + + + + + +Constructor Summary + +Constructors + +Constructor and Description + + +JavaRDD(RDDTrdd, + scala.reflect.ClassTagTclassTag) + + + + + + + + + +Method Summary + +Methods + +Modifier and Type +Method and Description + + +static UU +aggregate(UzeroValue, + Function2U,T,UseqOp, + Function2U,U,UcombOp) + + +JavaRDDT +cache() +Persist this RDD with the default storage level (MEMORY_ONLY). + + + +static UJavaPairRDDT,U +cartesian(JavaRDDLikeU,?other) + + +static void +checkpoint() + + +scala.reflect.ClassTagT +classTag() + + +JavaRDDT +coalesce(intnumPartitions) +Return a new RDD that is reduced into numPartitions partitions. + + + +JavaRDDT +coalesce(intnumPartitions, +booleanshuffle) +Return a new RDD that is reduced into numPartitions partitions. + + + +static java.util.ListT +collect() + + +static JavaFutureActionjava.util.ListT +collectAsync() + + +static java.util.ListT[] +collectPartitions(int[]partitionIds) + + +static SparkContext +context() + + +static long +count() + + +static PartialResultBoundedDouble +countApprox(longtimeout) + + +static PartialResultBoundedDouble +countApprox(longtimeout, + doubleconfidence) + + +static long +countApproxDistinct(doublerelativeSD) + + +static JavaFutureActionLong +countAsync() + + +static java.util.MapT,Long +countByValue() + + +static PartialResultjava.util.MapT,BoundedDouble +countByValueApprox(longtimeout) + + +static PartialResultjava.util.MapT,BoundedDouble +countByValueApprox(longtimeout, + doubleconfidence) + + +JavaRDDT +distinct() +Return a new RDD containing the distinct elements in this RDD. + + + +JavaRDDT +distinct(intnumPartitions) +Return a new RDD containing the distinct elements in this RDD. + + + +JavaRDDT +filter(FunctionT,Booleanf) +Return a new RDD containing only the elements that satisfy a predicate. + + + +static T +first() + + +static UJavaRDDU +flatMap(FlatMapFunctionT,Uf) + + +static JavaDoubleRDD +flatMapToDouble(DoubleFlatMapFunctionTf) + + +static K2,V2JavaPairRDDK2,V2 +flatMapToPair(PairFlatMapFunctionT,K2,V2f) + + +static T +fold(TzeroValue, +Function2T,T,Tf) + + +static void +foreach(VoidFunctionTf) + + +static JavaFutureActionVoid +foreachAsync(VoidFunctionTf) + + +static void +foreachPartition(VoidFunctionjava.util.IteratorTf) + + +static JavaFutureActionVoid +foreachPartitionAsync(VoidFunctionjava.util.IteratorTf) + + +static TJavaRDDT +fromRDD(RDDTrdd, + scala.reflect.ClassTagTevidence$1) + + +static OptionalString +getCheckpointFile() + + +static int +getNumPartitions() + + +static StorageLevel +getStorageLevel() + + +static JavaRDDjava.util.ListT +glom() + + +static UJavaPairRDDU,IterableT +groupBy(FunctionT,Uf) + + +static UJavaPairRDDU,IterableT +groupBy(FunctionT,Uf, + intnumPartitions) + + +static int +id() + + +JavaRDDT +intersection(JavaRDDTother) +Return the intersection of this RDD and another one. + + + +static boolean +isCheckpointed() + + +static boolean +isEmpty() + + +static java.util.IteratorT +iterator(Partitionsplit, +TaskContexttaskContext) + + +static UJavaPairRDDU,T +keyBy(FunctionT,Uf) + + +static RJavaRDDR +map(FunctionT,Rf) + + +static UJavaRDDU +mapPartitions(FlatMapFunctionjava.util.IteratorT,Uf) + + +static UJavaRDDU +mapPartitions(FlatMapFunctionjava.util.IteratorT,Uf, + booleanpreservesPartitioning) + + +static JavaDoubleRDD
[09/51] [partial] spark-website git commit: Add 2.1.2 docs
http://git-wip-us.apache.org/repos/asf/spark-website/blob/a6d9cbde/site/docs/2.1.2/api/java/org/apache/spark/api/java/JavaRDD.html -- diff --git a/site/docs/2.1.2/api/java/org/apache/spark/api/java/JavaRDD.html b/site/docs/2.1.2/api/java/org/apache/spark/api/java/JavaRDD.html new file mode 100644 index 000..a7004a5 --- /dev/null +++ b/site/docs/2.1.2/api/java/org/apache/spark/api/java/JavaRDD.html @@ -0,0 +1,1854 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + + + +JavaRDD (Spark 2.1.2 JavaDoc) + + + + + + + +JavaScript is disabled on your browser. + + + + + + + + +Overview +Package +Class +Tree +Deprecated +Index +Help + + + + +Prev Class +Next Class + + +Frames +No Frames + + +All Classes + + + + + + + +Summary: +Nested| +Field| +Constr| +Method + + +Detail: +Field| +Constr| +Method + + + + + + + + +org.apache.spark.api.java +Class JavaRDDT + + + +Object + + +org.apache.spark.api.java.JavaRDDT + + + + + + + +All Implemented Interfaces: +java.io.Serializable, JavaRDDLikeT,JavaRDDT + + + +public class JavaRDDT +extends Object +See Also:Serialized Form + + + + + + + + + + + +Constructor Summary + +Constructors + +Constructor and Description + + +JavaRDD(RDDTrdd, + scala.reflect.ClassTagTclassTag) + + + + + + + + + +Method Summary + +Methods + +Modifier and Type +Method and Description + + +static UU +aggregate(UzeroValue, + Function2U,T,UseqOp, + Function2U,U,UcombOp) + + +JavaRDDT +cache() +Persist this RDD with the default storage level (MEMORY_ONLY). + + + +static UJavaPairRDDT,U +cartesian(JavaRDDLikeU,?other) + + +static void +checkpoint() + + +scala.reflect.ClassTagT +classTag() + + +JavaRDDT +coalesce(intnumPartitions) +Return a new RDD that is reduced into numPartitions partitions. + + + +JavaRDDT +coalesce(intnumPartitions, +booleanshuffle) +Return a new RDD that is reduced into numPartitions partitions. + + + +static java.util.ListT +collect() + + +static JavaFutureActionjava.util.ListT +collectAsync() + + +static java.util.ListT[] +collectPartitions(int[]partitionIds) + + +static SparkContext +context() + + +static long +count() + + +static PartialResultBoundedDouble +countApprox(longtimeout) + + +static PartialResultBoundedDouble +countApprox(longtimeout, + doubleconfidence) + + +static long +countApproxDistinct(doublerelativeSD) + + +static JavaFutureActionLong +countAsync() + + +static java.util.MapT,Long +countByValue() + + +static PartialResultjava.util.MapT,BoundedDouble +countByValueApprox(longtimeout) + + +static PartialResultjava.util.MapT,BoundedDouble +countByValueApprox(longtimeout, + doubleconfidence) + + +JavaRDDT +distinct() +Return a new RDD containing the distinct elements in this RDD. + + + +JavaRDDT +distinct(intnumPartitions) +Return a new RDD containing the distinct elements in this RDD. + + + +JavaRDDT +filter(FunctionT,Booleanf) +Return a new RDD containing only the elements that satisfy a predicate. + + + +static T +first() + + +static UJavaRDDU +flatMap(FlatMapFunctionT,Uf) + + +static JavaDoubleRDD +flatMapToDouble(DoubleFlatMapFunctionTf) + + +static K2,V2JavaPairRDDK2,V2 +flatMapToPair(PairFlatMapFunctionT,K2,V2f) + + +static T +fold(TzeroValue, +Function2T,T,Tf) + + +static void +foreach(VoidFunctionTf) + + +static JavaFutureActionVoid +foreachAsync(VoidFunctionTf) + + +static void +foreachPartition(VoidFunctionjava.util.IteratorTf) + + +static JavaFutureActionVoid +foreachPartitionAsync(VoidFunctionjava.util.IteratorTf) + + +static TJavaRDDT +fromRDD(RDDTrdd, + scala.reflect.ClassTagTevidence$1) + + +static OptionalString +getCheckpointFile() + + +static int +getNumPartitions() + + +static StorageLevel +getStorageLevel() + + +static JavaRDDjava.util.ListT +glom() + + +static UJavaPairRDDU,IterableT +groupBy(FunctionT,Uf) + + +static UJavaPairRDDU,IterableT +groupBy(FunctionT,Uf, + intnumPartitions) + + +static int +id() + + +JavaRDDT +intersection(JavaRDDTother) +Return the intersection of this RDD and another one. + + + +static boolean +isCheckpointed() + + +static boolean +isEmpty() + + +static java.util.IteratorT +iterator(Partitionsplit, +TaskContexttaskContext) + + +static UJavaPairRDDU,T +keyBy(FunctionT,Uf) + + +static RJavaRDDR +map(FunctionT,Rf) + + +static UJavaRDDU +mapPartitions(FlatMapFunctionjava.util.IteratorT,Uf) + + +static UJavaRDDU +mapPartitions(FlatMapFunctionjava.util.IteratorT,Uf, + booleanpreservesPartitioning) + + +static JavaDoubleRDD
[09/51] [partial] spark-website git commit: Add 2.1.2 docs
http://git-wip-us.apache.org/repos/asf/spark-website/blob/0b563c84/site/docs/2.1.2/api/java/org/apache/spark/api/java/JavaRDD.html -- diff --git a/site/docs/2.1.2/api/java/org/apache/spark/api/java/JavaRDD.html b/site/docs/2.1.2/api/java/org/apache/spark/api/java/JavaRDD.html new file mode 100644 index 000..a7004a5 --- /dev/null +++ b/site/docs/2.1.2/api/java/org/apache/spark/api/java/JavaRDD.html @@ -0,0 +1,1854 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + + + +JavaRDD (Spark 2.1.2 JavaDoc) + + + + + + + +JavaScript is disabled on your browser. + + + + + + + + +Overview +Package +Class +Tree +Deprecated +Index +Help + + + + +Prev Class +Next Class + + +Frames +No Frames + + +All Classes + + + + + + + +Summary: +Nested| +Field| +Constr| +Method + + +Detail: +Field| +Constr| +Method + + + + + + + + +org.apache.spark.api.java +Class JavaRDDT + + + +Object + + +org.apache.spark.api.java.JavaRDDT + + + + + + + +All Implemented Interfaces: +java.io.Serializable, JavaRDDLikeT,JavaRDDT + + + +public class JavaRDDT +extends Object +See Also:Serialized Form + + + + + + + + + + + +Constructor Summary + +Constructors + +Constructor and Description + + +JavaRDD(RDDTrdd, + scala.reflect.ClassTagTclassTag) + + + + + + + + + +Method Summary + +Methods + +Modifier and Type +Method and Description + + +static UU +aggregate(UzeroValue, + Function2U,T,UseqOp, + Function2U,U,UcombOp) + + +JavaRDDT +cache() +Persist this RDD with the default storage level (MEMORY_ONLY). + + + +static UJavaPairRDDT,U +cartesian(JavaRDDLikeU,?other) + + +static void +checkpoint() + + +scala.reflect.ClassTagT +classTag() + + +JavaRDDT +coalesce(intnumPartitions) +Return a new RDD that is reduced into numPartitions partitions. + + + +JavaRDDT +coalesce(intnumPartitions, +booleanshuffle) +Return a new RDD that is reduced into numPartitions partitions. + + + +static java.util.ListT +collect() + + +static JavaFutureActionjava.util.ListT +collectAsync() + + +static java.util.ListT[] +collectPartitions(int[]partitionIds) + + +static SparkContext +context() + + +static long +count() + + +static PartialResultBoundedDouble +countApprox(longtimeout) + + +static PartialResultBoundedDouble +countApprox(longtimeout, + doubleconfidence) + + +static long +countApproxDistinct(doublerelativeSD) + + +static JavaFutureActionLong +countAsync() + + +static java.util.MapT,Long +countByValue() + + +static PartialResultjava.util.MapT,BoundedDouble +countByValueApprox(longtimeout) + + +static PartialResultjava.util.MapT,BoundedDouble +countByValueApprox(longtimeout, + doubleconfidence) + + +JavaRDDT +distinct() +Return a new RDD containing the distinct elements in this RDD. + + + +JavaRDDT +distinct(intnumPartitions) +Return a new RDD containing the distinct elements in this RDD. + + + +JavaRDDT +filter(FunctionT,Booleanf) +Return a new RDD containing only the elements that satisfy a predicate. + + + +static T +first() + + +static UJavaRDDU +flatMap(FlatMapFunctionT,Uf) + + +static JavaDoubleRDD +flatMapToDouble(DoubleFlatMapFunctionTf) + + +static K2,V2JavaPairRDDK2,V2 +flatMapToPair(PairFlatMapFunctionT,K2,V2f) + + +static T +fold(TzeroValue, +Function2T,T,Tf) + + +static void +foreach(VoidFunctionTf) + + +static JavaFutureActionVoid +foreachAsync(VoidFunctionTf) + + +static void +foreachPartition(VoidFunctionjava.util.IteratorTf) + + +static JavaFutureActionVoid +foreachPartitionAsync(VoidFunctionjava.util.IteratorTf) + + +static TJavaRDDT +fromRDD(RDDTrdd, + scala.reflect.ClassTagTevidence$1) + + +static OptionalString +getCheckpointFile() + + +static int +getNumPartitions() + + +static StorageLevel +getStorageLevel() + + +static JavaRDDjava.util.ListT +glom() + + +static UJavaPairRDDU,IterableT +groupBy(FunctionT,Uf) + + +static UJavaPairRDDU,IterableT +groupBy(FunctionT,Uf, + intnumPartitions) + + +static int +id() + + +JavaRDDT +intersection(JavaRDDTother) +Return the intersection of this RDD and another one. + + + +static boolean +isCheckpointed() + + +static boolean +isEmpty() + + +static java.util.IteratorT +iterator(Partitionsplit, +TaskContexttaskContext) + + +static UJavaPairRDDU,T +keyBy(FunctionT,Uf) + + +static RJavaRDDR +map(FunctionT,Rf) + + +static UJavaRDDU +mapPartitions(FlatMapFunctionjava.util.IteratorT,Uf) + + +static UJavaRDDU +mapPartitions(FlatMapFunctionjava.util.IteratorT,Uf, + booleanpreservesPartitioning) + + +static JavaDoubleRDD