f2909293cbb37cc4b4516e3bef4db66376159e52
Files Diff
- Added: 11
- Removed: 5
- Renamed: 0
- Modified: 12
Link to commit
Third party dependencies:
| Dependency Action | |
|---|---|
| Removed | |
| com.github.scopt:scopt_2.10:3.2.0 | |
| org.apache.avro:avro:1.7.6 | |
| org.eclipse.jetty:jetty-servlet:8.0.0.M1 | |
| org.apache.hadoop:hadoop-common:2.2.0 | |
| org.eclipse.jetty:jetty-security:8.0.0.M1 | |
| com.typesafe.akka:akka-remote_2.10:2.3.7 | |
| org.scala-lang:scala-compiler:2.10.4 | |
| org.scalatest:scalatest_2.10:2.2.2 | |
| org.apache.hadoop:hadoop-core:2.2.0 | |
| org.eclipse.jetty:jetty-util:8.0.0.M1 | |
| commons-collections:commons-collections:3.2.1 | |
| com.typesafe.akka:akka-camel_2.10:2.3.7 | |
| org.apache.hadoop:hadoop-client:2.2.0 | |
| org.javassist:javassist:3.18.1-GA | |
| org.apache.hadoop:hadoop-yarn-client:2.2.0 | |
| joda-time:joda-time:2.5 | |
| com.typesafe.akka:akka-slf4j_2.10:2.3.7 | |
| org.apache.hadoop:hadoop-hdfs:2.2.0 | |
| org.ow2.asm:asm:4.0 | |
| stax:stax-api:1.0.1 | |
| org.scala-lang:scala-library:2.10.4 | |
| org.apache.avro:avro-ipc:1.7.6 | |
| com.typesafe.akka:akka-testkit_2.10:2.3.7 | |
| org.eclipse.jetty:jetty-server:8.0.0.M1 | |
| org.scala-lang:scala-reflect:2.10.4 | |
| com.typesafe.akka:akka-actor_2.10:2.3.7 | |
| org.apache.hadoop:hadoop-mapreduce-client-core:2.2.0 | |
| commons-cli:commons-cli:1.2 |
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Class | 5 | ||
| Rename Class org.apache.flink.runtime.fs.hdfs.DistributedDataInputStream renamed to org.apache.flink.runtime.fs.hdfs.HadoopDataInputStream | From | To | |
| Rename Class org.apache.flink.runtime.fs.hdfs.DistributedFileSystem renamed to org.apache.flink.runtime.fs.hdfs.HadoopFileSystem | From | To | |
| Rename Class org.apache.flink.runtime.fs.hdfs.DistributedBlockLocation renamed to org.apache.flink.runtime.fs.hdfs.HadoopBlockLocation | From | To | |
| Rename Class org.apache.flink.runtime.fs.hdfs.DistributedFileStatus renamed to org.apache.flink.runtime.fs.hdfs.HadoopFileStatus | From | To | |
| Rename Class org.apache.flink.runtime.fs.hdfs.DistributedDataOutputStream renamed to org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type f : DistributedFileStatus to f : HadoopFileStatus in method public getFileBlockLocations(file FileStatus, start long, len long) : BlockLocation[] in class org.apache.flink.runtime.fs.maprfs.MapRFileSystem | From | To | |
| Change Variable Type f : DistributedFileStatus to f : HadoopFileStatus in method public getFileBlockLocations(file FileStatus, start long, len long) : BlockLocation[] in class org.apache.flink.runtime.fs.hdfs.HadoopFileSystem | From | To | |
| Extract Method | 3 | ||
| Extract Method private instantiateFileSystem(className String) : FileSystem extracted from public get(uri URI) : FileSystem in class org.apache.flink.core.fs.FileSystem | From | To | |
| Extract Method private instantiateHadoopFileSystemWrapper(wrappedFileSystem Class<?>) : FileSystem extracted from public get(uri URI) : FileSystem in class org.apache.flink.core.fs.FileSystem | From | To | |
| Extract Method private getDefaultHDFSClass() : Class<? extends org.apache.hadoop.fs.FileSystem> extracted from public DistributedFileSystem() in class org.apache.flink.runtime.fs.hdfs.HadoopFileSystem | From | To |