Binary compatibility report for the spark-testing-base_2.10-1.4.0_0.2.1 library between 1.4.0 and 1.3.0 versions (relating to the portability of client application spark-testing-base_2.10-1.4.0_0.2.1.jar)
Test Info
Library Name | spark-testing-base_2.10-1.4.0_0.2.1 |
Version #1 | 1.4.0 |
Version #2 | 1.3.0 |
Java Version | 1.7.0_75 |
Test Results
Total Java ARchives | 7 |
---|
Total Methods / Classes | 1459 / 3611 |
---|
Verdict | Incompatible (12.2%) |
Problem Summary
| Severity | Count |
---|
Added Methods | - | 16 |
---|
Removed Methods | High | 134 |
---|
Problems with Data Types | High | 7 |
---|
Medium | 1 |
Low | 3 |
Problems with Methods | High | 0 |
---|
Medium | 0 |
Low | 0 |
Added Methods (16)
spark-core_2.10-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.10-1.3.0.jar, SparkListenerApplicationStart.class
package org.apache.spark.scheduler
SparkListenerApplicationStart.copy ( String appName, scala.Option<String> appId, long time, String sparkUser ) : SparkListenerApplicationStart
[mangled: org/apache/spark/scheduler/SparkListenerApplicationStart.copy:(Ljava/lang/String;Lscala/Option;JLjava/lang/String;)Lorg/apache/spark/scheduler/SparkListenerApplicationStart;]
SparkListenerApplicationStart.SparkListenerApplicationStart ( String appName, scala.Option<String> appId, long time, String sparkUser )
[mangled: org/apache/spark/scheduler/SparkListenerApplicationStart."<init>":(Ljava/lang/String;Lscala/Option;JLjava/lang/String;)V]
spark-hive_2.10-1.3.0.jar, HiveContext.class
package org.apache.spark.sql.hive
HiveContext.conf ( ) : org.apache.spark.sql.SQLConf
[mangled: org/apache/spark/sql/hive/HiveContext.conf:()Lorg/apache/spark/sql/SQLConf;]
HiveContext.ddlParserWithHiveQL ( ) : org.apache.spark.sql.sources.DDLParser
[mangled: org/apache/spark/sql/hive/HiveContext.ddlParserWithHiveQL:()Lorg/apache/spark/sql/sources/DDLParser;]
HiveContext.outputBuffer ( ) : java.io.OutputStream
[mangled: org/apache/spark/sql/hive/HiveContext.outputBuffer:()Ljava/io/OutputStream;]
HiveContext.runHive ( String cmd, int maxRows ) : scala.collection.Seq<String>
[mangled: org/apache/spark/sql/hive/HiveContext.runHive:(Ljava/lang/String;I)Lscala/collection/Seq;]
HiveContext.sessionState ( ) : org.apache.hadoop.hive.ql.session.SessionState
[mangled: org/apache/spark/sql/hive/HiveContext.sessionState:()Lorg/apache/hadoop/hive/ql/session/SessionState;]
HiveContext.sql ( String sqlText ) : org.apache.spark.sql.DataFrame
[mangled: org/apache/spark/sql/hive/HiveContext.sql:(Ljava/lang/String;)Lorg/apache/spark/sql/DataFrame;]
spark-streaming_2.10-1.3.0.jar, Checkpoint.class
package org.apache.spark.streaming
Checkpoint.getCheckpointFiles ( String p1, org.apache.hadoop.fs.FileSystem p2 ) [static] : scala.collection.Seq<org.apache.hadoop.fs.Path>
[mangled: org/apache/spark/streaming/Checkpoint.getCheckpointFiles:(Ljava/lang/String;Lorg/apache/hadoop/fs/FileSystem;)Lscala/collection/Seq;]
Checkpoint.sparkConf ( ) : org.apache.spark.SparkConf
[mangled: org/apache/spark/streaming/Checkpoint.sparkConf:()Lorg/apache/spark/SparkConf;]
spark-streaming_2.10-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.10-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 (134)
spark-catalyst_2.10-1.4.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.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.10-1.4.0.jar, StructType.class
package org.apache.spark.sql.types
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.StructType ( )
[mangled: org/apache/spark/sql/types/StructType."<init>":()V]
spark-core_2.10-1.4.0.jar, RDD<T>.class
package org.apache.spark.rdd
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.10-1.4.0.jar, SparkConf.class
package org.apache.spark
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, 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]
spark-core_2.10-1.4.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.SparkContext.._conf ( ) : SparkConf
[mangled: org/apache/spark/SparkContext.org.apache.spark.SparkContext.._conf:()Lorg/apache/spark/SparkConf;]
SparkContext.SparkContext.._env ( ) : SparkEnv
[mangled: org/apache/spark/SparkContext.org.apache.spark.SparkContext.._env:()Lorg/apache/spark/SparkEnv;]
SparkContext.SparkContext..assertNotStopped ( ) : void
[mangled: org/apache/spark/SparkContext.org.apache.spark.SparkContext..assertNotStopped:()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.setLogLevel ( String logLevel ) : void
[mangled: org/apache/spark/SparkContext.setLogLevel:(Ljava/lang/String;)V]
SparkContext.supportDynamicAllocation ( ) : boolean
[mangled: org/apache/spark/SparkContext.supportDynamicAllocation:()Z]
SparkContext.withScope ( scala.Function0<U> body ) : U
[mangled: org/apache/spark/SparkContext.withScope:(Lscala/Function0;)Ljava/lang/Object;]
spark-core_2.10-1.4.0.jar, SparkListenerApplicationStart.class
package org.apache.spark.scheduler
SparkListenerApplicationStart.appAttemptId ( ) : scala.Option<String>
[mangled: org/apache/spark/scheduler/SparkListenerApplicationStart.appAttemptId:()Lscala/Option;]
SparkListenerApplicationStart.copy ( String appName, scala.Option<String> appId, long time, String sparkUser, scala.Option<String> appAttemptId ) : SparkListenerApplicationStart
[mangled: org/apache/spark/scheduler/SparkListenerApplicationStart.copy:(Ljava/lang/String;Lscala/Option;JLjava/lang/String;Lscala/Option;)Lorg/apache/spark/scheduler/SparkListenerApplicationStart;]
SparkListenerApplicationStart.SparkListenerApplicationStart ( String appName, scala.Option<String> appId, long time, String sparkUser, scala.Option<String> appAttemptId )
[mangled: org/apache/spark/scheduler/SparkListenerApplicationStart."<init>":(Ljava/lang/String;Lscala/Option;JLjava/lang/String;Lscala/Option;)V]
spark-hive_2.10-1.4.0.jar, HiveContext.class
package org.apache.spark.sql.hive
HiveContext.configure ( ) : scala.collection.immutable.Map<String,String>
[mangled: org/apache/spark/sql/hive/HiveContext.configure:()Lscala/collection/immutable/Map;]
HiveContext.convertMetastoreParquetWithSchemaMerging ( ) : boolean
[mangled: org/apache/spark/sql/hive/HiveContext.convertMetastoreParquetWithSchemaMerging:()Z]
HiveContext.createSession ( ) : HiveContext.SQLSession
[mangled: org/apache/spark/sql/hive/HiveContext.createSession:()Lorg/apache/spark/sql/hive/HiveContext$SQLSession;]
HiveContext.createSession ( ) : org.apache.spark.sql.SQLContext.SQLSession
[mangled: org/apache/spark/sql/hive/HiveContext.createSession:()Lorg/apache/spark/sql/SQLContext$SQLSession;]
HiveContext.dialectClassName ( ) : String
[mangled: org/apache/spark/sql/hive/HiveContext.dialectClassName:()Ljava/lang/String;]
HiveContext.executionHive ( ) : client.ClientWrapper
[mangled: org/apache/spark/sql/hive/HiveContext.executionHive:()Lorg/apache/spark/sql/hive/client/ClientWrapper;]
HiveContext.HIVE_METASTORE_JARS ( ) [static] : String
[mangled: org/apache/spark/sql/hive/HiveContext.HIVE_METASTORE_JARS:()Ljava/lang/String;]
HiveContext.HIVE_METASTORE_VERSION ( ) [static] : String
[mangled: org/apache/spark/sql/hive/HiveContext.HIVE_METASTORE_VERSION:()Ljava/lang/String;]
HiveContext.hiveExecutionVersion ( ) [static] : String
[mangled: org/apache/spark/sql/hive/HiveContext.hiveExecutionVersion:()Ljava/lang/String;]
HiveContext.hiveMetastoreBarrierPrefixes ( ) : scala.collection.Seq<String>
[mangled: org/apache/spark/sql/hive/HiveContext.hiveMetastoreBarrierPrefixes:()Lscala/collection/Seq;]
HiveContext.hiveMetastoreJars ( ) : String
[mangled: org/apache/spark/sql/hive/HiveContext.hiveMetastoreJars:()Ljava/lang/String;]
HiveContext.hiveMetastoreSharedPrefixes ( ) : scala.collection.Seq<String>
[mangled: org/apache/spark/sql/hive/HiveContext.hiveMetastoreSharedPrefixes:()Lscala/collection/Seq;]
HiveContext.hiveMetastoreVersion ( ) : String
[mangled: org/apache/spark/sql/hive/HiveContext.hiveMetastoreVersion:()Ljava/lang/String;]
HiveContext.metadataHive ( ) : client.ClientInterface
[mangled: org/apache/spark/sql/hive/HiveContext.metadataHive:()Lorg/apache/spark/sql/hive/client/ClientInterface;]
HiveContext.newTemporaryConfiguration ( ) [static] : scala.collection.immutable.Map<String,String>
[mangled: org/apache/spark/sql/hive/HiveContext.newTemporaryConfiguration:()Lscala/collection/immutable/Map;]
HiveContext.substitutor ( ) : org.apache.hadoop.hive.ql.parse.VariableSubstitution
[mangled: org/apache/spark/sql/hive/HiveContext.substitutor:()Lorg/apache/hadoop/hive/ql/parse/VariableSubstitution;]
spark-sql_2.10-1.4.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 ( 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.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.stat ( ) : DataFrameStatFunctions
[mangled: org/apache/spark/sql/DataFrame.stat:()Lorg/apache/spark/sql/DataFrameStatFunctions;]
DataFrame.write ( ) : DataFrameWriter
[mangled: org/apache/spark/sql/DataFrame.write:()Lorg/apache/spark/sql/DataFrameWriter;]
spark-streaming-kafka_2.10-1.4.0.jar, KafkaTestUtils.class
package org.apache.spark.streaming.kafka
KafkaTestUtils.brokerAddress ( ) : String
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.brokerAddress:()Ljava/lang/String;]
KafkaTestUtils.createTopic ( String topic ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.createTopic:(Ljava/lang/String;)V]
KafkaTestUtils.eventually ( org.apache.spark.streaming.Time timeout, org.apache.spark.streaming.Time interval, scala.Function0<T> func ) : T
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.eventually:(Lorg/apache/spark/streaming/Time;Lorg/apache/spark/streaming/Time;Lscala/Function0;)Ljava/lang/Object;]
KafkaTestUtils.isTraceEnabled ( ) : boolean
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.isTraceEnabled:()Z]
KafkaTestUtils.KafkaTestUtils ( )
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils."<init>":()V]
KafkaTestUtils.log ( ) : org.slf4j.Logger
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.log:()Lorg/slf4j/Logger;]
KafkaTestUtils.logDebug ( scala.Function0<String> msg ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.logDebug:(Lscala/Function0;)V]
KafkaTestUtils.logDebug ( scala.Function0<String> msg, Throwable throwable ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.logDebug:(Lscala/Function0;Ljava/lang/Throwable;)V]
KafkaTestUtils.logError ( scala.Function0<String> msg ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.logError:(Lscala/Function0;)V]
KafkaTestUtils.logError ( scala.Function0<String> msg, Throwable throwable ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.logError:(Lscala/Function0;Ljava/lang/Throwable;)V]
KafkaTestUtils.logInfo ( scala.Function0<String> msg ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.logInfo:(Lscala/Function0;)V]
KafkaTestUtils.logInfo ( scala.Function0<String> msg, Throwable throwable ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.logInfo:(Lscala/Function0;Ljava/lang/Throwable;)V]
KafkaTestUtils.logName ( ) : String
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.logName:()Ljava/lang/String;]
KafkaTestUtils.logTrace ( scala.Function0<String> msg ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.logTrace:(Lscala/Function0;)V]
KafkaTestUtils.logTrace ( scala.Function0<String> msg, Throwable throwable ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.logTrace:(Lscala/Function0;Ljava/lang/Throwable;)V]
KafkaTestUtils.logWarning ( scala.Function0<String> msg ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.logWarning:(Lscala/Function0;)V]
KafkaTestUtils.logWarning ( scala.Function0<String> msg, Throwable throwable ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.logWarning:(Lscala/Function0;Ljava/lang/Throwable;)V]
KafkaTestUtils.org.apache.spark.Logging..log_ ( ) : org.slf4j.Logger
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.org.apache.spark.Logging..log_:()Lorg/slf4j/Logger;]
KafkaTestUtils.org.apache.spark.Logging..log__.eq ( org.slf4j.Logger p1 ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.org.apache.spark.Logging..log__.eq:(Lorg/slf4j/Logger;)V]
KafkaTestUtils.KafkaTestUtils..brokerConf ( ) : kafka.server.KafkaConfig
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.org.apache.spark.streaming.kafka.KafkaTestUtils..brokerConf:()Lkafka/server/KafkaConfig;]
KafkaTestUtils.KafkaTestUtils..brokerConf_.eq ( kafka.server.KafkaConfig p1 ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.org.apache.spark.streaming.kafka.KafkaTestUtils..brokerConf_.eq:(Lkafka/server/KafkaConfig;)V]
KafkaTestUtils.KafkaTestUtils..brokerConfiguration ( ) : java.util.Properties
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.org.apache.spark.streaming.kafka.KafkaTestUtils..brokerConfiguration:()Ljava/util/Properties;]
KafkaTestUtils.KafkaTestUtils..brokerPort_.eq ( int p1 ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.org.apache.spark.streaming.kafka.KafkaTestUtils..brokerPort_.eq:(I)V]
KafkaTestUtils.KafkaTestUtils..server ( ) : kafka.server.KafkaServer
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.org.apache.spark.streaming.kafka.KafkaTestUtils..server:()Lkafka/server/KafkaServer;]
KafkaTestUtils.KafkaTestUtils..server_.eq ( kafka.server.KafkaServer p1 ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.org.apache.spark.streaming.kafka.KafkaTestUtils..server_.eq:(Lkafka/server/KafkaServer;)V]
KafkaTestUtils.sendMessages ( String topic, java.util.Map<String,Integer> messageToFreq ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.sendMessages:(Ljava/lang/String;Ljava/util/Map;)V]
KafkaTestUtils.sendMessages ( String topic, scala.collection.immutable.Map<String,Object> messageToFreq ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.sendMessages:(Ljava/lang/String;Lscala/collection/immutable/Map;)V]
KafkaTestUtils.sendMessages ( String topic, String[ ] messages ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.sendMessages:(Ljava/lang/String;[Ljava/lang/String;)V]
KafkaTestUtils.setup ( ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.setup:()V]
KafkaTestUtils.teardown ( ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.teardown:()V]
KafkaTestUtils.waitUntilLeaderOffset ( String topic, int partition, long offset ) : void
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.waitUntilLeaderOffset:(Ljava/lang/String;IJ)V]
KafkaTestUtils.zkAddress ( ) : String
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.zkAddress:()Ljava/lang/String;]
KafkaTestUtils.zookeeperClient ( ) : org.I0Itec.zkclient.ZkClient
[mangled: org/apache/spark/streaming/kafka/KafkaTestUtils.zookeeperClient:()Lorg/I0Itec/zkclient/ZkClient;]
spark-streaming_2.10-1.4.0.jar, Checkpoint.class
package org.apache.spark.streaming
Checkpoint.createSparkConf ( ) : org.apache.spark.SparkConf
[mangled: org/apache/spark/streaming/Checkpoint.createSparkConf:()Lorg/apache/spark/SparkConf;]
Checkpoint.deserialize ( java.io.InputStream p1, org.apache.spark.SparkConf p2 ) [static] : Checkpoint
[mangled: org/apache/spark/streaming/Checkpoint.deserialize:(Ljava/io/InputStream;Lorg/apache/spark/SparkConf;)Lorg/apache/spark/streaming/Checkpoint;]
Checkpoint.getCheckpointFiles ( String p1, scala.Option<org.apache.hadoop.fs.FileSystem> p2 ) [static] : scala.collection.Seq<org.apache.hadoop.fs.Path>
[mangled: org/apache/spark/streaming/Checkpoint.getCheckpointFiles:(Ljava/lang/String;Lscala/Option;)Lscala/collection/Seq;]
Checkpoint.serialize ( Checkpoint p1, org.apache.spark.SparkConf p2 ) [static] : byte[ ]
[mangled: org/apache/spark/streaming/Checkpoint.serialize:(Lorg/apache/spark/streaming/Checkpoint;Lorg/apache/spark/SparkConf;)[B]
spark-streaming_2.10-1.4.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.10-1.4.0.jar, InputDStream<T>.class
package org.apache.spark.streaming.dstream
InputDStream<T>.baseScope ( ) : scala.Option<String>
[mangled: org/apache/spark/streaming/dstream/InputDStream<T>.baseScope:()Lscala/Option;]
InputDStream<T>.id ( ) : int
[mangled: org/apache/spark/streaming/dstream/InputDStream<T>.id:()I]
InputDStream<T>.name ( ) : String
[mangled: org/apache/spark/streaming/dstream/InputDStream<T>.name:()Ljava/lang/String;]
spark-streaming_2.10-1.4.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-streaming_2.10-1.4.0.jar, Time.class
package org.apache.spark.streaming
Time.floor ( Duration that, Time zeroTime ) : Time
[mangled: org/apache/spark/streaming/Time.floor:(Lorg/apache/spark/streaming/Duration;Lorg/apache/spark/streaming/Time;)Lorg/apache/spark/streaming/Time;]
to the top
Problems with Data Types, High Severity (7)
spark-catalyst_2.10-1.4.0.jar
package org.apache.spark.sql
[+] Row (3)
| 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 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.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'.
spark-sql_2.10-1.4.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'.
spark-streaming-kafka_2.10-1.4.0.jar
package org.apache.spark.streaming.kafka
[+] KafkaTestUtils (1)
| Change | Effect |
---|
1 | This class has been removed. | A client program may be interrupted by NoClassDefFoundError exception. |
[+] affected methods (33)
brokerAddress ( )This method is from 'KafkaTestUtils' class.
createTopic ( java.lang.String )This method is from 'KafkaTestUtils' class.
eventually ( org.apache.spark.streaming.Time, org.apache.spark.streaming.Time, scala.Function0<T> )This method is from 'KafkaTestUtils' class.
isTraceEnabled ( )This method is from 'KafkaTestUtils' class.
KafkaTestUtils ( )This constructor is from 'KafkaTestUtils' class.
log ( )This method is from 'KafkaTestUtils' class.
logDebug ( scala.Function0<java.lang.String> )This method is from 'KafkaTestUtils' class.
logDebug ( scala.Function0<java.lang.String>, java.lang.Throwable )This method is from 'KafkaTestUtils' class.
logError ( scala.Function0<java.lang.String> )This method is from 'KafkaTestUtils' class.
logError ( scala.Function0<java.lang.String>, java.lang.Throwable )This method is from 'KafkaTestUtils' class.
logInfo ( scala.Function0<java.lang.String> )This method is from 'KafkaTestUtils' class.
logInfo ( scala.Function0<java.lang.String>, java.lang.Throwable )This method is from 'KafkaTestUtils' class.
logName ( )This method is from 'KafkaTestUtils' class.
logTrace ( scala.Function0<java.lang.String> )This method is from 'KafkaTestUtils' class.
logTrace ( scala.Function0<java.lang.String>, java.lang.Throwable )This method is from 'KafkaTestUtils' class.
logWarning ( scala.Function0<java.lang.String> )This method is from 'KafkaTestUtils' class.
logWarning ( scala.Function0<java.lang.String>, java.lang.Throwable )This method is from 'KafkaTestUtils' class.
org.apache.spark.Logging..log_ ( )This method is from 'KafkaTestUtils' class.
org.apache.spark.Logging..log__.eq ( org.slf4j.Logger )This method is from 'KafkaTestUtils' class.
KafkaTestUtils..brokerConf ( )This method is from 'KafkaTestUtils' class.
KafkaTestUtils..brokerConf_.eq ( kafka.server.KafkaConfig )This method is from 'KafkaTestUtils' class.
KafkaTestUtils..brokerConfiguration ( )This method is from 'KafkaTestUtils' class.
KafkaTestUtils..brokerPort_.eq ( int )This method is from 'KafkaTestUtils' class.
KafkaTestUtils..server ( )This method is from 'KafkaTestUtils' class.
KafkaTestUtils..server_.eq ( kafka.server.KafkaServer )This method is from 'KafkaTestUtils' class.
sendMessages ( java.lang.String, java.lang.String[ ] )This method is from 'KafkaTestUtils' class.
sendMessages ( java.lang.String, java.util.Map<java.lang.String,java.lang.Integer> )This method is from 'KafkaTestUtils' class.
sendMessages ( java.lang.String, scala.collection.immutable.Map<java.lang.String,java.lang.Object> )This method is from 'KafkaTestUtils' class.
setup ( )This method is from 'KafkaTestUtils' class.
teardown ( )This method is from 'KafkaTestUtils' class.
waitUntilLeaderOffset ( java.lang.String, int, long )This method is from 'KafkaTestUtils' class.
zkAddress ( )This method is from 'KafkaTestUtils' class.
zookeeperClient ( )This method is from 'KafkaTestUtils' class.
spark-streaming_2.10-1.4.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'.
to the top
Problems with Data Types, Medium Severity (1)
spark-core_2.10-1.4.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>'.
to the top
Problems with Data Types, Low Severity (3)
spark-hive_2.10-1.4.0.jar
package org.apache.spark.sql.hive
[+] HiveContext (3)
| Change | Effect |
---|
1 | Method parseSql ( java.lang.String ) has been moved up type hierarchy to parseSql ( java.lang.String ) | Method parseSql ( java.lang.String ) will be called instead of parseSql ( java.lang.String ) in a client program. |
2 | Method conf ( ) has been overridden by conf ( ) | Method conf ( ) will be called instead of conf ( ) in a client program. |
3 | Method sql ( java.lang.String ) has been overridden by sql ( java.lang.String ) | Method sql ( java.lang.String ) will be called instead of sql ( java.lang.String ) in a client program. |
[+] affected methods (3)
parseSql ( java.lang.String )Method 'parseSql ( java.lang.String )' will be called instead of this method in a client program.
conf ( )Method 'conf ( )' will be called instead of this method in a client program.
sql ( java.lang.String )Method 'sql ( java.lang.String )' will be called instead of this method in a client program.
to the top
Java ARchives (7)
spark-catalyst_2.10-1.4.0.jar
spark-core_2.10-1.4.0.jar
spark-hive_2.10-1.4.0.jar
spark-sql_2.10-1.4.0.jar
spark-streaming-kafka_2.10-1.4.0.jar
spark-streaming_2.10-1.4.0.jar
spark-yarn_2.10-1.4.0.jar
to the top
Generated on Thu Nov 5 07:30:04 2015 for spark-testing-base_2.10-1.4.0_0.2.1 by Java API Compliance Checker 1.4.1
A tool for checking backward compatibility of a Java library API