Я установил сервер ноутбука Jupyter в своем офисе и могу получить к нему доступ из дома, просто перейдя к works_pulic_ip: 8888, В последнее время я установил искровой кластер на работу, есть ли способ
Ниже код для получения списка имен файлов в архивный файл def getListOfFilesInRepo(zipFileRDD : RDD[(String,PortableDataStream)]) : (List[String]) = {
val zipInputStream = zipFileRDD.values.map(x
Я пытаюсь зарегистрировать свойства для каждого приложения Spark, которые работают в одном кластере пряжи (такие свойства, как spark.shuffle.compress, spark.reducer.maxMbInFlight, spark.executor.insta
настроения У меня есть вопрос о Apache Spark и Java Я делаю приложение, которое потоки данных из Twitter (Twitter4J). И я также создаю приложение, которое анализирует данные. txt-файл с твитами JSON.