Teknologian jakaminen

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

1) Yleiskatsaus

1. Ennalta määritetty lähde ja nielu

Ennalta määritetyt tietolähteet tukevat tietojen lukemista tiedostoista, hakemistoista, socketeista sekä kokoelmista ja iteraattoreista.

Ennalta määritetyt tietonielut tukevat tietojen kirjoittamista tiedostoihin, vakiotulostusta (stdout), vakiovirhetulostusta (stderr) ja pistokkeista.

2. Mukana liitin

Liitin voi olla vuorovaikutuksessa useiden kolmannen osapuolen järjestelmien kanssa, ja se tukee tällä hetkellä seuraavia järjestelmiä.

Apache Kafka (source/sink)
Apache Cassandra (source/sink)
Amazon DynamoDB (sink)
Amazon Kinesis Data Streams (source/sink)
Amazon Kinesis Data Firehose (sink)
DataGen (source)
Elasticsearch (sink)
Opensearch (sink)
FileSystem (sink)
RabbitMQ (source/sink)
Google PubSub (source/sink)
Hybrid Source (source)
Apache Pulsar (source)
JDBC (sink)
MongoDB (source/sink)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

3. Apache Bahirin liittimet

Flinkillä on myös Apache Bahirin kautta jaettuja lisäliittimiä, mukaan lukien:

Apache ActiveMQ (source/sink)
Apache Flume (sink)
Redis (sink)
Akka (sink)
Netty (source)
1
2
3
4
5

4. Muita tapoja muodostaa yhteys Flinkiin

a) Asynkroninen I/O

Liittimien käyttö ei ole ainoa tapa saada tietoja Flinkistä tai sieltä.

Voit kysyä tietoja ulkoisesta tietokannasta tai verkkopalvelusta saadaksesi alkuperäisen tietovirran ja sitten siirtää Map taiFlatMap Tietovirran alkukäsittelyä varten Flink tarjoaa asynkronisen I/O API:n, joka tekee tästä prosessista yksinkertaisemman, tehokkaamman ja vakaamman.