Binary compatibility report for the kafka-spark-consumer-1.0.3 library between 1.2.0 and 1.3.0 versions (relating to the portability of client application kafka-spark-consumer-1.0.3.jar)
Test Info
Library Name | kafka-spark-consumer-1.0.3 |
Version #1 | 1.2.0 |
Version #2 | 1.3.0 |
Java Version | 1.7.0_75 |
Test Results
Total Java ARchives | 2 |
---|
Total Methods / Classes | 158 / 1414 |
---|
Verdict | Incompatible (0.6%) |
Problem Summary
| Severity | Count |
---|
Added Methods | - | 8 |
---|
Removed Methods | High | 1 |
---|
Problems with Data Types | High | 0 |
---|
Medium | 0 |
Low | 0 |
Problems with Methods | High | 0 |
---|
Medium | 0 |
Low | 0 |
Added Methods (8)
spark-streaming_2.10-1.3.0.jar, JavaStreamingContext.class
package org.apache.spark.streaming.api.java
JavaStreamingContext.awaitTerminationOrTimeout ( long timeout ) : boolean
[mangled: org/apache/spark/streaming/api/java/JavaStreamingContext.awaitTerminationOrTimeout:(J)Z]
JavaStreamingContext.binaryRecordsStream ( String directory, int recordLength ) : JavaDStream<byte[ ]>
[mangled: org/apache/spark/streaming/api/java/JavaStreamingContext.binaryRecordsStream:(Ljava/lang/String;I)Lorg/apache/spark/streaming/api/java/JavaDStream;]
JavaStreamingContext.fileStream ( String directory, Class<K> kClass, Class<V> vClass, Class<F> fClass ) : JavaPairInputDStream<K,V>
[mangled: org/apache/spark/streaming/api/java/JavaStreamingContext.fileStream:(Ljava/lang/String;Ljava/lang/Class;Ljava/lang/Class;Ljava/lang/Class;)Lorg/apache/spark/streaming/api/java/JavaPairInputDStream;]
JavaStreamingContext.fileStream ( String directory, Class<K> kClass, Class<V> vClass, Class<F> fClass, org.apache.spark.api.java.function.Function<org.apache.hadoop.fs.Path,Boolean> filter, boolean newFilesOnly ) : JavaPairInputDStream<K,V>
[mangled: org/apache/spark/streaming/api/java/JavaStreamingContext.fileStream:(Ljava/lang/String;Ljava/lang/Class;Ljava/lang/Class;Ljava/lang/Class;Lorg/apache/spark/api/java/function/Function;Z)Lorg/apache/spark/streaming/api/java/JavaPairInputDStream;]
JavaStreamingContext.fileStream ( String directory, Class<K> kClass, Class<V> vClass, Class<F> fClass, org.apache.spark.api.java.function.Function<org.apache.hadoop.fs.Path,Boolean> filter, boolean newFilesOnly, org.apache.hadoop.conf.Configuration conf ) : JavaPairInputDStream<K,V>
[mangled: org/apache/spark/streaming/api/java/JavaStreamingContext.fileStream:(Ljava/lang/String;Ljava/lang/Class;Ljava/lang/Class;Ljava/lang/Class;Lorg/apache/spark/api/java/function/Function;ZLorg/apache/hadoop/conf/Configuration;)Lorg/apache/spark/streaming/api/java/JavaPairInputDStream;]
spark-streaming_2.10-1.3.0.jar, StreamingContext.class
package org.apache.spark.streaming
StreamingContext.awaitTerminationOrTimeout ( long timeout ) : boolean
[mangled: org/apache/spark/streaming/StreamingContext.awaitTerminationOrTimeout:(J)Z]
StreamingContext.binaryRecordsStream ( String directory, int recordLength ) : dstream.DStream<byte[ ]>
[mangled: org/apache/spark/streaming/StreamingContext.binaryRecordsStream:(Ljava/lang/String;I)Lorg/apache/spark/streaming/dstream/DStream;]
StreamingContext.fileStream ( String directory, scala.Function1<org.apache.hadoop.fs.Path,Object> filter, boolean newFilesOnly, org.apache.hadoop.conf.Configuration conf, scala.reflect.ClassTag<K> p5, scala.reflect.ClassTag<V> p6, scala.reflect.ClassTag<F> p7 ) : dstream.InputDStream<scala.Tuple2<K,V>>
[mangled: org/apache/spark/streaming/StreamingContext.fileStream:(Ljava/lang/String;Lscala/Function1;ZLorg/apache/hadoop/conf/Configuration;Lscala/reflect/ClassTag;Lscala/reflect/ClassTag;Lscala/reflect/ClassTag;)Lorg/apache/spark/streaming/dstream/InputDStream;]
to the top
Removed Methods (1)
spark-streaming_2.10-1.2.0.jar, JavaStreamingContext.class
package org.apache.spark.streaming.api.java
JavaStreamingContext.fileStream ( String directory ) : JavaPairInputDStream<K,V>
[mangled: org/apache/spark/streaming/api/java/JavaStreamingContext.fileStream:(Ljava/lang/String;)Lorg/apache/spark/streaming/api/java/JavaPairInputDStream;]
to the top
Java ARchives (2)
spark-core_2.10-1.2.0.jar
spark-streaming_2.10-1.2.0.jar
to the top
Generated on Wed Jun 10 16:23:48 2015 for kafka-spark-consumer-1.0.3 by Java API Compliance Checker 1.4.1
A tool for checking backward compatibility of a Java library API