avro-sql

Allows to run SQL over an Avro record to morph its structure

Лицензия	Лицензия Apache License 2.0
Группа	Группа com.landoop
Идентификатор	Идентификатор avro-sql
Последняя версия	Последняя версия 0.1
Дата	Дата 21 апр. 2017 г.
Тип	Тип jar
Описание	Описание avro-sql Allows to run SQL over an Avro record to morph its structure
Ссылка на сайт	Ссылка на сайт https://github.com/datamountaineer/kafka-connect-common
Система контроля версий	Система контроля версий https://github.com/datamountaineer/kafka-connect-common.git

Скачать avro-sql

Имя Файла	Размер
avro-sql-0.1.pom
avro-sql-0.1.jar	166 KB
avro-sql-0.1-sources.jar	10 KB
avro-sql-0.1-scaladoc.jar	362 KB
avro-sql-0.1-javadoc.jar	261 bytes
Обзор

Как подключить последнюю версию

Apache Maven

<!-- https://jarcasting.com/artifacts/com.landoop/avro-sql/ -->
<dependency>
    <groupId>com.landoop</groupId>
    <artifactId>avro-sql</artifactId>
    <version>0.1</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/com.landoop/avro-sql/
implementation 'com.landoop:avro-sql:0.1'

Gradle Kotlin

// https://jarcasting.com/artifacts/com.landoop/avro-sql/
implementation ("com.landoop:avro-sql:0.1")

Apache Buildr

'com.landoop:avro-sql:jar:0.1'

Apache Ivy

<dependency org="com.landoop" name="avro-sql" rev="0.1">
  <artifact name="avro-sql" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='com.landoop', module='avro-sql', version='0.1')
)

Scala SBT

libraryDependencies += "com.landoop" % "avro-sql" % "0.1"

Leiningen

[com.landoop/avro-sql "0.1"]

Зависимости

compile (6)

Идентификатор библиотеки	Тип	Версия
org.scala-lang : scala-library	jar	2.11.8
com.typesafe.scala-logging : scala-logging_2.11	jar	3.5.0
com.landoop : sql-core_2.11	jar	1.0
io.confluent » kafka-avro-serializer	jar	3.2.0
com.sksamuel.avro4s : avro4s-core_2.11	jar	1.6.2
org.apache.calcite : calcite-core	jar	1.12.0

test (7)

Идентификатор библиотеки	Тип	Версия
org.mockito : mockito-core	jar	2.7.13
org.scalacheck : scalacheck_2.11	jar	1.11.1
org.scalatest : scalatest_2.11	jar	2.2.6
junit : junit	jar	4.12
org.apache.curator : curator-test	jar	3.1.0
org.powermock : powermock-module-junit4	jar	1.6.5
org.pegdown : pegdown	jar	1.1.0

Модули Проекта

Данный проект не имеет модулей.

Kafka Connect Common is in Maven, include it in your connector.

Releases

Version	Confluent Version	Kafka	Kcql Version	Scala Version
2.0.5	5.4.0	2.4.0	2.8.7	2.12
2.0.4	5.4.0	2.4.0	2.8.7	2.12
2.0.3	5.4.0	2.4.0	2.8.6	2.12
2.0.2	5.4.0	2.4.0	2.8.5	2.12
2.0.1	5.4.0	2.4.0	2.8.4	2.12
2.0.0	5.4.0	2.4.0	2.8.4	2.12
1.1.9	5.0.0	1.1.0	2.8.4	2.11
1.1.8	5.0.0	1.1.0	2.8.4	2.11
1.1.5	5.0.0	1.1.0	2.8.2	2.11
1.1.5	4.1.0	1.1.0	2.8.2	2.11
1.1.4	4.1.0	1.1.0	2.8.2	2.11
1.1.3	4.1.0	1.1.0	2.8	2.11
1.1.2	4.1.0	1.1.0	2.7	2.11
1.1.1	4.1.0	1.1.0	2.5.1	2.11
1.1.0	4.1.0	1.1.0	2.5.1	2.11
1.0.9	4.0.0	1.0.0	2.5.1	2.11
1.0.8	4.0.0	1.0.0	2.5.1	2.11
1.0.7	4.0.0	1.0.0	2.5.1	2.11
1.0.6	4.0.0	1.0.0	2.5.1	2.11
1.0.5	4.0.0	1.0.0	2.5.1	2.11
1.0.4	4.0.0	1.0.0	2.5.1	2.11
1.0.3	4.0.0	1.0.0	2.4	2.11
1.0.2	4.0.0	1.0.0	2.4	2.11
1.0.1	4.0.0	1.0.0	2.4	2.11
1.0.2	4.0.0	1.0.0	2.4	2.11
1.0.1	4.0.0	1.0.0	2.4	2.11
1.0.0	4.0.0	1.0.0	2.4	2.11

#maven
<dependency>
	<groupId>com.datamountaineer</groupId>
	<artifactId>kafka-connect-common</artifactId>
	<version>LATEST</version>
</dependency>

kafka-connect-common

Common components used across the datamountaineer kafka connect connectors.

Packages

Config

SSLConfigConext

Contains class for SSL Context configuration for supplied trust and keystores.

Offsets

The offset handler retrieves, from Kafka the stored offset map per source partition.

Queues

Helper methods to drain LinkedBlockingQueues.

Sink

Contains Writer and KeyBuilder classes.

DbWriter

Defines the contract for inserting a new row for the connect sink record.

KeyBuilder

Builds the new record key for the given connect SinkRecord.
Builds a new key from the payload fields specified.

Schemas

RestService to integrate with the Schema Registry

PayloadFields

Works out the fields and their mappings to be used when inserting a new row.

ConvertUtil

Converts source and sink records to JSON and Avro and back.

StructFieldsExtractor

Extracts fields from a SinkRecord Struct based on a specified set of provided columns.

Версии библиотеки

Версия
0.1 21 апр. 2017 г.