Skip to content

Commit a6935c0

Browse files
committed
HADOOP-16830. RemoteIterators
-move to hadoop.util.functional -add unit tests -use in more code to see how well they work -tune close() and factory names I'm happy with them internally, we do need to mark as unstable at first though. Change-Id: I6493412c2de53468f8c6f6f2184be07db12c00b0
1 parent 84c30a7 commit a6935c0

File tree

19 files changed

+622
-191
lines changed

19 files changed

+622
-191
lines changed

hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/impl/FutureIOSupport.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,8 +32,8 @@
3232
import org.apache.hadoop.classification.InterfaceStability;
3333
import org.apache.hadoop.conf.Configuration;
3434
import org.apache.hadoop.fs.FSBuilder;
35-
import org.apache.hadoop.fs.functional.CallableRaisingIOE;
36-
import org.apache.hadoop.fs.functional.RuntimeIOException;
35+
import org.apache.hadoop.util.functional.CallableRaisingIOE;
36+
import org.apache.hadoop.util.functional.RuntimeIOException;
3737

3838
/**
3939
* Support for future IO and the FS Builder subclasses.

hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/impl/WrappedIOException.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525

2626
import org.apache.hadoop.classification.InterfaceAudience;
2727
import org.apache.hadoop.classification.InterfaceStability;
28-
import org.apache.hadoop.fs.functional.RuntimeIOException;
28+
import org.apache.hadoop.util.functional.RuntimeIOException;
2929

3030
/**
3131
* A wrapper for an IOException which
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
* limitations under the License.
1717
*/
1818

19-
package org.apache.hadoop.fs.functional;
19+
package org.apache.hadoop.util.functional;
2020

2121
import java.io.IOException;
2222

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
* limitations under the License.
1717
*/
1818

19-
package org.apache.hadoop.fs.functional;
19+
package org.apache.hadoop.util.functional;
2020

2121
import java.io.IOException;
2222

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
* limitations under the License.
1717
*/
1818

19-
package org.apache.hadoop.fs.functional;
19+
package org.apache.hadoop.util.functional;
2020

2121
import java.io.IOException;
2222

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
* limitations under the License.
1717
*/
1818

19-
package org.apache.hadoop.fs.functional;
19+
package org.apache.hadoop.util.functional;
2020

2121
import java.io.IOException;
2222

0 commit comments

Comments
 (0)