[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-31 Thread ASF GitHub Bot (JIRA)

[ 
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14723038#comment-14723038
 ] 

ASF GitHub Bot commented on FLINK-2077:
---

Github user gallenvara closed the pull request at:

https://github.com/apache/flink/pull/1035


> Rework Path class and add extend support for Windows paths
> --
>
> Key: FLINK-2077
> URL: https://issues.apache.org/jira/browse/FLINK-2077
> Project: Flink
>  Issue Type: Improvement
>  Components: Core
>Affects Versions: 0.9
>Reporter: Fabian Hueske
>Assignee: GaoLun
>Priority: Minor
>  Labels: starter
>
> The class {{org.apache.flink.core.fs.Path}} handles paths for Flink's 
> {{FileInputFormat}} and {{FileOutputFormat}}. Over time, this class has 
> become quite hard to read and modify. 
> It would benefit from some cleaning and refactoring. Along with the 
> refactoring, support for Windows paths like {{//host/dir1/dir2}} could be 
> added.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-21 Thread ASF GitHub Bot (JIRA)

[ 
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14706317#comment-14706317
 ] 

ASF GitHub Bot commented on FLINK-2077:
---

Github user gallenvara commented on a diff in the pull request:

https://github.com/apache/flink/pull/1035#discussion_r37610286
  
--- Diff: flink-core/src/main/java/org/apache/flink/core/fs/Path.java ---
@@ -430,40 +296,127 @@ public int depth() {
}
 
/**
-* Returns a qualified path object.
-* 
-* @param fs
-*the FileSystem that should be used to obtain the current 
working directory
-* @return the qualified path object
+* Checks if the provided path string is either null or has zero length 
and throws
+* a {@link IllegalArgumentException} if any of the two conditions 
apply.
+* In addition, leading and tailing whitespaces are removed.
+*
+* @param path
+*the path string to be checked
+* @return The checked and trimmed path.
+*/
+   private String checkAndTrimPathArg(String path) {
+   // disallow construction of a Path from an empty string
+   if (path == null) {
+   throw new IllegalArgumentException(Can not create a 
Path from a null string);
+   }
+   path = path.trim();
+   if (path.length() == 0) {
+   throw new IllegalArgumentException(Can not create a 
Path from an empty string);
+   }
+   return path;
+   }
+
+   /**
+* Initializes a path object given the scheme, authority and path 
string.
+*
+* @param scheme
+*the scheme string.
+* @param authority
+*the authority string.
+* @param path
+*the path string.
 */
-   public Path makeQualified(FileSystem fs) {
-   Path path = this;
-   if (!isAbsolute()) {
-   path = new Path(fs.getWorkingDirectory(), this);
+   private void initialize(String scheme, String authority, String path) {
+   try {
+   this.uri = new URI(scheme, authority, 
normalizePath(path), null, null).normalize();
+   } catch (URISyntaxException e) {
+   throw new IllegalArgumentException(e);
}
+   }
 
-   final URI pathUri = path.toUri();
-   final URI fsUri = fs.getUri();
+   /**
+* Normalizes a path string.
+*
+* @param path
+*the path string to normalize
+* @return the normalized path string
+*/
+   private String normalizePath(String path) {
 
-   String scheme = pathUri.getScheme();
-   String authority = pathUri.getAuthority();
+   // remove leading and tailing whitespaces
+   path = path.trim();
 
-   if (scheme != null  (authority != null || 
fsUri.getAuthority() == null)) {
-   return path;
+   // remove consecutive slashes  backslashes
+   path = path.replace(\\, /);
+   path = path.replaceAll(/+, /);
--- End diff --

Hi, @tillrohrmann  thanks for your review. But i haven't modified this line.


 Rework Path class and add extend support for Windows paths
 --

 Key: FLINK-2077
 URL: https://issues.apache.org/jira/browse/FLINK-2077
 Project: Flink
  Issue Type: Improvement
  Components: Core
Affects Versions: 0.9
Reporter: Fabian Hueske
Assignee: GaoLun
Priority: Minor
  Labels: starter

 The class {{org.apache.flink.core.fs.Path}} handles paths for Flink's 
 {{FileInputFormat}} and {{FileOutputFormat}}. Over time, this class has 
 become quite hard to read and modify. 
 It would benefit from some cleaning and refactoring. Along with the 
 refactoring, support for Windows paths like {{//host/dir1/dir2}} could be 
 added.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-21 Thread ASF GitHub Bot (JIRA)

[ 
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14706343#comment-14706343
 ] 

ASF GitHub Bot commented on FLINK-2077:
---

Github user gallenvara commented on the pull request:

https://github.com/apache/flink/pull/1035#issuecomment-133315613
  
@tillrohrmann  I'm new to Flink. Thanks for your words and if i have any 
mistake please point it out.
My idea on this issue is : 
the ```Path``` class has become quite hard to read and modify. In 
```Path``` class, the ```makeQualified``` method hasn't been called once.In 
order to reduce the amount of ```Path``` code and make the class much more 
thinner ,i have moved it to the util named ```FileSystemUtil``` as a tool. 
Also, i think the ```Path``` class handles the input and output's path.The 
```makeQualified``` method handles the FileSystem . I think they are parellel.
So i create the ```FileSystemUtil``` as a tool instead of being a method in 
```Path``` class.


 Rework Path class and add extend support for Windows paths
 --

 Key: FLINK-2077
 URL: https://issues.apache.org/jira/browse/FLINK-2077
 Project: Flink
  Issue Type: Improvement
  Components: Core
Affects Versions: 0.9
Reporter: Fabian Hueske
Assignee: GaoLun
Priority: Minor
  Labels: starter

 The class {{org.apache.flink.core.fs.Path}} handles paths for Flink's 
 {{FileInputFormat}} and {{FileOutputFormat}}. Over time, this class has 
 become quite hard to read and modify. 
 It would benefit from some cleaning and refactoring. Along with the 
 refactoring, support for Windows paths like {{//host/dir1/dir2}} could be 
 added.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-21 Thread ASF GitHub Bot (JIRA)

[ 
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14706415#comment-14706415
 ] 

ASF GitHub Bot commented on FLINK-2077:
---

Github user tillrohrmann commented on a diff in the pull request:

https://github.com/apache/flink/pull/1035#discussion_r37616089
  
--- Diff: flink-core/src/main/java/org/apache/flink/core/fs/Path.java ---
@@ -430,40 +296,127 @@ public int depth() {
}
 
/**
-* Returns a qualified path object.
-* 
-* @param fs
-*the FileSystem that should be used to obtain the current 
working directory
-* @return the qualified path object
+* Checks if the provided path string is either null or has zero length 
and throws
+* a {@link IllegalArgumentException} if any of the two conditions 
apply.
+* In addition, leading and tailing whitespaces are removed.
+*
+* @param path
+*the path string to be checked
+* @return The checked and trimmed path.
+*/
+   private String checkAndTrimPathArg(String path) {
+   // disallow construction of a Path from an empty string
+   if (path == null) {
+   throw new IllegalArgumentException(Can not create a 
Path from a null string);
+   }
+   path = path.trim();
+   if (path.length() == 0) {
+   throw new IllegalArgumentException(Can not create a 
Path from an empty string);
+   }
+   return path;
+   }
+
+   /**
+* Initializes a path object given the scheme, authority and path 
string.
+*
+* @param scheme
+*the scheme string.
+* @param authority
+*the authority string.
+* @param path
+*the path string.
 */
-   public Path makeQualified(FileSystem fs) {
-   Path path = this;
-   if (!isAbsolute()) {
-   path = new Path(fs.getWorkingDirectory(), this);
+   private void initialize(String scheme, String authority, String path) {
+   try {
+   this.uri = new URI(scheme, authority, 
normalizePath(path), null, null).normalize();
+   } catch (URISyntaxException e) {
+   throw new IllegalArgumentException(e);
}
+   }
 
-   final URI pathUri = path.toUri();
-   final URI fsUri = fs.getUri();
+   /**
+* Normalizes a path string.
+*
+* @param path
+*the path string to normalize
+* @return the normalized path string
+*/
+   private String normalizePath(String path) {
 
-   String scheme = pathUri.getScheme();
-   String authority = pathUri.getAuthority();
+   // remove leading and tailing whitespaces
+   path = path.trim();
 
-   if (scheme != null  (authority != null || 
fsUri.getAuthority() == null)) {
-   return path;
+   // remove consecutive slashes  backslashes
+   path = path.replace(\\, /);
+   path = path.replaceAll(/+, /);
--- End diff --

It's not about who has modified this line or not, it's about correctness 
and I think this line is wrong. Thus, it would be good if you corrected it.


 Rework Path class and add extend support for Windows paths
 --

 Key: FLINK-2077
 URL: https://issues.apache.org/jira/browse/FLINK-2077
 Project: Flink
  Issue Type: Improvement
  Components: Core
Affects Versions: 0.9
Reporter: Fabian Hueske
Assignee: GaoLun
Priority: Minor
  Labels: starter

 The class {{org.apache.flink.core.fs.Path}} handles paths for Flink's 
 {{FileInputFormat}} and {{FileOutputFormat}}. Over time, this class has 
 become quite hard to read and modify. 
 It would benefit from some cleaning and refactoring. Along with the 
 refactoring, support for Windows paths like {{//host/dir1/dir2}} could be 
 added.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-21 Thread ASF GitHub Bot (JIRA)

[ 
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14706514#comment-14706514
 ] 

ASF GitHub Bot commented on FLINK-2077:
---

Github user StephanEwen commented on the pull request:

https://github.com/apache/flink/pull/1035#issuecomment-133364252
  
A few more comments from my side:

  - The class overrides `equals()` but `hashCode()` has been removes. This 
is a classical bug.
  - The `compareTo()` method was a nice property (one could use Paths as 
data types and keys). Would be nice to keep it.
  - The main original problem was that the class did not support *mounted* 
drives on Windows, as are common in environments with shared storage (Microsoft 
Azure Cloud). I think these mounted drive paths start with `\\` or `//`.



 Rework Path class and add extend support for Windows paths
 --

 Key: FLINK-2077
 URL: https://issues.apache.org/jira/browse/FLINK-2077
 Project: Flink
  Issue Type: Improvement
  Components: Core
Affects Versions: 0.9
Reporter: Fabian Hueske
Assignee: GaoLun
Priority: Minor
  Labels: starter

 The class {{org.apache.flink.core.fs.Path}} handles paths for Flink's 
 {{FileInputFormat}} and {{FileOutputFormat}}. Over time, this class has 
 become quite hard to read and modify. 
 It would benefit from some cleaning and refactoring. Along with the 
 refactoring, support for Windows paths like {{//host/dir1/dir2}} could be 
 added.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-21 Thread ASF GitHub Bot (JIRA)

[ 
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14706429#comment-14706429
 ] 

ASF GitHub Bot commented on FLINK-2077:
---

Github user tillrohrmann commented on the pull request:

https://github.com/apache/flink/pull/1035#issuecomment-133340112
  
Hi @gallenvara, great to see that more and more new people join the Flink 
community :-)

IMHO, whether a method is used from within the same class or not is not a 
good indicator for moving a method out of it. You'll find many classes in Flink 
which define methods which are not used by itself. It's part of the idea of OOP 
that the methods you define on a class constitute the interface to it. Thus, it 
defines what you can do with it. In that sense, `makeQualified` should stay 
part of the `Path` class, because it allows you to create a qualified path 
object from another path object.

Moreover, scattering functionality around in some static util classes won't 
make it easier for others to actually find it. How should people know that 
there is a class `FileSystemUtil` which allows you to convert paths into 
qualified paths? It's more natural to look at the methods defined in the `Path` 
class. Having much code in one class is not per se bad if you structure it 
clearly and if your methods don't become behemoths it's fine. I also don't 
think that @fhueske had this in mind when he created the JIRA issue.

Maybe I'm totally wrong here, but I think we should close this PR.


 Rework Path class and add extend support for Windows paths
 --

 Key: FLINK-2077
 URL: https://issues.apache.org/jira/browse/FLINK-2077
 Project: Flink
  Issue Type: Improvement
  Components: Core
Affects Versions: 0.9
Reporter: Fabian Hueske
Assignee: GaoLun
Priority: Minor
  Labels: starter

 The class {{org.apache.flink.core.fs.Path}} handles paths for Flink's 
 {{FileInputFormat}} and {{FileOutputFormat}}. Over time, this class has 
 become quite hard to read and modify. 
 It would benefit from some cleaning and refactoring. Along with the 
 refactoring, support for Windows paths like {{//host/dir1/dir2}} could be 
 added.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-20 Thread ASF GitHub Bot (JIRA)

[ 
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704621#comment-14704621
 ] 

ASF GitHub Bot commented on FLINK-2077:
---

Github user tillrohrmann commented on the pull request:

https://github.com/apache/flink/pull/1035#issuecomment-132962489
  
@gallenvara, could you elaborate a little bit on why you've moved the 
`makeQualified` method into the static `FileSystemUtil` class? What's the 
benefit of it. Is this the only thing which can be refactored to make the 
`Path` class more readable?


 Rework Path class and add extend support for Windows paths
 --

 Key: FLINK-2077
 URL: https://issues.apache.org/jira/browse/FLINK-2077
 Project: Flink
  Issue Type: Improvement
  Components: Core
Affects Versions: 0.9
Reporter: Fabian Hueske
Assignee: GaoLun
Priority: Minor
  Labels: starter

 The class {{org.apache.flink.core.fs.Path}} handles paths for Flink's 
 {{FileInputFormat}} and {{FileOutputFormat}}. Over time, this class has 
 become quite hard to read and modify. 
 It would benefit from some cleaning and refactoring. Along with the 
 refactoring, support for Windows paths like {{//host/dir1/dir2}} could be 
 added.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-20 Thread ASF GitHub Bot (JIRA)

[ 
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704613#comment-14704613
 ] 

ASF GitHub Bot commented on FLINK-2077:
---

Github user tillrohrmann commented on a diff in the pull request:

https://github.com/apache/flink/pull/1035#discussion_r37512972
  
--- Diff: flink-core/src/main/java/org/apache/flink/core/fs/Path.java ---
@@ -430,40 +296,127 @@ public int depth() {
}
 
/**
-* Returns a qualified path object.
-* 
-* @param fs
-*the FileSystem that should be used to obtain the current 
working directory
-* @return the qualified path object
+* Checks if the provided path string is either null or has zero length 
and throws
+* a {@link IllegalArgumentException} if any of the two conditions 
apply.
+* In addition, leading and tailing whitespaces are removed.
+*
+* @param path
+*the path string to be checked
+* @return The checked and trimmed path.
+*/
+   private String checkAndTrimPathArg(String path) {
+   // disallow construction of a Path from an empty string
+   if (path == null) {
+   throw new IllegalArgumentException(Can not create a 
Path from a null string);
+   }
+   path = path.trim();
+   if (path.length() == 0) {
+   throw new IllegalArgumentException(Can not create a 
Path from an empty string);
+   }
+   return path;
+   }
+
+   /**
+* Initializes a path object given the scheme, authority and path 
string.
+*
+* @param scheme
+*the scheme string.
+* @param authority
+*the authority string.
+* @param path
+*the path string.
 */
-   public Path makeQualified(FileSystem fs) {
-   Path path = this;
-   if (!isAbsolute()) {
-   path = new Path(fs.getWorkingDirectory(), this);
+   private void initialize(String scheme, String authority, String path) {
+   try {
+   this.uri = new URI(scheme, authority, 
normalizePath(path), null, null).normalize();
+   } catch (URISyntaxException e) {
+   throw new IllegalArgumentException(e);
}
+   }
 
-   final URI pathUri = path.toUri();
-   final URI fsUri = fs.getUri();
+   /**
+* Normalizes a path string.
+*
+* @param path
+*the path string to normalize
+* @return the normalized path string
+*/
+   private String normalizePath(String path) {
 
-   String scheme = pathUri.getScheme();
-   String authority = pathUri.getAuthority();
+   // remove leading and tailing whitespaces
+   path = path.trim();
 
-   if (scheme != null  (authority != null || 
fsUri.getAuthority() == null)) {
-   return path;
+   // remove consecutive slashes  backslashes
+   path = path.replace(\\, /);
+   path = path.replaceAll(/+, /);
--- End diff --

Doesn't this also replaces a single `/` with a `/`. Maybe the regex should 
be `//+`.


 Rework Path class and add extend support for Windows paths
 --

 Key: FLINK-2077
 URL: https://issues.apache.org/jira/browse/FLINK-2077
 Project: Flink
  Issue Type: Improvement
  Components: Core
Affects Versions: 0.9
Reporter: Fabian Hueske
Assignee: GaoLun
Priority: Minor
  Labels: starter

 The class {{org.apache.flink.core.fs.Path}} handles paths for Flink's 
 {{FileInputFormat}} and {{FileOutputFormat}}. Over time, this class has 
 become quite hard to read and modify. 
 It would benefit from some cleaning and refactoring. Along with the 
 refactoring, support for Windows paths like {{//host/dir1/dir2}} could be 
 added.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-19 Thread ASF GitHub Bot (JIRA)

[ 
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14702656#comment-14702656
 ] 

ASF GitHub Bot commented on FLINK-2077:
---

Github user zentol commented on the pull request:

https://github.com/apache/flink/pull/1035#issuecomment-132481210
  
The changes i see are:
* removed hashCode()
* moved makeQualified to a new file as a static method
* reordered the remaining methods in Path

is that about right?


 Rework Path class and add extend support for Windows paths
 --

 Key: FLINK-2077
 URL: https://issues.apache.org/jira/browse/FLINK-2077
 Project: Flink
  Issue Type: Improvement
  Components: Core
Affects Versions: 0.9
Reporter: Fabian Hueske
Assignee: GaoLun
Priority: Minor
  Labels: starter

 The class {{org.apache.flink.core.fs.Path}} handles paths for Flink's 
 {{FileInputFormat}} and {{FileOutputFormat}}. Over time, this class has 
 become quite hard to read and modify. 
 It would benefit from some cleaning and refactoring. Along with the 
 refactoring, support for Windows paths like {{//host/dir1/dir2}} could be 
 added.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-18 Thread ASF GitHub Bot (JIRA)

[ 
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14702375#comment-14702375
 ] 

ASF GitHub Bot commented on FLINK-2077:
---

GitHub user gallenvara opened a pull request:

https://github.com/apache/flink/pull/1035

[FLINK-2077] [core] Rework Path class and add extend support for Windows 
paths

The class org.apache.flink.core.fs.Path handles paths for Flink's 
FileInputFormat and FileOutputFormat. Over time, this class has become quite 
hard to read and modify.
This PR does some work on cleaning and refactoring.

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/gallenvara/flink path_refactor

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/flink/pull/1035.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1035


commit 526a50a4ba38ae84574c31a6e67b39ac14649d44
Author: gallenvara gallenv...@126.com
Date:   2015-08-18T10:31:40Z

[Flink-2077] Clean and refactor the Path class.

commit 4fb1b03f89d1a3a2793e957ff0132ba70bffb3a6
Author: gallenvara gallenv...@126.com
Date:   2015-08-19T01:41:55Z

[Flink-2077] Clean and refactor the Path class.

commit 380ed45473f51ff2835bf8fcaa00e45c7b0b
Author: gallenvara gallenv...@126.com
Date:   2015-08-19T02:46:46Z

[Flink-2077] Clean and refactor the Path class.

commit b7c770df6b2b255a30b5af5589544bf1597f32f5
Author: gallenvara gallenv...@126.com
Date:   2015-08-19T03:22:41Z

[FLINK-2077] [core] Rework Path class and add extend support for Windows 
paths




 Rework Path class and add extend support for Windows paths
 --

 Key: FLINK-2077
 URL: https://issues.apache.org/jira/browse/FLINK-2077
 Project: Flink
  Issue Type: Improvement
  Components: Core
Affects Versions: 0.9
Reporter: Fabian Hueske
Assignee: GaoLun
Priority: Minor
  Labels: starter

 The class {{org.apache.flink.core.fs.Path}} handles paths for Flink's 
 {{FileInputFormat}} and {{FileOutputFormat}}. Over time, this class has 
 become quite hard to read and modify. 
 It would benefit from some cleaning and refactoring. Along with the 
 refactoring, support for Windows paths like {{//host/dir1/dir2}} could be 
 added.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-13 Thread Fabian Hueske (JIRA)

[ 
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695236#comment-14695236
 ] 

Fabian Hueske commented on FLINK-2077:
--

Hi Lun,

{{//host/dir1/dir2}} is an example for a path to a Windows share, i.e., a path 
to a directory {{dir1/dir2}} which is shared by a host {{host}}. You can check 
the [Windows Dev 
Center|https://msdn.microsoft.com/en-us/library/windows/desktop/aa365247%28v=vs.85%29.aspx#paths]
 for Windows path specification.

However, the focus of this JIRA would be rather to clean up the {{Path}} class 
which exists for a long time and has been changed at several places. Now it is 
a bit messed up and hard to maintain.
Adding support for Windows share paths would be nice but is not mandatory.

Thanks, Fabian

 Rework Path class and add extend support for Windows paths
 --

 Key: FLINK-2077
 URL: https://issues.apache.org/jira/browse/FLINK-2077
 Project: Flink
  Issue Type: Improvement
  Components: Core
Affects Versions: 0.9
Reporter: Fabian Hueske
Assignee: GaoLun
Priority: Minor
  Labels: starter

 The class {{org.apache.flink.core.fs.Path}} handles paths for Flink's 
 {{FileInputFormat}} and {{FileOutputFormat}}. Over time, this class has 
 become quite hard to read and modify. 
 It would benefit from some cleaning and refactoring. Along with the 
 refactoring, support for Windows paths like {{//host/dir1/dir2}} could be 
 added.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-12 Thread GaoLun (JIRA)

[ 
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693036#comment-14693036
 ] 

GaoLun commented on FLINK-2077:
---

Hi, Fabian.
what do you mean about 'path like //host/dir1/dir2' ? 
In the dir1 or dir2 ,there must hava several '/' .How to pick out dir1 and dir2 
with a slash '/' 

 Rework Path class and add extend support for Windows paths
 --

 Key: FLINK-2077
 URL: https://issues.apache.org/jira/browse/FLINK-2077
 Project: Flink
  Issue Type: Improvement
  Components: Core
Affects Versions: 0.9
Reporter: Fabian Hueske
Assignee: GaoLun
Priority: Minor
  Labels: starter

 The class {{org.apache.flink.core.fs.Path}} handles paths for Flink's 
 {{FileInputFormat}} and {{FileOutputFormat}}. Over time, this class has 
 become quite hard to read and modify. 
 It would benefit from some cleaning and refactoring. Along with the 
 refactoring, support for Windows paths like {{//host/dir1/dir2}} could be 
 added.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-11 Thread Fabian Hueske (JIRA)

[ 
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14681419#comment-14681419
 ] 

Fabian Hueske commented on FLINK-2077:
--

Hi [~gallenvara_bg], thanks for picking this issue.
I'll assign it to you.

Let me know if you have questions.

 Rework Path class and add extend support for Windows paths
 --

 Key: FLINK-2077
 URL: https://issues.apache.org/jira/browse/FLINK-2077
 Project: Flink
  Issue Type: Improvement
  Components: Core
Affects Versions: 0.9
Reporter: Fabian Hueske
Priority: Minor
  Labels: starter

 The class {{org.apache.flink.core.fs.Path}} handles paths for Flink's 
 {{FileInputFormat}} and {{FileOutputFormat}}. Over time, this class has 
 become quite hard to read and modify. 
 It would benefit from some cleaning and refactoring. Along with the 
 refactoring, support for Windows paths like {{//host/dir1/dir2}} could be 
 added.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-10 Thread GaoLun (JIRA)

[ 
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14681157#comment-14681157
 ] 

GaoLun commented on FLINK-2077:
---

If no one work for this issue , i will work it.

 Rework Path class and add extend support for Windows paths
 --

 Key: FLINK-2077
 URL: https://issues.apache.org/jira/browse/FLINK-2077
 Project: Flink
  Issue Type: Improvement
  Components: Core
Affects Versions: 0.9
Reporter: Fabian Hueske
Priority: Minor
  Labels: starter

 The class {{org.apache.flink.core.fs.Path}} handles paths for Flink's 
 {{FileInputFormat}} and {{FileOutputFormat}}. Over time, this class has 
 become quite hard to read and modify. 
 It would benefit from some cleaning and refactoring. Along with the 
 refactoring, support for Windows paths like {{//host/dir1/dir2}} could be 
 added.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)