tranquility

Спокойствие

«Оставайся рядом, друзья мои, и я исцелю твои раны».
–Mythen of the Wild

Спокойство помогает вам отправлять потоки событий в Druid, Raddest Store Data Ever (http://druid.io/), в режиме реального времени. Он обрабатывает разделение, репликацию, обнаружение обслуживания и перенос схемы для вас, плавно и без простоя. Спокойство написано в Scala, и идиоматические идиоматические Java и Scala API, которые прекрасно работают с Finagle, Samza, Spark, Storm и Trident.

Этот проект - друг Друида. Для обсуждения, не стесняйтесь использовать обычные каналы друида: http://druid.io/community/

Документация

Общий:

• Обзор - Введение в концепции спокойствия, в том числе подробности о том, как он создает и управляет Druid задачами.
• Конфигурация - первый шаг к использованию спокойствия - это настройка соответствующей его для вашего Druid DataSource. Обычно это делается с помощью файла конфигурации, с необязательными уточнениями в коде.
• Устранение неполадок - решения для общих проблем.

Модули:

• Core - самый базовый API, распределяющий данные. Скорее всего, вы будете использовать это, если не используете один из модулей более высокого уровня.
• Сервер - HTTP -сервер, который позволяет использовать спокойствие без разработки приложения JVM.
• Самза - спокойствие включает в себя систему Samza SystemProducer.
• Spark - спокойствие работает с RDD и Dstreams.
• Шторм - Спокойство включает в себя штормовой болт и государство Тридента.
• Кафка - приложение для толкания сообщений от Кафки в друид через спокойствие.
• Flink - спокойствие включает в себя раковину.

Получение спокойствия с Maven

Ядро спокойствия, Samza, Spark, Storm и Flink предназначены для включения в приложение, которое вы пишете. Эти модули размещены на Maven Central, чтобы облегчить их включение. Текущие стабильные версии:

< dependency >
  < groupId >io.druid</ groupId >
  < artifactId >tranquility-core_2.11</ artifactId >
  < version >0.8.2</ version >
</ dependency >
< dependency >
  < groupId >io.druid</ groupId >
  < artifactId >tranquility-samza_2.11</ artifactId >
  < version >0.8.2</ version >
</ dependency >
< dependency >
  < groupId >io.druid</ groupId >
  < artifactId >tranquility-spark_2.11</ artifactId >
  < version >0.8.2</ version >
</ dependency >
< dependency >
  < groupId >io.druid</ groupId >
  < artifactId >tranquility-storm_2.11</ artifactId >
  < version >0.8.2</ version >
</ dependency >
< dependency >
  < groupId >io.druid</ groupId >
  < artifactId >tranquility-flink_2.11</ artifactId >
  < version >0.8.2</ version >
</ dependency >

Вам нужно только включить модули, которые вы на самом деле используете.

Все модули спокойствия построены для Scala 2.11.

Эта версия построена для работы с Druid 0.7.x и 0.8.x. Если вы используете Druid 0.6.x, вы можете использовать транвиль v0.3.2, которая является самой последней версией, созданной для использования с Druid 0.6.x.

Спокойство построено с SBT. Если вы хотите самостоятельно построить банки, вы можете запустить sbt +package . Чтобы построить дистрибутив, запустите sbt ++2.11.8 'project distribution' universal:packageZipTarball .

Загружаемое распространение

Скачаемое распределение транвита включает в себя программы Server и Kafka, которые являются автономными программами, которые можно использовать без написания кода. Вы можете скачать дистрибуцию и запустить их напрямую. Распространение также включает в себя основные артефакты API, если вы предпочитаете загружать их, а не проходить через Maven.

Текущее распределение: передача транквиволов-0.8.2.

Чтобы использовать его, сначала загрузите его, а затем распакуйте в свой каталог, запустив tar -xzf tranquility-distribution-0.8.2.tgz .

Как внести свой вклад

См. Appling.md.