JarCasting
JarCasting JarCasting

Pravega Flink Connectors

Streaming Storage Platform

License

License
GroupId

GroupId

io.pravega
ArtifactId

ArtifactId

pravega-connectors-flink-1.8_2.11
Last Version

Last Version

0.8.1
Release Date

Release Date
Type

Type

jar
Description

Description

Pravega Flink Connectors
Streaming Storage Platform
Project URL

Project URL

http://pravega.io
Source Code Management

Source Code Management

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

Download pravega-connectors-flink-1.8_2.11

Filename Size
pravega-connectors-flink-1.8_2.11-0.8.1.pom
pravega-connectors-flink-1.8_2.11-0.8.1.jar 16 MB
pravega-connectors-flink-1.8_2.11-0.8.1-sources.jar 70 KB
pravega-connectors-flink-1.8_2.11-0.8.1-javadoc.jar 215 KB
Browse

How to add to project

<!-- 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"]

Dependencies

provided (6)

Group / Artifact Type Version
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

Project Modules

There are no modules declared in this project.

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

Versions

Version
0.8.1
0.8.0