Описание тега apache-apex

Apex - это собственная платформа YARN, которая объединяет потоковую и пакетную обработку. Он обрабатывает большие данные в движении, обеспечивая высокую масштабируемость, высокую производительность, отказоустойчивость, отслеживание состояния, безопасность, распределение и простоту эксплуатации.
1 ответ

Apache Apex против Apache Flink

Так как обе являются потоковыми средами, которые обрабатывают события одновременно, каковы основные архитектурные различия между этими двумя технологиями / потоковой средой? Кроме того, каковы некоторые конкретные случаи использования, когда один яв…
24 авг '17 в 12:40
3 ответа

Используйте Apex без DataTorrent RTS

Можно ли использовать Apache Apex без DataTorrent RTS? Это кажется возможным, но я не смог найти учебник по установке собственной сборки исходников apex (для запуска вам нужно как минимум apex двоичный). Я вижу, что Apex CLI доступен после сборки в …
23 ноя '16 в 13:38
1 ответ

Внеочередная обработка в Apache Apex

В документации apache-apex утверждается, что порядок событий в процессорах сохраняется (в зависимости от того, как они генерируются), но означает ли это, что не существует концепции времени-события, которая допускает обработку событий вне очереди? К…
08 апр '16 в 06:09
1 ответ

Есть ли в Apache Apex какой-то веб-интерфейс?

Я совершенно новичок в платформе Apache Apex. Есть ли веб-интерфейс? Я смог запустить Docker Sandbox и пример приложения. Тем не менее, URL отслеживания пряжи указывает на 404 страницы. Например, http://localhost:8088/proxy/application_1527541640016…
28 май '18 в 21:22
1 ответ

Невозможно получить страницу обзора приложения запущенного приложения

В большинстве случаев я не могу перейти к обзору приложений на странице мониторинга приложений. Иногда, когда я захожу, все статистические данные на странице, такие как: логический план, вкладки физического плана вообще не существуют, и ни одна из с…
19 авг '16 в 02:35
1 ответ

Как провести модульное тестирование оператора Kafka 0.9 с Apache Apex?

Репост от users@apex.incubator.apache.org Я хотел бы запустить код модульного тестирования, используя новый оператор Kafka, который поддерживает протокол версии 0.9. В этот процесс я включил версию библиотеки Малхар-Кафки (инкубация 3.3.1) и использ…
22 апр '16 в 14:56
1 ответ

Как создать DAG с JSON в Apache Apex?

Я пытался найти документацию для заполнения экземпляра DAG с использованием JSON. Есть ли где-нибудь официальная документация к формату?
07 апр '16 в 21:39
0 ответов

Apache Apex - Пользовательский менеджер смещения Кафки

Если я напишу свою собственную реализацию OffsetManager для оператора ввода Кафка, Как мне настроить оператор ввода kafka для использования моего собственного менеджера смещений сборки? Я знаю о свойстве "OffsetManager", но может кто-нибудь поделить…
2 ответа

Как сделать пакетную обработку с помощью Apex?

Как я могу создать приложение пакетной обработки с Apache Apex? Все примеры, которые я нашел, были потоковыми приложениями, что означает, что они не заканчиваются, и я хотел бы закрыть мое приложение, как только оно обработает все данные. Спасибо
28 ноя '16 в 07:56
1 ответ

AbstractFileOutputWriter Генерация дубликатов файлов tmp

У меня есть приложение Apache Apex, которое использует Kafka Logs и записывает его в HDFS. Группа обеспечения доступности баз данных достаточно проста, так что есть потребитель Kafka (20 разделов памяти по 2 ГБ для оператора), подключенный потоком к…
19 авг '16 в 00:28
1 ответ

DataTorrent/ Apache Apex с sbt

Некоторое время работал над DataTorrent/ Apex. Можно ли использовать SBT для создания приложений DataTorrent (Java)? Во время выполнения sbt clean assembly в root каталог приложения DataTorrent обнаружил успешную сборку. Но был создан только файл .j…
12 июл '16 в 03:39
1 ответ

Как перезапустить приложение Apache Apex?

Из документации apex ясно, что приложение, запущенное с apache apex, может быть убито или отключено с помощью команд: kill-app & shutdown-app соответственно. Но когда приложение выключено (завершение работы / уничтожение), как перезапустить его из п…
13 июн '16 в 07:52
2 ответа

Чем Apache Apex отличается от Apache Storm?

Apache Apex похож на Apache Storm. Пользователи создают приложение / топологию как направленный ациклический граф (DAG) на обеих платформах. Apex использует операторы / потоки, а Storm использует носики / потоки / болты. Они оба обрабатывают данные…
1 ответ

В чем разница между Apache Spark и Apache Apex?

Apache Apex - это платформа унифицированного управления потоками и пакетной обработкой корпоративного класса с открытым исходным кодом. Используется в платформе GE Predix для IOT. Каковы основные различия между этими двумя платформами? Вопросы С то…
2 ответа

Как передать аргументы в класс application.java в Apache Apex?

Как я могу передать аргументы Application.java учебный класс? Например, как мы проходим (String[] args) в основной метод в Java? Не удалось найти никаких ссылок. Может кто-нибудь поделиться пожалуйста знаниями по этому поводу? Большое спасибо.
15 июн '16 в 15:55
2 ответа

Как рассчитать сетевую задержку между операторами в Apache Apex

Есть ли способ, с помощью которого мы можем предсказать задержку N/W между двумя различными операторами в Apache Apex. В ситуации, когда данные, которые будут использоваться оператором, находятся на другом компьютере; это добавит к задержке оператор…
20 фев '17 в 12:54
3 ответа

Могу ли я получить пример кода для использования сообщения avro kafka?

Я только что установил платформу Datatorrent RTS (Apache Apex) и запустил демонстрацию pi. Я хочу использовать "avro" сообщения от kafka, а затем собирать и хранить данные в формате hdf. Можно ли получить пример кода для этого или кафки?
15 апр '16 в 17:53
1 ответ

Как получить ApplicationID из приложения Apache Apex?

Можно ли получить идентификатор приложения Apex: egapplication_1463594017097_0024 в программе Apex? Например, из объекта DAG или другого объекта?
21 май '16 в 03:17
1 ответ

Ошибка архетипа Maven при создании нового проекта Apache Apex

Я следую за документацией, связанной с Apache Apex, которая помогает создать проект запуска. https://apex.apache.org/docs/apex-3.4/apex_development_setup/ Выполняя команду maven, @echo off @rem Script for creating a new application setlocal mvn arch…
16 фев '17 в 06:48
2 ответа

Не удалось запустить Apache Apex Cli

Я пытаюсь запустить Apache Apex cli, но не могу этого сделать. в документе написано только тип apex в командной строке, но это говорит No command 'apex' found Есть ли некоторые предварительные шаги, которые мне нужно выполнить, прежде чем начать его…
09 янв '17 в 09:04