bulkProcessorFlushIntervalMillis=params.getInt(CONFIG_KEY_BULK_FLUSH_INTERVAL_MS); | bulkProcessorFlushIntervalMillis=params.getLong(CONFIG_KEY_BULK_FLUSH_INTERVAL_MS); | bulkProcessorFlushIntervalMillis=params.getInt(CONFIG_KEY_BULK_FLUSH_INTERVAL_MS) | bulkProcessorFlushIntervalMillis=params.getLong(CONFIG_KEY_BULK_FLUSH_INTERVAL_MS) | flink | abbd6b02d743486f3c0c1336139dd6b3edd20840 | org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase | | _1 | bulkProcessorFlushIntervalMillis |
---|
_2 | bulkProcessorFlushIntervalMillis |
---|
| TCIVar | bulkProcessorFlushIntervalMillis |
---|
v1 | params |
---|
v2 | CONFIG_KEY_BULK_FLUSH_INTERVAL_MS |
---|
| | TCIVar | bulkProcessorFlushIntervalMillis |
---|
v1 | params |
---|
v2 | CONFIG_KEY_BULK_FLUSH_INTERVAL_MS |
---|
| Uses | True |