Binary compatibility report for the spark-cassandra-connector_2.11-1.5.0-M3 library between 1.5.0 and 1.3.0 versions (relating to the portability of client application spark-cassandra-connector_2.11-1.5.0-M3.jar)
Test Info
Library Name | spark-cassandra-connector_2.11-1.5.0-M3 |
Version #1 | 1.5.0 |
Version #2 | 1.3.0 |
Java Version | 1.7.0_85 |
Test Results
Total Java ARchives | 7 |
---|
Total Methods / Classes | 1365 / 4125 |
---|
Verdict | Incompatible (19.8%) |
Problem Summary
| Severity | Count |
---|
Added Methods | - | 29 |
---|
Removed Methods | High | 187 |
---|
Problems with Data Types | High | 24 |
---|
Medium | 5 |
Low | 1 |
Problems with Methods | High | 0 |
---|
Medium | 0 |
Low | 0 |
Other Changes in Data Types | - | 1 |
Added Methods (29)
spark-catalyst_2.11-1.3.0.jar, Catalog.class
package org.apache.spark.sql.catalyst.analysis
Catalog.caseSensitive ( ) [abstract] : boolean
[mangled: org/apache/spark/sql/catalyst/analysis/Catalog.caseSensitive:()Z]
Catalog.refreshTable ( String p1, String p2 ) [abstract] : void
[mangled: org/apache/spark/sql/catalyst/analysis/Catalog.refreshTable:(Ljava/lang/String;Ljava/lang/String;)V]
spark-catalyst_2.11-1.3.0.jar, Expression.class
package org.apache.spark.sql.catalyst.expressions
Expression.eval ( org.apache.spark.sql.Row p1 ) [abstract] : Object
[mangled: org/apache/spark/sql/catalyst/expressions/Expression.eval:(Lorg/apache/spark/sql/Row;)Ljava/lang/Object;]
spark-catalyst_2.11-1.3.0.jar, LogicalPlan.class
package org.apache.spark.sql.catalyst.plans.logical
LogicalPlan.LogicalPlan..resolveAsColumn ( String[ ] nameParts, scala.Function2<String,String,Object> resolver, org.apache.spark.sql.catalyst.expressions.Attribute attribute ) : scala.Option<scala.Tuple2<org.apache.spark.sql.catalyst.expressions.Attribute,scala.collection.immutable.List<String>>>
[mangled: org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.org.apache.spark.sql.catalyst.plans.logical.LogicalPlan..resolveAsColumn:([Ljava/lang/String;Lscala/Function2;Lorg/apache/spark/sql/catalyst/expressions/Attribute;)Lscala/Option;]
LogicalPlan.LogicalPlan..resolveAsTableColumn ( String[ ] nameParts, scala.Function2<String,String,Object> resolver, org.apache.spark.sql.catalyst.expressions.Attribute attribute ) : scala.Option<scala.Tuple2<org.apache.spark.sql.catalyst.expressions.Attribute,scala.collection.immutable.List<String>>>
[mangled: org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.org.apache.spark.sql.catalyst.plans.logical.LogicalPlan..resolveAsTableColumn:([Ljava/lang/String;Lscala/Function2;Lorg/apache/spark/sql/catalyst/expressions/Attribute;)Lscala/Option;]
LogicalPlan.resolve ( String name, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> input, scala.Function2<String,String,Object> resolver ) : scala.Option<org.apache.spark.sql.catalyst.expressions.NamedExpression>
[mangled: org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.resolve:(Ljava/lang/String;Lscala/collection/Seq;Lscala/Function2;)Lscala/Option;]
LogicalPlan.resolve ( String name, scala.Function2<String,String,Object> resolver ) : scala.Option<org.apache.spark.sql.catalyst.expressions.NamedExpression>
[mangled: org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.resolve:(Ljava/lang/String;Lscala/Function2;)Lscala/Option;]
LogicalPlan.resolveChildren ( String name, scala.Function2<String,String,Object> resolver ) : scala.Option<org.apache.spark.sql.catalyst.expressions.NamedExpression>
[mangled: org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.resolveChildren:(Ljava/lang/String;Lscala/Function2;)Lscala/Option;]
spark-core_2.11-1.3.0.jar, RDD<T>.class
package org.apache.spark.rdd
RDD<T>.markCheckpointed ( RDD<?> checkpointRDD ) : void
[mangled: org/apache/spark/rdd/RDD<T>.markCheckpointed:(Lorg/apache/spark/rdd/RDD;)V]
spark-core_2.11-1.3.0.jar, SparkConf.class
package org.apache.spark
SparkConf.translateConfKey ( String p1, boolean p2 ) [static] : String
[mangled: org/apache/spark/SparkConf.translateConfKey:(Ljava/lang/String;Z)Ljava/lang/String;]
spark-core_2.11-1.3.0.jar, SparkContext.class
package org.apache.spark
SparkContext.requestTotalExecutors ( int numExecutors ) : boolean
[mangled: org/apache/spark/SparkContext.requestTotalExecutors:(I)Z]
spark-sql_2.11-1.3.0.jar, DataFrame.class
package org.apache.spark.sql
DataFrame.cache ( ) : RDDApi
[mangled: org/apache/spark/sql/DataFrame.cache:()Lorg/apache/spark/sql/RDDApi;]
DataFrame.collect ( ) : Object
[mangled: org/apache/spark/sql/DataFrame.collect:()Ljava/lang/Object;]
DataFrame.first ( ) : Object
[mangled: org/apache/spark/sql/DataFrame.first:()Ljava/lang/Object;]
DataFrame.persist ( ) : RDDApi
[mangled: org/apache/spark/sql/DataFrame.persist:()Lorg/apache/spark/sql/RDDApi;]
DataFrame.persist ( org.apache.spark.storage.StorageLevel newLevel ) : RDDApi
[mangled: org/apache/spark/sql/DataFrame.persist:(Lorg/apache/spark/storage/StorageLevel;)Lorg/apache/spark/sql/RDDApi;]
DataFrame.showString ( int numRows ) : String
[mangled: org/apache/spark/sql/DataFrame.showString:(I)Ljava/lang/String;]
DataFrame.take ( int n ) : Object
[mangled: org/apache/spark/sql/DataFrame.take:(I)Ljava/lang/Object;]
DataFrame.unpersist ( ) : RDDApi
[mangled: org/apache/spark/sql/DataFrame.unpersist:()Lorg/apache/spark/sql/RDDApi;]
DataFrame.unpersist ( boolean blocking ) : RDDApi
[mangled: org/apache/spark/sql/DataFrame.unpersist:(Z)Lorg/apache/spark/sql/RDDApi;]
spark-sql_2.11-1.3.0.jar, SQLContext.class
package org.apache.spark.sql
SQLContext.cacheManager ( ) : CacheManager
[mangled: org/apache/spark/sql/SQLContext.cacheManager:()Lorg/apache/spark/sql/CacheManager;]
SQLContext.checkAnalysis ( ) : catalyst.analysis.CheckAnalysis
[mangled: org/apache/spark/sql/SQLContext.checkAnalysis:()Lorg/apache/spark/sql/catalyst/analysis/CheckAnalysis;]
SQLContext.createDataFrame ( org.apache.spark.api.java.JavaRDD<Row> rowRDD, java.util.List<String> columns ) : DataFrame
[mangled: org/apache/spark/sql/SQLContext.createDataFrame:(Lorg/apache/spark/api/java/JavaRDD;Ljava/util/List;)Lorg/apache/spark/sql/DataFrame;]
SQLContext.ddlParser ( ) : sources.DDLParser
[mangled: org/apache/spark/sql/SQLContext.ddlParser:()Lorg/apache/spark/sql/sources/DDLParser;]
spark-streaming_2.11-1.3.0.jar, DStream<T>.class
package org.apache.spark.streaming.dstream
DStream<T>.validate ( ) : void
[mangled: org/apache/spark/streaming/dstream/DStream<T>.validate:()V]
spark-streaming_2.11-1.3.0.jar, StreamingContext.class
package org.apache.spark.streaming
StreamingContext.getNewReceiverStreamId ( ) : int
[mangled: org/apache/spark/streaming/StreamingContext.getNewReceiverStreamId:()I]
StreamingContext.state ( ) : scala.Enumeration.Value
[mangled: org/apache/spark/streaming/StreamingContext.state:()Lscala/Enumeration$Value;]
StreamingContext.state_.eq ( scala.Enumeration.Value p1 ) : void
[mangled: org/apache/spark/streaming/StreamingContext.state_.eq:(Lscala/Enumeration$Value;)V]
StreamingContext.StreamingContextState ( ) : StreamingContext.StreamingContextState.
[mangled: org/apache/spark/streaming/StreamingContext.StreamingContextState:()Lorg/apache/spark/streaming/StreamingContext$StreamingContextState$;]
to the top
Removed Methods (187)
spark-catalyst_2.11-1.5.0.jar, Catalog.class
package org.apache.spark.sql.catalyst.analysis
Catalog.checkTableIdentifier ( scala.collection.Seq<String> p1 ) [abstract] : void
[mangled: org/apache/spark/sql/catalyst/analysis/Catalog.checkTableIdentifier:(Lscala/collection/Seq;)V]
Catalog.conf ( ) [abstract] : org.apache.spark.sql.catalyst.CatalystConf
[mangled: org/apache/spark/sql/catalyst/analysis/Catalog.conf:()Lorg/apache/spark/sql/catalyst/CatalystConf;]
Catalog.refreshTable ( org.apache.spark.sql.catalyst.TableIdentifier p1 ) [abstract] : void
[mangled: org/apache/spark/sql/catalyst/analysis/Catalog.refreshTable:(Lorg/apache/spark/sql/catalyst/TableIdentifier;)V]
spark-catalyst_2.11-1.5.0.jar, DecimalType.class
package org.apache.spark.sql.types
DecimalType.DecimalType ( int precision, int scale )
[mangled: org/apache/spark/sql/types/DecimalType."<init>":(II)V]
spark-catalyst_2.11-1.5.0.jar, Expression.class
package org.apache.spark.sql.catalyst.expressions
Expression.checkInputDataTypes ( ) : org.apache.spark.sql.catalyst.analysis.TypeCheckResult
[mangled: org/apache/spark/sql/catalyst/expressions/Expression.checkInputDataTypes:()Lorg/apache/spark/sql/catalyst/analysis/TypeCheckResult;]
Expression.deterministic ( ) : boolean
[mangled: org/apache/spark/sql/catalyst/expressions/Expression.deterministic:()Z]
Expression.eval ( org.apache.spark.sql.catalyst.InternalRow p1 ) [abstract] : Object
[mangled: org/apache/spark/sql/catalyst/expressions/Expression.eval:(Lorg/apache/spark/sql/catalyst/InternalRow;)Ljava/lang/Object;]
Expression.gen ( codegen.CodeGenContext ctx ) : codegen.GeneratedExpressionCode
[mangled: org/apache/spark/sql/catalyst/expressions/Expression.gen:(Lorg/apache/spark/sql/catalyst/expressions/codegen/CodeGenContext;)Lorg/apache/spark/sql/catalyst/expressions/codegen/GeneratedExpressionCode;]
Expression.genCode ( codegen.CodeGenContext p1, codegen.GeneratedExpressionCode p2 ) [abstract] : String
[mangled: org/apache/spark/sql/catalyst/expressions/Expression.genCode:(Lorg/apache/spark/sql/catalyst/expressions/codegen/CodeGenContext;Lorg/apache/spark/sql/catalyst/expressions/codegen/GeneratedExpressionCode;)Ljava/lang/String;]
Expression.prettyName ( ) : String
[mangled: org/apache/spark/sql/catalyst/expressions/Expression.prettyName:()Ljava/lang/String;]
Expression.semanticEquals ( Expression other ) : boolean
[mangled: org/apache/spark/sql/catalyst/expressions/Expression.semanticEquals:(Lorg/apache/spark/sql/catalyst/expressions/Expression;)Z]
Expression.toString ( ) : String
[mangled: org/apache/spark/sql/catalyst/expressions/Expression.toString:()Ljava/lang/String;]
spark-catalyst_2.11-1.5.0.jar, LogicalPlan.class
package org.apache.spark.sql.catalyst.plans.logical
LogicalPlan.analyzed ( ) : boolean
[mangled: org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.analyzed:()Z]
LogicalPlan.LogicalPlan..resolveAsColumn ( scala.collection.Seq<String> nameParts, scala.Function2<String,String,Object> resolver, org.apache.spark.sql.catalyst.expressions.Attribute attribute ) : scala.Option<scala.Tuple2<org.apache.spark.sql.catalyst.expressions.Attribute,scala.collection.immutable.List<String>>>
[mangled: org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.org.apache.spark.sql.catalyst.plans.logical.LogicalPlan..resolveAsColumn:(Lscala/collection/Seq;Lscala/Function2;Lorg/apache/spark/sql/catalyst/expressions/Attribute;)Lscala/Option;]
LogicalPlan.LogicalPlan..resolveAsTableColumn ( scala.collection.Seq<String> nameParts, scala.Function2<String,String,Object> resolver, org.apache.spark.sql.catalyst.expressions.Attribute attribute ) : scala.Option<scala.Tuple2<org.apache.spark.sql.catalyst.expressions.Attribute,scala.collection.immutable.List<String>>>
[mangled: org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.org.apache.spark.sql.catalyst.plans.logical.LogicalPlan..resolveAsTableColumn:(Lscala/collection/Seq;Lscala/Function2;Lorg/apache/spark/sql/catalyst/expressions/Attribute;)Lscala/Option;]
LogicalPlan.resolve ( scala.collection.Seq<String> nameParts, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> input, scala.Function2<String,String,Object> resolver ) : scala.Option<org.apache.spark.sql.catalyst.expressions.NamedExpression>
[mangled: org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.resolve:(Lscala/collection/Seq;Lscala/collection/Seq;Lscala/Function2;)Lscala/Option;]
LogicalPlan.resolve ( scala.collection.Seq<String> nameParts, scala.Function2<String,String,Object> resolver ) : scala.Option<org.apache.spark.sql.catalyst.expressions.NamedExpression>
[mangled: org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.resolve:(Lscala/collection/Seq;Lscala/Function2;)Lscala/Option;]
LogicalPlan.resolveChildren ( scala.collection.Seq<String> nameParts, scala.Function2<String,String,Object> resolver ) : scala.Option<org.apache.spark.sql.catalyst.expressions.NamedExpression>
[mangled: org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.resolveChildren:(Lscala/collection/Seq;Lscala/Function2;)Lscala/Option;]
LogicalPlan.resolveExpressions ( scala.PartialFunction<org.apache.spark.sql.catalyst.expressions.Expression,org.apache.spark.sql.catalyst.expressions.Expression> r ) : LogicalPlan
[mangled: org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.resolveExpressions:(Lscala/PartialFunction;)Lorg/apache/spark/sql/catalyst/plans/logical/LogicalPlan;]
LogicalPlan.resolveOperators ( scala.PartialFunction<LogicalPlan,LogicalPlan> rule ) : LogicalPlan
[mangled: org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.resolveOperators:(Lscala/PartialFunction;)Lorg/apache/spark/sql/catalyst/plans/logical/LogicalPlan;]
LogicalPlan.resolveQuoted ( String name, scala.Function2<String,String,Object> resolver ) : scala.Option<org.apache.spark.sql.catalyst.expressions.NamedExpression>
[mangled: org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.resolveQuoted:(Ljava/lang/String;Lscala/Function2;)Lscala/Option;]
LogicalPlan.setAnalyzed ( ) : void
[mangled: org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.setAnalyzed:()V]
spark-catalyst_2.11-1.5.0.jar, Row.class
package org.apache.spark.sql
Row.fieldIndex ( String p1 ) [abstract] : int
[mangled: org/apache/spark/sql/Row.fieldIndex:(Ljava/lang/String;)I]
Row.getAs ( String p1 ) [abstract] : T
[mangled: org/apache/spark/sql/Row.getAs:(Ljava/lang/String;)Ljava/lang/Object;]
Row.getTimestamp ( int p1 ) [abstract] : java.sql.Timestamp
[mangled: org/apache/spark/sql/Row.getTimestamp:(I)Ljava/sql/Timestamp;]
Row.getValuesMap ( scala.collection.Seq<String> p1 ) [abstract] : scala.collection.immutable.Map<String,T>
[mangled: org/apache/spark/sql/Row.getValuesMap:(Lscala/collection/Seq;)Lscala/collection/immutable/Map;]
spark-catalyst_2.11-1.5.0.jar, SimpleCatalystConf.class
package org.apache.spark.sql.catalyst
SimpleCatalystConf.SimpleCatalystConf ( boolean caseSensitiveAnalysis )
[mangled: org/apache/spark/sql/catalyst/SimpleCatalystConf."<init>":(Z)V]
spark-catalyst_2.11-1.5.0.jar, StructType.class
package org.apache.spark.sql.types
StructType.add ( StructField field ) : StructType
[mangled: org/apache/spark/sql/types/StructType.add:(Lorg/apache/spark/sql/types/StructField;)Lorg/apache/spark/sql/types/StructType;]
StructType.add ( String name, DataType dataType ) : StructType
[mangled: org/apache/spark/sql/types/StructType.add:(Ljava/lang/String;Lorg/apache/spark/sql/types/DataType;)Lorg/apache/spark/sql/types/StructType;]
StructType.add ( String name, DataType dataType, boolean nullable ) : StructType
[mangled: org/apache/spark/sql/types/StructType.add:(Ljava/lang/String;Lorg/apache/spark/sql/types/DataType;Z)Lorg/apache/spark/sql/types/StructType;]
StructType.add ( String name, DataType dataType, boolean nullable, Metadata metadata ) : StructType
[mangled: org/apache/spark/sql/types/StructType.add:(Ljava/lang/String;Lorg/apache/spark/sql/types/DataType;ZLorg/apache/spark/sql/types/Metadata;)Lorg/apache/spark/sql/types/StructType;]
StructType.add ( String name, String dataType ) : StructType
[mangled: org/apache/spark/sql/types/StructType.add:(Ljava/lang/String;Ljava/lang/String;)Lorg/apache/spark/sql/types/StructType;]
StructType.add ( String name, String dataType, boolean nullable ) : StructType
[mangled: org/apache/spark/sql/types/StructType.add:(Ljava/lang/String;Ljava/lang/String;Z)Lorg/apache/spark/sql/types/StructType;]
StructType.add ( String name, String dataType, boolean nullable, Metadata metadata ) : StructType
[mangled: org/apache/spark/sql/types/StructType.add:(Ljava/lang/String;Ljava/lang/String;ZLorg/apache/spark/sql/types/Metadata;)Lorg/apache/spark/sql/types/StructType;]
StructType.existsRecursively ( scala.Function1<DataType,Object> f ) : boolean
[mangled: org/apache/spark/sql/types/StructType.existsRecursively:(Lscala/Function1;)Z]
StructType.fieldIndex ( String name ) : int
[mangled: org/apache/spark/sql/types/StructType.fieldIndex:(Ljava/lang/String;)I]
StructType.getFieldIndex ( String name ) : scala.Option<Object>
[mangled: org/apache/spark/sql/types/StructType.getFieldIndex:(Ljava/lang/String;)Lscala/Option;]
StructType.interpretedOrdering ( ) : org.apache.spark.sql.catalyst.expressions.InterpretedOrdering
[mangled: org/apache/spark/sql/types/StructType.interpretedOrdering:()Lorg/apache/spark/sql/catalyst/expressions/InterpretedOrdering;]
StructType.StructType ( )
[mangled: org/apache/spark/sql/types/StructType."<init>":()V]
spark-catalyst_2.11-1.5.0.jar, TableIdentifier.class
package org.apache.spark.sql.catalyst
TableIdentifier.apply ( String p1, scala.Option<String> p2 ) [static] : TableIdentifier
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.apply:(Ljava/lang/String;Lscala/Option;)Lorg/apache/spark/sql/catalyst/TableIdentifier;]
TableIdentifier.canEqual ( Object p1 ) : boolean
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.canEqual:(Ljava/lang/Object;)Z]
TableIdentifier.copy ( String table, scala.Option<String> database ) : TableIdentifier
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.copy:(Ljava/lang/String;Lscala/Option;)Lorg/apache/spark/sql/catalyst/TableIdentifier;]
TableIdentifier.curried ( ) [static] : scala.Function1<String,scala.Function1<scala.Option<String>,TableIdentifier>>
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.curried:()Lscala/Function1;]
TableIdentifier.database ( ) : scala.Option<String>
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.database:()Lscala/Option;]
TableIdentifier.equals ( Object p1 ) : boolean
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.equals:(Ljava/lang/Object;)Z]
TableIdentifier.hashCode ( ) : int
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.hashCode:()I]
TableIdentifier.productArity ( ) : int
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.productArity:()I]
TableIdentifier.productElement ( int p1 ) : Object
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.productElement:(I)Ljava/lang/Object;]
TableIdentifier.productIterator ( ) : scala.collection.Iterator<Object>
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.productIterator:()Lscala/collection/Iterator;]
TableIdentifier.productPrefix ( ) : String
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.productPrefix:()Ljava/lang/String;]
TableIdentifier.quotedString ( ) : String
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.quotedString:()Ljava/lang/String;]
TableIdentifier.table ( ) : String
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.table:()Ljava/lang/String;]
TableIdentifier.TableIdentifier ( String table, scala.Option<String> database )
[mangled: org/apache/spark/sql/catalyst/TableIdentifier."<init>":(Ljava/lang/String;Lscala/Option;)V]
TableIdentifier.toSeq ( ) : scala.collection.Seq<String>
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.toSeq:()Lscala/collection/Seq;]
TableIdentifier.toString ( ) : String
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.toString:()Ljava/lang/String;]
TableIdentifier.tupled ( ) [static] : scala.Function1<scala.Tuple2<String,scala.Option<String>>,TableIdentifier>
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.tupled:()Lscala/Function1;]
TableIdentifier.unapply ( TableIdentifier p1 ) [static] : scala.Option<scala.Tuple2<String,scala.Option<String>>>
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.unapply:(Lorg/apache/spark/sql/catalyst/TableIdentifier;)Lscala/Option;]
TableIdentifier.unquotedString ( ) : String
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.unquotedString:()Ljava/lang/String;]
TableIdentifier.withDatabase ( String database ) : TableIdentifier
[mangled: org/apache/spark/sql/catalyst/TableIdentifier.withDatabase:(Ljava/lang/String;)Lorg/apache/spark/sql/catalyst/TableIdentifier;]
spark-core_2.11-1.5.0.jar, RDD<T>.class
package org.apache.spark.rdd
RDD<T>.isLocallyCheckpointed ( ) : boolean
[mangled: org/apache/spark/rdd/RDD<T>.isLocallyCheckpointed:()Z]
RDD<T>.localCheckpoint ( ) : RDD<T>
[mangled: org/apache/spark/rdd/RDD<T>.localCheckpoint:()Lorg/apache/spark/rdd/RDD;]
RDD<T>.markCheckpointed ( ) : void
[mangled: org/apache/spark/rdd/RDD<T>.markCheckpointed:()V]
RDD<T>.RDD..doCheckpointCalled ( ) : boolean
[mangled: org/apache/spark/rdd/RDD<T>.org.apache.spark.rdd.RDD..doCheckpointCalled:()Z]
RDD<T>.RDD..doCheckpointCalled_.eq ( boolean p1 ) : void
[mangled: org/apache/spark/rdd/RDD<T>.org.apache.spark.rdd.RDD..doCheckpointCalled_.eq:(Z)V]
RDD<T>.RDD..sc ( ) : org.apache.spark.SparkContext
[mangled: org/apache/spark/rdd/RDD<T>.org.apache.spark.rdd.RDD..sc:()Lorg/apache/spark/SparkContext;]
RDD<T>.randomSampleWithRange ( double lb, double ub, long seed ) : RDD<T>
[mangled: org/apache/spark/rdd/RDD<T>.randomSampleWithRange:(DDJ)Lorg/apache/spark/rdd/RDD;]
RDD<T>.scope ( ) : scala.Option<RDDOperationScope>
[mangled: org/apache/spark/rdd/RDD<T>.scope:()Lscala/Option;]
RDD<T>.withScope ( scala.Function0<U> body ) : U
[mangled: org/apache/spark/rdd/RDD<T>.withScope:(Lscala/Function0;)Ljava/lang/Object;]
spark-core_2.11-1.5.0.jar, SparkConf.class
package org.apache.spark
SparkConf.getAvroSchema ( ) : scala.collection.immutable.Map<Object,String>
[mangled: org/apache/spark/SparkConf.getAvroSchema:()Lscala/collection/immutable/Map;]
SparkConf.getDeprecatedConfig ( String p1, SparkConf p2 ) [static] : scala.Option<String>
[mangled: org/apache/spark/SparkConf.getDeprecatedConfig:(Ljava/lang/String;Lorg/apache/spark/SparkConf;)Lscala/Option;]
SparkConf.getSizeAsBytes ( String key ) : long
[mangled: org/apache/spark/SparkConf.getSizeAsBytes:(Ljava/lang/String;)J]
SparkConf.getSizeAsBytes ( String key, long defaultValue ) : long
[mangled: org/apache/spark/SparkConf.getSizeAsBytes:(Ljava/lang/String;J)J]
SparkConf.getSizeAsBytes ( String key, String defaultValue ) : long
[mangled: org/apache/spark/SparkConf.getSizeAsBytes:(Ljava/lang/String;Ljava/lang/String;)J]
SparkConf.getSizeAsGb ( String key ) : long
[mangled: org/apache/spark/SparkConf.getSizeAsGb:(Ljava/lang/String;)J]
SparkConf.getSizeAsGb ( String key, String defaultValue ) : long
[mangled: org/apache/spark/SparkConf.getSizeAsGb:(Ljava/lang/String;Ljava/lang/String;)J]
SparkConf.getSizeAsKb ( String key ) : long
[mangled: org/apache/spark/SparkConf.getSizeAsKb:(Ljava/lang/String;)J]
SparkConf.getSizeAsKb ( String key, String defaultValue ) : long
[mangled: org/apache/spark/SparkConf.getSizeAsKb:(Ljava/lang/String;Ljava/lang/String;)J]
SparkConf.getSizeAsMb ( String key ) : long
[mangled: org/apache/spark/SparkConf.getSizeAsMb:(Ljava/lang/String;)J]
SparkConf.getSizeAsMb ( String key, String defaultValue ) : long
[mangled: org/apache/spark/SparkConf.getSizeAsMb:(Ljava/lang/String;Ljava/lang/String;)J]
SparkConf.getTimeAsMs ( String key ) : long
[mangled: org/apache/spark/SparkConf.getTimeAsMs:(Ljava/lang/String;)J]
SparkConf.getTimeAsMs ( String key, String defaultValue ) : long
[mangled: org/apache/spark/SparkConf.getTimeAsMs:(Ljava/lang/String;Ljava/lang/String;)J]
SparkConf.getTimeAsSeconds ( String key ) : long
[mangled: org/apache/spark/SparkConf.getTimeAsSeconds:(Ljava/lang/String;)J]
SparkConf.getTimeAsSeconds ( String key, String defaultValue ) : long
[mangled: org/apache/spark/SparkConf.getTimeAsSeconds:(Ljava/lang/String;Ljava/lang/String;)J]
SparkConf.logDeprecationWarning ( String p1 ) [static] : void
[mangled: org/apache/spark/SparkConf.logDeprecationWarning:(Ljava/lang/String;)V]
SparkConf.registerAvroSchemas ( scala.collection.Seq<org.apache.avro.Schema> schemas ) : SparkConf
[mangled: org/apache/spark/SparkConf.registerAvroSchemas:(Lscala/collection/Seq;)Lorg/apache/spark/SparkConf;]
spark-core_2.11-1.5.0.jar, SparkContext.class
package org.apache.spark
SparkContext.applicationAttemptId ( ) : scala.Option<String>
[mangled: org/apache/spark/SparkContext.applicationAttemptId:()Lscala/Option;]
SparkContext.externalBlockStoreFolderName ( ) : String
[mangled: org/apache/spark/SparkContext.externalBlockStoreFolderName:()Ljava/lang/String;]
SparkContext.getOrCreate ( ) [static] : SparkContext
[mangled: org/apache/spark/SparkContext.getOrCreate:()Lorg/apache/spark/SparkContext;]
SparkContext.getOrCreate ( SparkConf p1 ) [static] : SparkContext
[mangled: org/apache/spark/SparkContext.getOrCreate:(Lorg/apache/spark/SparkConf;)Lorg/apache/spark/SparkContext;]
SparkContext.killAndReplaceExecutor ( String executorId ) : boolean
[mangled: org/apache/spark/SparkContext.killAndReplaceExecutor:(Ljava/lang/String;)Z]
SparkContext.SparkContext.._cleaner ( ) : scala.Option<ContextCleaner>
[mangled: org/apache/spark/SparkContext.org.apache.spark.SparkContext.._cleaner:()Lscala/Option;]
SparkContext.SparkContext.._conf ( ) : SparkConf
[mangled: org/apache/spark/SparkContext.org.apache.spark.SparkContext.._conf:()Lorg/apache/spark/SparkConf;]
SparkContext.SparkContext.._dagScheduler ( ) : scheduler.DAGScheduler
[mangled: org/apache/spark/SparkContext.org.apache.spark.SparkContext.._dagScheduler:()Lorg/apache/spark/scheduler/DAGScheduler;]
SparkContext.SparkContext.._env ( ) : SparkEnv
[mangled: org/apache/spark/SparkContext.org.apache.spark.SparkContext.._env:()Lorg/apache/spark/SparkEnv;]
SparkContext.SparkContext.._eventLogger ( ) : scala.Option<scheduler.EventLoggingListener>
[mangled: org/apache/spark/SparkContext.org.apache.spark.SparkContext.._eventLogger:()Lscala/Option;]
SparkContext.SparkContext.._executorAllocationManager ( ) : scala.Option<ExecutorAllocationManager>
[mangled: org/apache/spark/SparkContext.org.apache.spark.SparkContext.._executorAllocationManager:()Lscala/Option;]
SparkContext.SparkContext.._heartbeatReceiver ( ) : rpc.RpcEndpointRef
[mangled: org/apache/spark/SparkContext.org.apache.spark.SparkContext.._heartbeatReceiver:()Lorg/apache/spark/rpc/RpcEndpointRef;]
SparkContext.SparkContext.._listenerBusStarted_.eq ( boolean p1 ) : void
[mangled: org/apache/spark/SparkContext.org.apache.spark.SparkContext.._listenerBusStarted_.eq:(Z)V]
SparkContext.SparkContext.._progressBar ( ) : scala.Option<ui.ConsoleProgressBar>
[mangled: org/apache/spark/SparkContext.org.apache.spark.SparkContext.._progressBar:()Lscala/Option;]
SparkContext.SparkContext.._ui ( ) : scala.Option<ui.SparkUI>
[mangled: org/apache/spark/SparkContext.org.apache.spark.SparkContext.._ui:()Lscala/Option;]
SparkContext.SparkContext..assertNotStopped ( ) : void
[mangled: org/apache/spark/SparkContext.org.apache.spark.SparkContext..assertNotStopped:()V]
SparkContext.SparkContext..postApplicationEnd ( ) : void
[mangled: org/apache/spark/SparkContext.org.apache.spark.SparkContext..postApplicationEnd:()V]
SparkContext.range ( long start, long end, long step, int numSlices ) : rdd.RDD<Object>
[mangled: org/apache/spark/SparkContext.range:(JJJI)Lorg/apache/spark/rdd/RDD;]
SparkContext.requestTotalExecutors ( int numExecutors, int localityAwareTasks, scala.collection.immutable.Map<String,Object> hostToLocalTaskCount ) : boolean
[mangled: org/apache/spark/SparkContext.requestTotalExecutors:(IILscala/collection/immutable/Map;)Z]
SparkContext.runJob ( rdd.RDD<T> rdd, scala.Function1<scala.collection.Iterator<T>,U> func, scala.collection.Seq<Object> partitions, scala.reflect.ClassTag<U> p4 ) : Object
[mangled: org/apache/spark/SparkContext.runJob:(Lorg/apache/spark/rdd/RDD;Lscala/Function1;Lscala/collection/Seq;Lscala/reflect/ClassTag;)Ljava/lang/Object;]
SparkContext.runJob ( rdd.RDD<T> rdd, scala.Function2<TaskContext,scala.collection.Iterator<T>,U> func, scala.collection.Seq<Object> partitions, scala.Function2<Object,U,scala.runtime.BoxedUnit> resultHandler, scala.reflect.ClassTag<U> p5 ) : void
[mangled: org/apache/spark/SparkContext.runJob:(Lorg/apache/spark/rdd/RDD;Lscala/Function2;Lscala/collection/Seq;Lscala/Function2;Lscala/reflect/ClassTag;)V]
SparkContext.runJob ( rdd.RDD<T> rdd, scala.Function2<TaskContext,scala.collection.Iterator<T>,U> func, scala.collection.Seq<Object> partitions, scala.reflect.ClassTag<U> p4 ) : Object
[mangled: org/apache/spark/SparkContext.runJob:(Lorg/apache/spark/rdd/RDD;Lscala/Function2;Lscala/collection/Seq;Lscala/reflect/ClassTag;)Ljava/lang/Object;]
SparkContext.setLogLevel ( String logLevel ) : void
[mangled: org/apache/spark/SparkContext.setLogLevel:(Ljava/lang/String;)V]
SparkContext.withScope ( scala.Function0<U> body ) : U
[mangled: org/apache/spark/SparkContext.withScope:(Lscala/Function0;)Ljava/lang/Object;]
spark-core_2.11-1.5.0.jar, TaskContext.class
package org.apache.spark
TaskContext.collectAccumulators ( ) [abstract] : scala.collection.immutable.Map<Object,Object>
[mangled: org/apache/spark/TaskContext.collectAccumulators:()Lscala/collection/immutable/Map;]
TaskContext.collectInternalAccumulators ( ) [abstract] : scala.collection.immutable.Map<Object,Object>
[mangled: org/apache/spark/TaskContext.collectInternalAccumulators:()Lscala/collection/immutable/Map;]
TaskContext.getMetricsSources ( String p1 ) [abstract] : scala.collection.Seq<metrics.source.Source>
[mangled: org/apache/spark/TaskContext.getMetricsSources:(Ljava/lang/String;)Lscala/collection/Seq;]
TaskContext.getPartitionId ( ) [static] : int
[mangled: org/apache/spark/TaskContext.getPartitionId:()I]
TaskContext.internalMetricsToAccumulators ( ) [abstract] : scala.collection.immutable.Map<String,Accumulator<Object>>
[mangled: org/apache/spark/TaskContext.internalMetricsToAccumulators:()Lscala/collection/immutable/Map;]
TaskContext.registerAccumulator ( Accumulable<?,?> p1 ) [abstract] : void
[mangled: org/apache/spark/TaskContext.registerAccumulator:(Lorg/apache/spark/Accumulable;)V]
TaskContext.taskMemoryManager ( ) [abstract] : unsafe.memory.TaskMemoryManager
[mangled: org/apache/spark/TaskContext.taskMemoryManager:()Lorg/apache/spark/unsafe/memory/TaskMemoryManager;]
spark-sql_2.11-1.5.0.jar, BaseRelation.class
package org.apache.spark.sql.sources
BaseRelation.needConversion ( ) : boolean
[mangled: org/apache/spark/sql/sources/BaseRelation.needConversion:()Z]
spark-sql_2.11-1.5.0.jar, DataFrame.class
package org.apache.spark.sql
DataFrame.coalesce ( int numPartitions ) : DataFrame
[mangled: org/apache/spark/sql/DataFrame.coalesce:(I)Lorg/apache/spark/sql/DataFrame;]
DataFrame.cube ( Column... cols ) : GroupedData
[mangled: org/apache/spark/sql/DataFrame.cube:([Lorg/apache/spark/sql/Column;)Lorg/apache/spark/sql/GroupedData;]
DataFrame.cube ( scala.collection.Seq<Column> cols ) : GroupedData
[mangled: org/apache/spark/sql/DataFrame.cube:(Lscala/collection/Seq;)Lorg/apache/spark/sql/GroupedData;]
DataFrame.cube ( String col1, scala.collection.Seq<String> cols ) : GroupedData
[mangled: org/apache/spark/sql/DataFrame.cube:(Ljava/lang/String;Lscala/collection/Seq;)Lorg/apache/spark/sql/GroupedData;]
DataFrame.cube ( String col1, String... cols ) : GroupedData
[mangled: org/apache/spark/sql/DataFrame.cube:(Ljava/lang/String;[Ljava/lang/String;)Lorg/apache/spark/sql/GroupedData;]
DataFrame.describe ( scala.collection.Seq<String> cols ) : DataFrame
[mangled: org/apache/spark/sql/DataFrame.describe:(Lscala/collection/Seq;)Lorg/apache/spark/sql/DataFrame;]
DataFrame.describe ( String... cols ) : DataFrame
[mangled: org/apache/spark/sql/DataFrame.describe:([Ljava/lang/String;)Lorg/apache/spark/sql/DataFrame;]
DataFrame.drop ( Column col ) : DataFrame
[mangled: org/apache/spark/sql/DataFrame.drop:(Lorg/apache/spark/sql/Column;)Lorg/apache/spark/sql/DataFrame;]
DataFrame.drop ( String colName ) : DataFrame
[mangled: org/apache/spark/sql/DataFrame.drop:(Ljava/lang/String;)Lorg/apache/spark/sql/DataFrame;]
DataFrame.dropDuplicates ( ) : DataFrame
[mangled: org/apache/spark/sql/DataFrame.dropDuplicates:()Lorg/apache/spark/sql/DataFrame;]
DataFrame.dropDuplicates ( scala.collection.Seq<String> colNames ) : DataFrame
[mangled: org/apache/spark/sql/DataFrame.dropDuplicates:(Lscala/collection/Seq;)Lorg/apache/spark/sql/DataFrame;]
DataFrame.dropDuplicates ( String[ ] colNames ) : DataFrame
[mangled: org/apache/spark/sql/DataFrame.dropDuplicates:([Ljava/lang/String;)Lorg/apache/spark/sql/DataFrame;]
DataFrame.inputFiles ( ) : String[ ]
[mangled: org/apache/spark/sql/DataFrame.inputFiles:()[Ljava/lang/String;]
DataFrame.join ( DataFrame right, scala.collection.Seq<String> usingColumns ) : DataFrame
[mangled: org/apache/spark/sql/DataFrame.join:(Lorg/apache/spark/sql/DataFrame;Lscala/collection/Seq;)Lorg/apache/spark/sql/DataFrame;]
DataFrame.join ( DataFrame right, String usingColumn ) : DataFrame
[mangled: org/apache/spark/sql/DataFrame.join:(Lorg/apache/spark/sql/DataFrame;Ljava/lang/String;)Lorg/apache/spark/sql/DataFrame;]
DataFrame.na ( ) : DataFrameNaFunctions
[mangled: org/apache/spark/sql/DataFrame.na:()Lorg/apache/spark/sql/DataFrameNaFunctions;]
DataFrame.DataFrame..logicalPlanToDataFrame ( catalyst.plans.logical.LogicalPlan logicalPlan ) : DataFrame
[mangled: org/apache/spark/sql/DataFrame.org.apache.spark.sql.DataFrame..logicalPlanToDataFrame:(Lorg/apache/spark/sql/catalyst/plans/logical/LogicalPlan;)Lorg/apache/spark/sql/DataFrame;]
DataFrame.randomSplit ( double[ ] weights ) : DataFrame[ ]
[mangled: org/apache/spark/sql/DataFrame.randomSplit:([D)[Lorg/apache/spark/sql/DataFrame;]
DataFrame.randomSplit ( double[ ] weights, long seed ) : DataFrame[ ]
[mangled: org/apache/spark/sql/DataFrame.randomSplit:([DJ)[Lorg/apache/spark/sql/DataFrame;]
DataFrame.randomSplit ( scala.collection.immutable.List<Object> weights, long seed ) : DataFrame[ ]
[mangled: org/apache/spark/sql/DataFrame.randomSplit:(Lscala/collection/immutable/List;J)[Lorg/apache/spark/sql/DataFrame;]
DataFrame.rollup ( Column... cols ) : GroupedData
[mangled: org/apache/spark/sql/DataFrame.rollup:([Lorg/apache/spark/sql/Column;)Lorg/apache/spark/sql/GroupedData;]
DataFrame.rollup ( scala.collection.Seq<Column> cols ) : GroupedData
[mangled: org/apache/spark/sql/DataFrame.rollup:(Lscala/collection/Seq;)Lorg/apache/spark/sql/GroupedData;]
DataFrame.rollup ( String col1, scala.collection.Seq<String> cols ) : GroupedData
[mangled: org/apache/spark/sql/DataFrame.rollup:(Ljava/lang/String;Lscala/collection/Seq;)Lorg/apache/spark/sql/GroupedData;]
DataFrame.rollup ( String col1, String... cols ) : GroupedData
[mangled: org/apache/spark/sql/DataFrame.rollup:(Ljava/lang/String;[Ljava/lang/String;)Lorg/apache/spark/sql/GroupedData;]
DataFrame.show ( boolean truncate ) : void
[mangled: org/apache/spark/sql/DataFrame.show:(Z)V]
DataFrame.show ( int numRows, boolean truncate ) : void
[mangled: org/apache/spark/sql/DataFrame.show:(IZ)V]
DataFrame.showString ( int _numRows, boolean truncate ) : String
[mangled: org/apache/spark/sql/DataFrame.showString:(IZ)Ljava/lang/String;]
DataFrame.stat ( ) : DataFrameStatFunctions
[mangled: org/apache/spark/sql/DataFrame.stat:()Lorg/apache/spark/sql/DataFrameStatFunctions;]
DataFrame.where ( String conditionExpr ) : DataFrame
[mangled: org/apache/spark/sql/DataFrame.where:(Ljava/lang/String;)Lorg/apache/spark/sql/DataFrame;]
DataFrame.withNewExecutionId ( scala.Function0<T> body ) : T
[mangled: org/apache/spark/sql/DataFrame.withNewExecutionId:(Lscala/Function0;)Ljava/lang/Object;]
DataFrame.write ( ) : DataFrameWriter
[mangled: org/apache/spark/sql/DataFrame.write:()Lorg/apache/spark/sql/DataFrameWriter;]
spark-sql_2.11-1.5.0.jar, LogicalRelation.class
package org.apache.spark.sql.execution.datasources
LogicalRelation.LogicalRelation ( org.apache.spark.sql.sources.BaseRelation relation )
[mangled: org/apache/spark/sql/execution/datasources/LogicalRelation."<init>":(Lorg/apache/spark/sql/sources/BaseRelation;)V]
spark-sql_2.11-1.5.0.jar, SQLContext.class
package org.apache.spark.sql
SQLContext.cacheManager ( ) : execution.CacheManager
[mangled: org/apache/spark/sql/SQLContext.cacheManager:()Lorg/apache/spark/sql/execution/CacheManager;]
SQLContext.createDataFrame ( org.apache.spark.rdd.RDD<Row> rowRDD, types.StructType schema, boolean needsConversion ) : DataFrame
[mangled: org/apache/spark/sql/SQLContext.createDataFrame:(Lorg/apache/spark/rdd/RDD;Lorg/apache/spark/sql/types/StructType;Z)Lorg/apache/spark/sql/DataFrame;]
SQLContext.createSession ( ) : SQLContext.SQLSession
[mangled: org/apache/spark/sql/SQLContext.createSession:()Lorg/apache/spark/sql/SQLContext$SQLSession;]
SQLContext.currentSession ( ) : SQLContext.SQLSession
[mangled: org/apache/spark/sql/SQLContext.currentSession:()Lorg/apache/spark/sql/SQLContext$SQLSession;]
SQLContext.ddlParser ( ) : execution.datasources.DDLParser
[mangled: org/apache/spark/sql/SQLContext.ddlParser:()Lorg/apache/spark/sql/execution/datasources/DDLParser;]
SQLContext.defaultSession ( ) : SQLContext.SQLSession
[mangled: org/apache/spark/sql/SQLContext.defaultSession:()Lorg/apache/spark/sql/SQLContext$SQLSession;]
SQLContext.detachSession ( ) : void
[mangled: org/apache/spark/sql/SQLContext.detachSession:()V]
SQLContext.dialectClassName ( ) : String
[mangled: org/apache/spark/sql/SQLContext.dialectClassName:()Ljava/lang/String;]
SQLContext.getConf ( SQLConf.SQLConfEntry<T> entry ) : T
[mangled: org/apache/spark/sql/SQLContext.getConf:(Lorg/apache/spark/sql/SQLConf$SQLConfEntry;)Ljava/lang/Object;]
SQLContext.getConf ( SQLConf.SQLConfEntry<T> entry, T defaultValue ) : T
[mangled: org/apache/spark/sql/SQLContext.getConf:(Lorg/apache/spark/sql/SQLConf$SQLConfEntry;Ljava/lang/Object;)Ljava/lang/Object;]
SQLContext.getOrCreate ( org.apache.spark.SparkContext p1 ) [static] : SQLContext
[mangled: org/apache/spark/sql/SQLContext.getOrCreate:(Lorg/apache/spark/SparkContext;)Lorg/apache/spark/sql/SQLContext;]
SQLContext.getSQLDialect ( ) : catalyst.ParserDialect
[mangled: org/apache/spark/sql/SQLContext.getSQLDialect:()Lorg/apache/spark/sql/catalyst/ParserDialect;]
SQLContext.internalCreateDataFrame ( org.apache.spark.rdd.RDD<catalyst.InternalRow> catalystRows, types.StructType schema ) : DataFrame
[mangled: org/apache/spark/sql/SQLContext.internalCreateDataFrame:(Lorg/apache/spark/rdd/RDD;Lorg/apache/spark/sql/types/StructType;)Lorg/apache/spark/sql/DataFrame;]
SQLContext.listener ( ) : execution.ui.SQLListener
[mangled: org/apache/spark/sql/SQLContext.listener:()Lorg/apache/spark/sql/execution/ui/SQLListener;]
SQLContext.openSession ( ) : SQLContext.SQLSession
[mangled: org/apache/spark/sql/SQLContext.openSession:()Lorg/apache/spark/sql/SQLContext$SQLSession;]
SQLContext.range ( long end ) : DataFrame
[mangled: org/apache/spark/sql/SQLContext.range:(J)Lorg/apache/spark/sql/DataFrame;]
SQLContext.range ( long start, long end ) : DataFrame
[mangled: org/apache/spark/sql/SQLContext.range:(JJ)Lorg/apache/spark/sql/DataFrame;]
SQLContext.range ( long start, long end, long step, int numPartitions ) : DataFrame
[mangled: org/apache/spark/sql/SQLContext.range:(JJJI)Lorg/apache/spark/sql/DataFrame;]
SQLContext.read ( ) : DataFrameReader
[mangled: org/apache/spark/sql/SQLContext.read:()Lorg/apache/spark/sql/DataFrameReader;]
SQLContext.setConf ( SQLConf.SQLConfEntry<T> entry, T value ) : void
[mangled: org/apache/spark/sql/SQLContext.setConf:(Lorg/apache/spark/sql/SQLConf$SQLConfEntry;Ljava/lang/Object;)V]
SQLContext.setSession ( SQLContext.SQLSession session ) : void
[mangled: org/apache/spark/sql/SQLContext.setSession:(Lorg/apache/spark/sql/SQLContext$SQLSession;)V]
SQLContext.tlSession ( ) : ThreadLocal<SQLContext.SQLSession>
[mangled: org/apache/spark/sql/SQLContext.tlSession:()Ljava/lang/ThreadLocal;]
spark-streaming_2.11-1.5.0.jar, DStream<T>.class
package org.apache.spark.streaming.dstream
DStream<T>.baseScope ( ) : scala.Option<String>
[mangled: org/apache/spark/streaming/dstream/DStream<T>.baseScope:()Lscala/Option;]
DStream<T>.createRDDWithLocalProperties ( org.apache.spark.streaming.Time time, scala.Function0<U> body ) : U
[mangled: org/apache/spark/streaming/dstream/DStream<T>.createRDDWithLocalProperties:(Lorg/apache/spark/streaming/Time;Lscala/Function0;)Ljava/lang/Object;]
DStream<T>.validateAtStart ( ) : void
[mangled: org/apache/spark/streaming/dstream/DStream<T>.validateAtStart:()V]
spark-streaming_2.11-1.5.0.jar, StreamingContext.class
package org.apache.spark.streaming
StreamingContext.getActive ( ) [static] : scala.Option<StreamingContext>
[mangled: org/apache/spark/streaming/StreamingContext.getActive:()Lscala/Option;]
StreamingContext.getActiveOrCreate ( scala.Function0<StreamingContext> p1 ) [static] : StreamingContext
[mangled: org/apache/spark/streaming/StreamingContext.getActiveOrCreate:(Lscala/Function0;)Lorg/apache/spark/streaming/StreamingContext;]
StreamingContext.getActiveOrCreate ( String p1, scala.Function0<StreamingContext> p2, org.apache.hadoop.conf.Configuration p3, boolean p4 ) [static] : StreamingContext
[mangled: org/apache/spark/streaming/StreamingContext.getActiveOrCreate:(Ljava/lang/String;Lscala/Function0;Lorg/apache/hadoop/conf/Configuration;Z)Lorg/apache/spark/streaming/StreamingContext;]
StreamingContext.getNewInputStreamId ( ) : int
[mangled: org/apache/spark/streaming/StreamingContext.getNewInputStreamId:()I]
StreamingContext.getState ( ) : StreamingContextState
[mangled: org/apache/spark/streaming/StreamingContext.getState:()Lorg/apache/spark/streaming/StreamingContextState;]
StreamingContext.isCheckpointingEnabled ( ) : boolean
[mangled: org/apache/spark/streaming/StreamingContext.isCheckpointingEnabled:()Z]
StreamingContext.StreamingContext..startSite ( ) : java.util.concurrent.atomic.AtomicReference<org.apache.spark.util.CallSite>
[mangled: org/apache/spark/streaming/StreamingContext.org.apache.spark.streaming.StreamingContext..startSite:()Ljava/util/concurrent/atomic/AtomicReference;]
StreamingContext.StreamingContext..stopOnShutdown ( ) : void
[mangled: org/apache/spark/streaming/StreamingContext.org.apache.spark.streaming.StreamingContext..stopOnShutdown:()V]
StreamingContext.StreamingContext ( String path, org.apache.spark.SparkContext sparkContext )
[mangled: org/apache/spark/streaming/StreamingContext."<init>":(Ljava/lang/String;Lorg/apache/spark/SparkContext;)V]
StreamingContext.withNamedScope ( String name, scala.Function0<U> body ) : U
[mangled: org/apache/spark/streaming/StreamingContext.withNamedScope:(Ljava/lang/String;Lscala/Function0;)Ljava/lang/Object;]
StreamingContext.withScope ( scala.Function0<U> body ) : U
[mangled: org/apache/spark/streaming/StreamingContext.withScope:(Lscala/Function0;)Ljava/lang/Object;]
spark-unsafe_2.11-1.5.0.jar, UTF8String.class
package org.apache.spark.unsafe.types
UTF8String.fromString ( String str ) [static] : UTF8String
[mangled: org/apache/spark/unsafe/types/UTF8String.fromString:(Ljava/lang/String;)Lorg/apache/spark/unsafe/types/UTF8String;]
UTF8String.toString ( ) : String
[mangled: org/apache/spark/unsafe/types/UTF8String.toString:()Ljava/lang/String;]
to the top
Problems with Data Types, High Severity (24)
spark-catalyst_2.11-1.5.0.jar
package org.apache.spark.sql
[+] Row (4)
| Change | Effect |
---|
1 | Abstract method fieldIndex ( java.lang.String ) has been removed from this interface. | A client program may be interrupted by NoSuchMethodError exception. |
2 | Abstract method getAs ( java.lang.String ) has been removed from this interface. | A client program may be interrupted by NoSuchMethodError exception. |
3 | Abstract method getTimestamp ( int ) has been removed from this interface. | A client program may be interrupted by NoSuchMethodError exception. |
4 | Abstract method getValuesMap ( scala.collection.Seq<java.lang.String> ) has been removed from this interface. | A client program may be interrupted by NoSuchMethodError exception. |
[+] affected methods (33)
first ( )Return value of this method has type 'Row'.
head ( )Return value of this method has type 'Row'.
anyNull ( )This abstract method is from 'Row' interface.
apply ( int )This abstract method is from 'Row' interface.
copy ( )Return value of this abstract method has type 'Row'.
equals ( java.lang.Object )This abstract method is from 'Row' interface.
get ( int )This abstract method is from 'Row' interface.
getAs ( int )This abstract method is from 'Row' interface.
getBoolean ( int )This abstract method is from 'Row' interface.
getByte ( int )This abstract method is from 'Row' interface.
getDate ( int )This abstract method is from 'Row' interface.
getDecimal ( int )This abstract method is from 'Row' interface.
getDouble ( int )This abstract method is from 'Row' interface.
getFloat ( int )This abstract method is from 'Row' interface.
getInt ( int )This abstract method is from 'Row' interface.
getJavaMap ( int )This abstract method is from 'Row' interface.
getList ( int )This abstract method is from 'Row' interface.
getLong ( int )This abstract method is from 'Row' interface.
getMap ( int )This abstract method is from 'Row' interface.
getSeq ( int )This abstract method is from 'Row' interface.
getShort ( int )This abstract method is from 'Row' interface.
getString ( int )This abstract method is from 'Row' interface.
getStruct ( int )Return value of this abstract method has type 'Row'.
hashCode ( )This abstract method is from 'Row' interface.
isNullAt ( int )This abstract method is from 'Row' interface.
length ( )This abstract method is from 'Row' interface.
mkString ( )This abstract method is from 'Row' interface.
mkString ( java.lang.String )This abstract method is from 'Row' interface.
mkString ( java.lang.String, java.lang.String, java.lang.String )This abstract method is from 'Row' interface.
schema ( )This abstract method is from 'Row' interface.
size ( )This abstract method is from 'Row' interface.
toSeq ( )This abstract method is from 'Row' interface.
toString ( )This abstract method is from 'Row' interface.
package org.apache.spark.sql.catalyst
[+] SimpleCatalystConf (1)
| Change | Effect |
---|
1 | This class has been removed. | A client program may be interrupted by NoClassDefFoundError exception. |
[+] affected methods (1)
SimpleCatalystConf ( boolean )This constructor is from 'SimpleCatalystConf' class.
[+] TableIdentifier (1)
| Change | Effect |
---|
1 | This class has been removed. | A client program may be interrupted by NoClassDefFoundError exception. |
[+] affected methods (20)
apply ( java.lang.String, scala.Option<java.lang.String> )This method is from 'TableIdentifier' class.
canEqual ( java.lang.Object )This method is from 'TableIdentifier' class.
copy ( java.lang.String, scala.Option<java.lang.String> )This method is from 'TableIdentifier' class.
curried ( )This method is from 'TableIdentifier' class.
database ( )This method is from 'TableIdentifier' class.
equals ( java.lang.Object )This method is from 'TableIdentifier' class.
hashCode ( )This method is from 'TableIdentifier' class.
productArity ( )This method is from 'TableIdentifier' class.
productElement ( int )This method is from 'TableIdentifier' class.
productIterator ( )This method is from 'TableIdentifier' class.
productPrefix ( )This method is from 'TableIdentifier' class.
quotedString ( )This method is from 'TableIdentifier' class.
table ( )This method is from 'TableIdentifier' class.
TableIdentifier ( java.lang.String, scala.Option<java.lang.String> )This constructor is from 'TableIdentifier' class.
toSeq ( )This method is from 'TableIdentifier' class.
toString ( )This method is from 'TableIdentifier' class.
tupled ( )This method is from 'TableIdentifier' class.
unapply ( TableIdentifier )This method is from 'TableIdentifier' class.
unquotedString ( )This method is from 'TableIdentifier' class.
withDatabase ( java.lang.String )This method is from 'TableIdentifier' class.
package org.apache.spark.sql.catalyst.analysis
[+] Analyzer (1)
| Change | Effect |
---|
1 | Removed super-interface CheckAnalysis. | A client program may be interrupted by NoSuchMethodError exception. |
[+] affected methods (1)
analyzer ( )Return value of this method has type 'Analyzer'.
[+] Catalog (3)
| Change | Effect |
---|
1 | Abstract method checkTableIdentifier ( scala.collection.Seq<java.lang.String> ) has been removed from this interface. | A client program may be interrupted by NoSuchMethodError exception. |
2 | Abstract method conf ( ) has been removed from this interface. | A client program may be interrupted by NoSuchMethodError exception. |
3 | Abstract method refreshTable ( org.apache.spark.sql.catalyst.TableIdentifier ) has been removed from this interface. | A client program may be interrupted by NoSuchMethodError exception. |
[+] affected methods (10)
getDBTable ( scala.collection.Seq<java.lang.String> )This abstract method is from 'Catalog' interface.
getDbTableName ( scala.collection.Seq<java.lang.String> )This abstract method is from 'Catalog' interface.
getTables ( scala.Option<java.lang.String> )This abstract method is from 'Catalog' interface.
lookupRelation ( scala.collection.Seq<java.lang.String>, scala.Option<java.lang.String> )This abstract method is from 'Catalog' interface.
processTableIdentifier ( scala.collection.Seq<java.lang.String> )This abstract method is from 'Catalog' interface.
registerTable ( scala.collection.Seq<java.lang.String>, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan )This abstract method is from 'Catalog' interface.
tableExists ( scala.collection.Seq<java.lang.String> )This abstract method is from 'Catalog' interface.
unregisterAllTables ( )This abstract method is from 'Catalog' interface.
unregisterTable ( scala.collection.Seq<java.lang.String> )This abstract method is from 'Catalog' interface.
catalog ( )Return value of this method has type 'Catalog'.
package org.apache.spark.sql.catalyst.expressions
[+] Expression (2)
| Change | Effect |
---|
1 | Abstract method eval ( org.apache.spark.sql.catalyst.InternalRow ) has been removed from this class. | A client program may be interrupted by NoSuchMethodError exception. |
2 | Abstract method genCode ( codegen.CodeGenContext, codegen.GeneratedExpressionCode ) has been removed from this class. | A client program may be interrupted by NoSuchMethodError exception. |
[+] affected methods (8)
childrenResolved ( )This method is from 'Expression' abstract class.
dataType ( )This abstract method is from 'Expression' abstract class.
Expression ( )This constructor is from 'Expression' abstract class.
foldable ( )This method is from 'Expression' abstract class.
nullable ( )This abstract method is from 'Expression' abstract class.
prettyString ( )This method is from 'Expression' abstract class.
references ( )This method is from 'Expression' abstract class.
resolved ( )This method is from 'Expression' abstract class.
[+] NamedExpression (1)
| Change | Effect |
---|
1 | This interface became class. | A client program may be interrupted by IncompatibleClassChangeError exception. |
[+] affected methods (2)
name ( )This abstract method is from 'NamedExpression' interface.
resolve ( java.lang.String )Return value of this method has type 'NamedExpression'.
spark-core_2.11-1.5.0.jar
package org.apache.spark
[+] TaskContext (6)
| Change | Effect |
---|
1 | Abstract method collectAccumulators ( ) has been removed from this class. | A client program may be interrupted by NoSuchMethodError exception. |
2 | Abstract method collectInternalAccumulators ( ) has been removed from this class. | A client program may be interrupted by NoSuchMethodError exception. |
3 | Abstract method getMetricsSources ( java.lang.String ) has been removed from this class. | A client program may be interrupted by NoSuchMethodError exception. |
4 | Abstract method internalMetricsToAccumulators ( ) has been removed from this class. | A client program may be interrupted by NoSuchMethodError exception. |
5 | Abstract method registerAccumulator ( Accumulable<?,?> ) has been removed from this class. | A client program may be interrupted by NoSuchMethodError exception. |
6 | Abstract method taskMemoryManager ( ) has been removed from this class. | A client program may be interrupted by NoSuchMethodError exception. |
[+] affected methods (15)
compute ( Partition, TaskContext )2nd parameter 'p2' of this abstract method has type 'TaskContext'.
computeOrReadCheckpoint ( Partition, TaskContext )2nd parameter 'context' of this method has type 'TaskContext'.
iterator ( Partition, TaskContext )2nd parameter 'context' of this method has type 'TaskContext'.
addTaskCompletionListener ( util.TaskCompletionListener )Return value of this abstract method has type 'TaskContext'.
addTaskCompletionListener ( scala.Function1<TaskContext,scala.runtime.BoxedUnit> )Return value of this abstract method has type 'TaskContext'.
attemptNumber ( )This abstract method is from 'TaskContext' abstract class.
get ( )Return value of this method has type 'TaskContext'.
isCompleted ( )This abstract method is from 'TaskContext' abstract class.
isInterrupted ( )This abstract method is from 'TaskContext' abstract class.
isRunningLocally ( )This abstract method is from 'TaskContext' abstract class.
partitionId ( )This abstract method is from 'TaskContext' abstract class.
stageId ( )This abstract method is from 'TaskContext' abstract class.
taskAttemptId ( )This abstract method is from 'TaskContext' abstract class.
TaskContext ( )This constructor is from 'TaskContext' abstract class.
taskMetrics ( )This abstract method is from 'TaskContext' abstract class.
spark-sql_2.11-1.5.0.jar
package org.apache.spark.sql
[+] Column (1)
| Change | Effect |
---|
1 | Removed super-interface org.apache.spark.Logging. | A client program may be interrupted by NoSuchMethodError exception. |
[+] affected methods (9)
agg ( Column, Column... )1st parameter 'expr' of this method has type 'Column'.
agg ( Column, scala.collection.Seq<Column> )1st parameter 'expr' of this method has type 'Column'.
apply ( java.lang.String )Return value of this method has type 'Column'.
col ( java.lang.String )Return value of this method has type 'Column'.
filter ( Column )1st parameter 'condition' of this method has type 'Column'.
join ( DataFrame, Column )2nd parameter 'joinExprs' of this method has type 'Column'.
join ( DataFrame, Column, java.lang.String )2nd parameter 'joinExprs' of this method has type 'Column'.
where ( Column )1st parameter 'condition' of this method has type 'Column'.
withColumn ( java.lang.String, Column )2nd parameter 'col' of this method has type 'Column'.
[+] SQLConf (1)
| Change | Effect |
---|
1 | Removed super-interface catalyst.CatalystConf. | A client program may be interrupted by NoSuchMethodError exception. |
[+] affected methods (1)
conf ( )Return value of this method has type 'SQLConf'.
package org.apache.spark.sql.execution.datasources
[+] LogicalRelation (1)
| Change | Effect |
---|
1 | This class has been removed. | A client program may be interrupted by NoClassDefFoundError exception. |
[+] affected methods (1)
LogicalRelation ( org.apache.spark.sql.sources.BaseRelation )This constructor is from 'LogicalRelation' class.
spark-streaming_2.11-1.5.0.jar
package org.apache.spark.streaming.ui
[+] StreamingJobProgressListener (1)
| Change | Effect |
---|
1 | Removed super-interface org.apache.spark.scheduler.SparkListener. | A client program may be interrupted by NoSuchMethodError exception. |
[+] affected methods (1)
progressListener ( )Return value of this method has type 'StreamingJobProgressListener'.
spark-unsafe_2.11-1.5.0.jar
package org.apache.spark.unsafe.types
[+] UTF8String (1)
| Change | Effect |
---|
1 | This class has been removed. | A client program may be interrupted by NoClassDefFoundError exception. |
[+] affected methods (2)
fromString ( java.lang.String )This method is from 'UTF8String' class.
toString ( )This method is from 'UTF8String' class.
to the top
Problems with Data Types, Medium Severity (5)
spark-catalyst_2.11-1.5.0.jar
package org.apache.spark.sql.catalyst.analysis
[+] Catalog (1)
| Change | Effect |
---|
1 | Abstract method caseSensitive ( ) has been added to this interface. | A client program may be interrupted by AbstractMethodError exception. Added abstract method is called in 2nd library version by the method processTableIdentifier ( Catalog, scala.collection.Seq ) and may not be implemented by old clients. |
[+] affected methods (10)
getDBTable ( scala.collection.Seq<java.lang.String> )This abstract method is from 'Catalog' interface.
getDbTableName ( scala.collection.Seq<java.lang.String> )This abstract method is from 'Catalog' interface.
getTables ( scala.Option<java.lang.String> )This abstract method is from 'Catalog' interface.
lookupRelation ( scala.collection.Seq<java.lang.String>, scala.Option<java.lang.String> )This abstract method is from 'Catalog' interface.
processTableIdentifier ( scala.collection.Seq<java.lang.String> )This abstract method is from 'Catalog' interface.
registerTable ( scala.collection.Seq<java.lang.String>, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan )This abstract method is from 'Catalog' interface.
tableExists ( scala.collection.Seq<java.lang.String> )This abstract method is from 'Catalog' interface.
unregisterAllTables ( )This abstract method is from 'Catalog' interface.
unregisterTable ( scala.collection.Seq<java.lang.String> )This abstract method is from 'Catalog' interface.
catalog ( )Return value of this method has type 'Catalog'.
package org.apache.spark.sql.catalyst.expressions
[+] Expression (1)
| Change | Effect |
---|
1 | Abstract method eval ( org.apache.spark.sql.Row ) has been added to this class. | A client program may be interrupted by AbstractMethodError exception. Added abstract method is called in 2nd library version by the method toInspector ( org.apache.spark.sql.hive.HiveInspectors, Expression ) and may not be implemented by old clients. |
[+] affected methods (8)
childrenResolved ( )This method is from 'Expression' abstract class.
dataType ( )This abstract method is from 'Expression' abstract class.
Expression ( )This constructor is from 'Expression' abstract class.
foldable ( )This method is from 'Expression' abstract class.
nullable ( )This abstract method is from 'Expression' abstract class.
prettyString ( )This method is from 'Expression' abstract class.
references ( )This method is from 'Expression' abstract class.
resolved ( )This method is from 'Expression' abstract class.
package org.apache.spark.sql.types
[+] DataType (1)
| Change | Effect |
---|
1 | Removed super-class AbstractDataType. | Access of a client program to the fields or methods of the old super-class may be interrupted by NoSuchFieldError or NoSuchMethodError exceptions. |
[+] affected methods (6)
dataType ( )Return value of this abstract method has type 'DataType'.
parseDataType ( java.lang.String )Return value of this method has type 'DataType'.
ArrayType ( DataType, boolean )1st parameter 'elementType' of this method has type 'DataType'.
MapType ( DataType, DataType, boolean )1st parameter 'keyType' of this method has type 'DataType'.
StructField ( java.lang.String, DataType, boolean, Metadata )2nd parameter 'dataType' of this method has type 'DataType'.
asNullable ( )Return value of this method has type 'DataType'.
spark-core_2.11-1.5.0.jar
package org.apache.spark.api.java
[+] JavaRDD<T> (1)
| Change | Effect |
---|
1 | Removed super-class AbstractJavaRDDLike<T,JavaRDD<T>>. | Access of a client program to the fields or methods of the old super-class may be interrupted by NoSuchFieldError or NoSuchMethodError exceptions. |
[+] affected methods (1)
toJavaRDD ( )Return value of this method has type 'JavaRDD<T>'.
spark-sql_2.11-1.5.0.jar
package org.apache.spark.sql
[+] SQLContext.implicits. (1)
| Change | Effect |
---|
1 | Removed super-class SQLImplicits. | Access of a client program to the fields or methods of the old super-class may be interrupted by NoSuchFieldError or NoSuchMethodError exceptions. |
[+] affected methods (1)
implicits ( )Return value of this method has type 'SQLContext.implicits.'.
to the top
Problems with Data Types, Low Severity (1)
spark-sql_2.11-1.5.0.jar
package org.apache.spark.sql
[+] DataFrame (1)
| Change | Effect |
---|
1 | Added super-class java.lang.Object. | A static field from a super-interface of a client class may hide a field (with the same name) inherited from new super-class and cause IncompatibleClassChangeError exception. |
[+] affected methods (112)
agg ( java.util.Map<java.lang.String,java.lang.String> )Return value of this method has type 'DataFrame'.
agg ( Column, Column... )Return value of this method has type 'DataFrame'.
agg ( Column, scala.collection.Seq<Column> )Return value of this method has type 'DataFrame'.
agg ( scala.collection.immutable.Map<java.lang.String,java.lang.String> )Return value of this method has type 'DataFrame'.
agg ( scala.Tuple2<java.lang.String,java.lang.String>, scala.collection.Seq<scala.Tuple2<java.lang.String,java.lang.String>> )Return value of this method has type 'DataFrame'.
apply ( java.lang.String )This method is from 'DataFrame' class.
as ( java.lang.String )Return value of this method has type 'DataFrame'.
as ( scala.Symbol )Return value of this method has type 'DataFrame'.
cache ( )Return value of this method has type 'DataFrame'.
col ( java.lang.String )This method is from 'DataFrame' class.
collect ( )This method is from 'DataFrame' class.
collectAsList ( )This method is from 'DataFrame' class.
columns ( )This method is from 'DataFrame' class.
count ( )This method is from 'DataFrame' class.
DataFrame ( SQLContext, catalyst.plans.logical.LogicalPlan )This constructor is from 'DataFrame' class.
DataFrame ( SQLContext, SQLContext.QueryExecution )This constructor is from 'DataFrame' class.
distinct ( )Return value of this method has type 'DataFrame'.
dtypes ( )This method is from 'DataFrame' class.
except ( DataFrame )1st parameter 'other' of this method has type 'DataFrame'.
explain ( )This method is from 'DataFrame' class.
explain ( boolean )This method is from 'DataFrame' class.
explode ( java.lang.String, java.lang.String, scala.Function1<A,scala.collection.TraversableOnce<B>>, scala.reflect.api.TypeTags.TypeTag<B> )Return value of this method has type 'DataFrame'.
explode ( scala.collection.Seq<Column>, scala.Function1<Row,scala.collection.TraversableOnce<A>>, scala.reflect.api.TypeTags.TypeTag<A> )Return value of this method has type 'DataFrame'.
filter ( java.lang.String )Return value of this method has type 'DataFrame'.
filter ( Column )Return value of this method has type 'DataFrame'.
first ( )This method is from 'DataFrame' class.
flatMap ( scala.Function1<Row,scala.collection.TraversableOnce<R>>, scala.reflect.ClassTag<R> )This method is from 'DataFrame' class.
foreach ( scala.Function1<Row,scala.runtime.BoxedUnit> )This method is from 'DataFrame' class.
foreachPartition ( scala.Function1<scala.collection.Iterator<Row>,scala.runtime.BoxedUnit> )This method is from 'DataFrame' class.
groupBy ( java.lang.String, java.lang.String... )This method is from 'DataFrame' class.
groupBy ( java.lang.String, scala.collection.Seq<java.lang.String> )This method is from 'DataFrame' class.
groupBy ( Column... )This method is from 'DataFrame' class.
groupBy ( scala.collection.Seq<Column> )This method is from 'DataFrame' class.
head ( )This method is from 'DataFrame' class.
head ( int )This method is from 'DataFrame' class.
intersect ( DataFrame )1st parameter 'other' of this method has type 'DataFrame'.
isLocal ( )This method is from 'DataFrame' class.
javaRDD ( )This method is from 'DataFrame' class.
javaToPython ( )This method is from 'DataFrame' class.
join ( DataFrame )Return value of this method has type 'DataFrame'.
join ( DataFrame, Column )Return value of this method has type 'DataFrame'.
join ( DataFrame, Column, java.lang.String )Return value of this method has type 'DataFrame'.
limit ( int )Return value of this method has type 'DataFrame'.
logicalPlan ( )This method is from 'DataFrame' class.
map ( scala.Function1<Row,R>, scala.reflect.ClassTag<R> )This method is from 'DataFrame' class.
mapPartitions ( scala.Function1<scala.collection.Iterator<Row>,scala.collection.Iterator<R>>, scala.reflect.ClassTag<R> )This method is from 'DataFrame' class.
numericColumns ( )This method is from 'DataFrame' class.
orderBy ( java.lang.String, java.lang.String... )Return value of this method has type 'DataFrame'.
orderBy ( java.lang.String, scala.collection.Seq<java.lang.String> )Return value of this method has type 'DataFrame'.
orderBy ( Column... )Return value of this method has type 'DataFrame'.
orderBy ( scala.collection.Seq<Column> )Return value of this method has type 'DataFrame'.
persist ( )Return value of this method has type 'DataFrame'.
persist ( org.apache.spark.storage.StorageLevel )Return value of this method has type 'DataFrame'.
printSchema ( )This method is from 'DataFrame' class.
queryExecution ( )This method is from 'DataFrame' class.
rdd ( )This method is from 'DataFrame' class.
registerTempTable ( java.lang.String )This method is from 'DataFrame' class.
repartition ( int )Return value of this method has type 'DataFrame'.
resolve ( java.lang.String )This method is from 'DataFrame' class.
sample ( boolean, double )Return value of this method has type 'DataFrame'.
sample ( boolean, double, long )Return value of this method has type 'DataFrame'.
schema ( )This method is from 'DataFrame' class.
select ( java.lang.String, java.lang.String... )Return value of this method has type 'DataFrame'.
select ( java.lang.String, scala.collection.Seq<java.lang.String> )Return value of this method has type 'DataFrame'.
select ( Column... )Return value of this method has type 'DataFrame'.
select ( scala.collection.Seq<Column> )Return value of this method has type 'DataFrame'.
selectExpr ( java.lang.String... )Return value of this method has type 'DataFrame'.
selectExpr ( scala.collection.Seq<java.lang.String> )Return value of this method has type 'DataFrame'.
show ( )This method is from 'DataFrame' class.
show ( int )This method is from 'DataFrame' class.
sort ( java.lang.String, java.lang.String... )Return value of this method has type 'DataFrame'.
sort ( java.lang.String, scala.collection.Seq<java.lang.String> )Return value of this method has type 'DataFrame'.
sort ( Column... )Return value of this method has type 'DataFrame'.
sort ( scala.collection.Seq<Column> )Return value of this method has type 'DataFrame'.
sqlContext ( )This method is from 'DataFrame' class.
take ( int )This method is from 'DataFrame' class.
toDF ( )Return value of this method has type 'DataFrame'.
toDF ( java.lang.String... )Return value of this method has type 'DataFrame'.
toDF ( scala.collection.Seq<java.lang.String> )Return value of this method has type 'DataFrame'.
toJavaRDD ( )This method is from 'DataFrame' class.
toJSON ( )This method is from 'DataFrame' class.
toString ( )This method is from 'DataFrame' class.
unionAll ( DataFrame )1st parameter 'other' of this method has type 'DataFrame'.
unpersist ( )Return value of this method has type 'DataFrame'.
unpersist ( boolean )Return value of this method has type 'DataFrame'.
where ( Column )Return value of this method has type 'DataFrame'.
withColumn ( java.lang.String, Column )Return value of this method has type 'DataFrame'.
withColumnRenamed ( java.lang.String, java.lang.String )Return value of this method has type 'DataFrame'.
createRelation ( SQLContext, SaveMode, scala.collection.immutable.Map<java.lang.String,java.lang.String>, DataFrame )4th parameter 'p4' of this abstract method has type 'DataFrame'.
insert ( DataFrame, boolean )1st parameter 'p1' of this abstract method has type 'DataFrame'.
applySchemaToPythonRDD ( org.apache.spark.rdd.RDD<java.lang.Object[ ]>, java.lang.String )Return value of this method has type 'DataFrame'.
applySchemaToPythonRDD ( org.apache.spark.rdd.RDD<java.lang.Object[ ]>, types.StructType )Return value of this method has type 'DataFrame'.
baseRelationToDataFrame ( sources.BaseRelation )Return value of this method has type 'DataFrame'.
createDataFrame ( org.apache.spark.api.java.JavaRDD<?>, java.lang.Class<?> )Return value of this method has type 'DataFrame'.
createDataFrame ( org.apache.spark.api.java.JavaRDD<Row>, types.StructType )Return value of this method has type 'DataFrame'.
createDataFrame ( org.apache.spark.rdd.RDD<?>, java.lang.Class<?> )Return value of this method has type 'DataFrame'.
createDataFrame ( org.apache.spark.rdd.RDD<A>, scala.reflect.api.TypeTags.TypeTag<A> )Return value of this method has type 'DataFrame'.
createDataFrame ( org.apache.spark.rdd.RDD<Row>, types.StructType )Return value of this method has type 'DataFrame'.
createDataFrame ( scala.collection.Seq<A>, scala.reflect.api.TypeTags.TypeTag<A> )Return value of this method has type 'DataFrame'.
createExternalTable ( java.lang.String, java.lang.String )Return value of this method has type 'DataFrame'.
createExternalTable ( java.lang.String, java.lang.String, java.lang.String )Return value of this method has type 'DataFrame'.
createExternalTable ( java.lang.String, java.lang.String, java.util.Map<java.lang.String,java.lang.String> )Return value of this method has type 'DataFrame'.
createExternalTable ( java.lang.String, java.lang.String, types.StructType, java.util.Map<java.lang.String,java.lang.String> )Return value of this method has type 'DataFrame'.
createExternalTable ( java.lang.String, java.lang.String, types.StructType, scala.collection.immutable.Map<java.lang.String,java.lang.String> )Return value of this method has type 'DataFrame'.
createExternalTable ( java.lang.String, java.lang.String, scala.collection.immutable.Map<java.lang.String,java.lang.String> )Return value of this method has type 'DataFrame'.
emptyDataFrame ( )Return value of this method has type 'DataFrame'.
parquetFile ( java.lang.String... )Return value of this method has type 'DataFrame'.
registerDataFrameAsTable ( DataFrame, java.lang.String )1st parameter 'df' of this method has type 'DataFrame'.
sql ( java.lang.String )Return value of this method has type 'DataFrame'.
table ( java.lang.String )Return value of this method has type 'DataFrame'.
tables ( )Return value of this method has type 'DataFrame'.
tables ( java.lang.String )Return value of this method has type 'DataFrame'.
to the top
Other Changes in Data Types (1)
spark-catalyst_2.11-1.5.0.jar
package org.apache.spark.sql.catalyst.analysis
[+] Catalog (1)
| Change | Effect |
---|
1 | Abstract method refreshTable ( java.lang.String, java.lang.String ) has been added to this interface. | No effect. |
[+] affected methods (10)
getDBTable ( scala.collection.Seq<java.lang.String> )This abstract method is from 'Catalog' interface.
getDbTableName ( scala.collection.Seq<java.lang.String> )This abstract method is from 'Catalog' interface.
getTables ( scala.Option<java.lang.String> )This abstract method is from 'Catalog' interface.
lookupRelation ( scala.collection.Seq<java.lang.String>, scala.Option<java.lang.String> )This abstract method is from 'Catalog' interface.
processTableIdentifier ( scala.collection.Seq<java.lang.String> )This abstract method is from 'Catalog' interface.
registerTable ( scala.collection.Seq<java.lang.String>, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan )This abstract method is from 'Catalog' interface.
tableExists ( scala.collection.Seq<java.lang.String> )This abstract method is from 'Catalog' interface.
unregisterAllTables ( )This abstract method is from 'Catalog' interface.
unregisterTable ( scala.collection.Seq<java.lang.String> )This abstract method is from 'Catalog' interface.
catalog ( )Return value of this method has type 'Catalog'.
to the top
Java ARchives (7)
spark-catalyst_2.11-1.5.0.jar
spark-core_2.11-1.5.0.jar
spark-hive_2.11-1.5.0.jar
spark-repl_2.11-1.5.0.jar
spark-sql_2.11-1.5.0.jar
spark-streaming_2.11-1.5.0.jar
spark-unsafe_2.11-1.5.0.jar
to the top
Generated on Wed Dec 9 13:43:01 2015 for spark-cassandra-connector_2.11-1.5.0-M3 by Java API Compliance Checker 1.4.1
A tool for checking backward compatibility of a Java library API