2017-06-20 2 views
0

Ich möchte Flink-Connector zur OrientDB-Datenbank bauen. Ich will Daten Lokalität Merkmal behandeln, was ist der beste Weg, alle Daten parallel in einem Datensatz zu laden? Ich weiß, dass ich mit der OrientDB-Methode zum Lesen von Daten umgehen muss, aber auf der anderen Seite sind die Prinzipien und Best Practices, mit denen ich diese Art von Aufgabe bewältigen muss.Was ist der beste Weg, um einen Apache Flink Stecker zu bauen?

Antwort

0

können Sie beziehen sich auf flink-hbase Stecker unter flink-Anschlüsse in flink source. Grundsätzlich müssen Sie die Schnittstelle InputFormat oder RichInputFormat implementieren, wenn Sie die RuntimeContext benötigen.

Verwandte Themen