6731ec1e48d0a0092dd2330adda73bcf37fda8d7
Files Diff
- Added: 0
- Removed: 1
- Renamed: 0
- Modified: 28
Link to commit
Third party dependencies:
| Dependency Action | |
|---|---|
| Added | |
| com.github.scopt:scopt_2.10:3.2.0 | |
| org.clapper:grizzled-slf4j_2.10:1.0.2 | |
| org.apache.avro:avro:1.7.6 | |
| org.joda:joda-convert:1.7 | |
| com.typesafe.akka:akka-remote_2.10:2.3.7 | |
| org.scala-lang:scala-compiler:2.10.4 | |
| commons-beanutils:commons-beanutils-bean-collections:1.8.3 | |
| org.javassist:javassist:3.18.2-GA | |
| org.scalatest:scalatest_2.10:2.2.2 | |
| com.fasterxml.jackson.core:jackson-databind:2.7.4 | |
| com.fasterxml.jackson.core:jackson-annotations:2.7.4 | |
| com.typesafe.akka:akka-camel_2.10:2.3.7 | |
| com.101tec:zkclient:0.7 | |
| org.apache.commons:commons-compress:1.4.1 | |
| io.netty:netty-all:4.0.27.Final | |
| joda-time:joda-time:2.5 | |
| com.typesafe.akka:akka-slf4j_2.10:2.3.7 | |
| com.google.code.findbugs:jsr305:1.3.9 | |
| org.scala-lang:scala-library:2.10.4 | |
| org.apache.commons:commons-math3:3.5 | |
| org.apache.avro:avro-ipc:1.7.6 | |
| org.apache.httpcomponents:httpcore:4.2.5 | |
| com.typesafe.akka:akka-testkit_2.10:2.3.7 | |
| org.apache.httpcomponents:httpclient:4.2.6 | |
| com.fasterxml.jackson.core:jackson-core:2.7.4 | |
| commons-configuration:commons-configuration:1.7 | |
| commons-collections:commons-collections:3.2.2 | |
| commons-cli:commons-cli:1.3.1 | |
| org.scala-lang:scala-reflect:2.10.4 | |
| com.typesafe.akka:akka-actor_2.10:2.3.7 | |
| commons-io:commons-io:2.4 | |
| org.apache.zookeeper:zookeeper:3.4.6 | |
| com.esotericsoftware.kryo:kryo:2.24.0 |
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 6 | ||
| Change Parameter Type serializationSchema : KeyedSerializationSchema<IN> to serializationSchema : KeyedSerializationSchema<T> in method public FlinkKafkaProducer010(topicId String, serializationSchema KeyedSerializationSchema<T>, producerConfig Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010 | From | To | |
| Change Parameter Type serializationSchema : SerializationSchema<IN> to serializationSchema : SerializationSchema<T> in method public FlinkKafkaProducer010(topicId String, serializationSchema SerializationSchema<T>, producerConfig Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010 | From | To | |
| Change Parameter Type serializationSchema : SerializationSchema<IN> to serializationSchema : SerializationSchema<T> in method public FlinkKafkaProducer010(topicId String, serializationSchema SerializationSchema<T>, producerConfig Properties, customPartitioner KafkaPartitioner<T>) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010 | From | To | |
| Change Parameter Type serializationSchema : SerializationSchema<IN> to serializationSchema : SerializationSchema<T> in method public FlinkKafkaProducer010(brokerList String, topicId String, serializationSchema SerializationSchema<T>) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010 | From | To | |
| Change Parameter Type customPartitioner : KafkaPartitioner<IN> to customPartitioner : KafkaPartitioner<T> in method public FlinkKafkaProducer010(topicId String, serializationSchema SerializationSchema<T>, producerConfig Properties, customPartitioner KafkaPartitioner<T>) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010 | From | To | |
| Change Parameter Type serializationSchema : KeyedSerializationSchema<IN> to serializationSchema : KeyedSerializationSchema<T> in method public FlinkKafkaProducer010(brokerList String, topicId String, serializationSchema KeyedSerializationSchema<T>) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010 | From | To | |
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute props : Properties to standardProps : Properties in method public runMetricsTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase | From | To | |
| Extract Variable | 2 | ||
| Extract Variable testTopic : String in method public testPunctuatedWatermarks() : void from class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcherTimestampsTest | From | To | |
| Extract Variable testTopic : String in method public testPeriodicWatermarks() : void from class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcherTimestampsTest | From | To | |
| Extract Method | 2 | ||
| Extract Method public cancelCurrentJob(jobManager ActorGateway, name String) : void extracted from public cancelCurrentJob(jobManager ActorGateway) : void in class org.apache.flink.streaming.connectors.kafka.testutils.JobManagerCommunicationUtils | From | To | |
| Extract Method protected assignPartitionsToConsumer(consumer KafkaConsumer<byte[],byte[]>, topicPartitions List<TopicPartition>) : void extracted from public run() : void in class org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter forwardKafkaMetrics : boolean to useMetrics : boolean in method public Kafka010Fetcher(sourceContext SourceContext<T>, assignedPartitions List<KafkaTopicPartition>, watermarksPeriodic SerializedValue<AssignerWithPeriodicWatermarks<T>>, watermarksPunctuated SerializedValue<AssignerWithPunctuatedWatermarks<T>>, runtimeContext StreamingRuntimeContext, deserializer KeyedDeserializationSchema<T>, kafkaProperties Properties, pollTimeout long, useMetrics boolean) in class org.apache.flink.streaming.connectors.kafka.internal.Kafka010Fetcher | From | To |