Pravega Flink Connectors

Streaming Storage Platform

Лицензия

Лицензия

Группа

Группа

io.pravega
Идентификатор

Идентификатор

pravega-connectors-flink-1.8_2.11
Последняя версия

Последняя версия

0.8.1
Дата

Дата

Тип

Тип

jar
Описание

Описание

Pravega Flink Connectors
Streaming Storage Platform
Ссылка на сайт

Ссылка на сайт

http://pravega.io
Система контроля версий

Система контроля версий

https://github.com/pravega/flink-connectors/tree/master

Скачать pravega-connectors-flink-1.8_2.11

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

<!-- https://jarcasting.com/artifacts/io.pravega/pravega-connectors-flink-1.8_2.11/ -->
<dependency>
    <groupId>io.pravega</groupId>
    <artifactId>pravega-connectors-flink-1.8_2.11</artifactId>
    <version>0.8.1</version>
</dependency>
// https://jarcasting.com/artifacts/io.pravega/pravega-connectors-flink-1.8_2.11/
implementation 'io.pravega:pravega-connectors-flink-1.8_2.11:0.8.1'
// https://jarcasting.com/artifacts/io.pravega/pravega-connectors-flink-1.8_2.11/
implementation ("io.pravega:pravega-connectors-flink-1.8_2.11:0.8.1")
'io.pravega:pravega-connectors-flink-1.8_2.11:jar:0.8.1'
<dependency org="io.pravega" name="pravega-connectors-flink-1.8_2.11" rev="0.8.1">
  <artifact name="pravega-connectors-flink-1.8_2.11" type="jar" />
</dependency>
@Grapes(
@Grab(group='io.pravega', module='pravega-connectors-flink-1.8_2.11', version='0.8.1')
)
libraryDependencies += "io.pravega" % "pravega-connectors-flink-1.8_2.11" % "0.8.1"
[io.pravega/pravega-connectors-flink-1.8_2.11 "0.8.1"]

Зависимости

provided (6)

Идентификатор библиотеки Тип Версия
org.slf4j : slf4j-api jar 1.7.25
org.apache.flink : flink-streaming-java_2.11 jar 1.8.1
org.apache.flink : flink-table-planner_2.11 jar 1.8.1
org.apache.flink : flink-table-api-java-bridge_2.11 jar 1.8.1
org.apache.flink : flink-json jar 1.8.1
org.apache.flink : flink-avro jar 1.8.1

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

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

Pravega Flink Connectors Build Status

This repository implements connectors to read and write Pravega Streams with Apache Flink stream processing framework.

The connectors can be used to build end-to-end stream processing pipelines (see Samples) that use Pravega as the stream storage and message bus, and Apache Flink for computation over the streams.

Features & Highlights

  • Exactly-once processing guarantees for both Reader and Writer, supporting end-to-end exactly-once processing pipelines

  • Seamless integration with Flink's checkpoints and savepoints.

  • Parallel Readers and Writers supporting high throughput and low latency processing.

  • Table API support to access Pravega Streams for both Batch and Streaming use case.

Documentation

To learn more about how to build and use the Flink Connector library, follow the connector documentation here.

More examples on how to use the connectors with Flink application can be found in Pravega Samples repository.

About

Flink connectors for Pravega is 100% open source and community-driven. All components are available under Apache 2 License on GitHub.

io.pravega

Pravega

Streaming Storage Platform

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

Версия
0.8.1
0.8.0