org.apache.flink.core.fs.Path.compareTo()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(2.4k)|赞(0)|评价(0)|浏览(77)

本文整理了Java中org.apache.flink.core.fs.Path.compareTo()方法的一些代码示例,展示了Path.compareTo()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Path.compareTo()方法的具体详情如下:
包路径:org.apache.flink.core.fs.Path
类名称:Path
方法名:compareTo

Path.compareTo介绍

暂无

代码示例

代码示例来源:origin: apache/flink

@Override
public int compareTo(TimestampedFileInputSplit o) {
  int modTimeComp = Long.compare(this.modificationTime, o.modificationTime);
  if (modTimeComp != 0L) {
    return modTimeComp;
  }
  // the file input split does not prevent null paths.
  if (this.getPath() == null && o.getPath() != null) {
    return 1;
  } else if (this.getPath() != null && o.getPath() == null) {
    return -1;
  }
  int pathComp = this.getPath() == o.getPath() ? 0 :
    this.getPath().compareTo(o.getPath());
  return pathComp != 0 ? pathComp :
    this.getSplitNumber() - o.getSplitNumber();
}

代码示例来源:origin: org.apache.flink/flink-streaming-java_2.11

@Override
public int compareTo(TimestampedFileInputSplit o) {
  int modTimeComp = Long.compare(this.modificationTime, o.modificationTime);
  if (modTimeComp != 0L) {
    return modTimeComp;
  }
  // the file input split does not prevent null paths.
  if (this.getPath() == null && o.getPath() != null) {
    return 1;
  } else if (this.getPath() != null && o.getPath() == null) {
    return -1;
  }
  int pathComp = this.getPath() == o.getPath() ? 0 :
    this.getPath().compareTo(o.getPath());
  return pathComp != 0 ? pathComp :
    this.getSplitNumber() - o.getSplitNumber();
}

代码示例来源:origin: org.apache.flink/flink-streaming-java

@Override
public int compareTo(TimestampedFileInputSplit o) {
  int modTimeComp = Long.compare(this.modificationTime, o.modificationTime);
  if (modTimeComp != 0L) {
    return modTimeComp;
  }
  // the file input split does not prevent null paths.
  if (this.getPath() == null && o.getPath() != null) {
    return 1;
  } else if (this.getPath() != null && o.getPath() == null) {
    return -1;
  }
  int pathComp = this.getPath() == o.getPath() ? 0 :
    this.getPath().compareTo(o.getPath());
  return pathComp != 0 ? pathComp :
    this.getSplitNumber() - o.getSplitNumber();
}

代码示例来源:origin: org.apache.flink/flink-streaming-java_2.10

@Override
public int compareTo(TimestampedFileInputSplit o) {
  int modTimeComp = Long.compare(this.modificationTime, o.modificationTime);
  if (modTimeComp != 0L) {
    return modTimeComp;
  }
  // the file input split does not prevent null paths.
  if (this.getPath() == null && o.getPath() != null) {
    return 1;
  } else if (this.getPath() != null && o.getPath() == null) {
    return -1;
  }
  int pathComp = this.getPath() == o.getPath() ? 0 :
    this.getPath().compareTo(o.getPath());
  return pathComp != 0 ? pathComp :
    this.getSplitNumber() - o.getSplitNumber();
}

相关文章