K
Конфигурейшон чего
HDFS
Size: a a a
2020 September 09
Oℕ
....
K
....
def getSizeByPath(path: String): Long = {
val p = new Path(path)
val fs = p.getFileSystem(new Configuration())
if (fs.exists(p)) fs.getContentSummary(p).getLength else 0
}
val p = new Path(path)
val fs = p.getFileSystem(new Configuration())
if (fs.exists(p)) fs.getContentSummary(p).getLength else 0
}
K
условно такой код
S
Если используются akka stream - там есть FileIO
В zio есть zio-nio
В zio есть zio-nio
GP
def getSizeByPath(path: String): Long = {
val p = new Path(path)
val fs = p.getFileSystem(new Configuration())
if (fs.exists(p)) fs.getContentSummary(p).getLength else 0
}
val p = new Path(path)
val fs = p.getFileSystem(new Configuration())
if (fs.exists(p)) fs.getContentSummary(p).getLength else 0
}
это не тот FileSystem чтоли
S
Oℕ
def getSizeByPath(path: String): Long = {
val p = new Path(path)
val fs = p.getFileSystem(new Configuration())
if (fs.exists(p)) fs.getContentSummary(p).getLength else 0
}
val p = new Path(path)
val fs = p.getFileSystem(new Configuration())
if (fs.exists(p)) fs.getContentSummary(p).getLength else 0
}
можно апи к этому FileSystem
Oℕ
что за либа
K
это не тот FileSystem чтоли
походу чисто хдфсный
K
я проглядел
S
что за либа
да это HDFS клиент джавовый, похоже
GP
походу чисто хдфсный
это хдфс
GP
нету ничего
K
Я почему -то подумал , что стандартный
K
На сигнатуры давно не смотрел
S
нету ничего
а как же альпакка?
GP
На сигнатуры давно не смотрел
conf кидаешь; сам же прислал
K
conf кидаешь; сам же прислал
там явного импорта прост не было у меня
K
поэтому увидел , что FileSystem