Technology sharing

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

1) Overview

1. Praedefinitum Source et pessum

Fontes notitiarum praedefinitorum subsidii legendi notitias ex fasciculis, directoriis, basibus, necnon collectionibus et iteratoribus.

Praedefinita notitia subsidia scribendi notitias ad fasciculos deprimit, vexillum output (stdout), vexillum errorum output (stderr), ac bases.

2. Connector inclusa

Connector cum variis systematis tertii-partii correspondet, et nunc sequentes systemata sustinet.

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. Connectors in Apache Bahir

Flink etiam connexiones additionales per Apache Bahir distributas habet, inter quas:

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

4. Aliae modi ad coniungere ad Flink

a) Asynchronous I / O *

Connexiones per connexiones non solum est ut notitias vel ex Flink accipias.

Potes quaerere notitias ex datorum externo aut instrumentorum telae ad ut initium notitiae fluminis accipias, et deinde transire velis Map or *FlatMap Ad initiales notitias fluentis processus, Flink praebet asynchronum I/O API, ut hunc processum simpliciorem, efficaciorem magisque stabiliorem reddat.