File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
content.zh/docs/connectors/datastream
content/docs/connectors/datastream Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -251,7 +251,7 @@ input = ...
251
251
# 下面的 set_bulk_flush_max_actions 使 sink 在接收每个元素之后立即提交,否则这些元素将被缓存起来
252
252
es7_sink = Elasticsearch7SinkBuilder() \
253
253
.set_bulk_flush_max_actions(1 ) \
254
- .set_emitter(ElasticsearchEmitter.static (' foo' , ' id' )) \
254
+ .set_emitter(ElasticsearchEmitter.static_index (' foo' , ' id' )) \
255
255
.set_hosts([' localhost:9200' ]) \
256
256
.build()
257
257
Original file line number Diff line number Diff line change @@ -251,7 +251,7 @@ input = ...
251
251
# The set_bulk_flush_max_actions instructs the sink to emit after every element, otherwise they would be buffered
252
252
es7_sink = Elasticsearch7SinkBuilder() \
253
253
.set_bulk_flush_max_actions(1 ) \
254
- .set_emitter(ElasticsearchEmitter.static (' foo' , ' id' )) \
254
+ .set_emitter(ElasticsearchEmitter.static_index (' foo' , ' id' )) \
255
255
.set_hosts([' localhost:9200' ]) \
256
256
.build()
257
257
You can’t perform that action at this time.
0 commit comments