我使用elasticsearch连接器作为接收器将数据插入elasticsearch(请参阅:https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/connectors/elasticsearch.html).
但是,我没有找到任何连接器来从elasticsearch获取数据作为源。
在flink管道中是否有任何连接器或示例可以使用elasticsearch文档作为源?
当做,
阿里
我使用elasticsearch连接器作为接收器将数据插入elasticsearch(请参阅:https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/connectors/elasticsearch.html).
但是,我没有找到任何连接器来从elasticsearch获取数据作为源。
在flink管道中是否有任何连接器或示例可以使用elasticsearch文档作为源?
当做,
阿里
2条答案
按热度按时间9cbw7uwe1#
我最终定义了一个简单的readfromlasticsearch函数
inkz8wg92#
我不知道flink有没有明确的es来源。我确实看到一个用户在谈论使用elasticsearch hadoop作为
HadoopInputFormat
但我不知道这是否对他们有效(见他们的代码)。