Path	Lines of Code
elasticsearch/src/main/java/org/apache/pekko/stream/connectors/elasticsearch/ApiVersion.java	5
elasticsearch/src/main/java/org/apache/pekko/stream/connectors/elasticsearch/ApiVersionBase.java	2
elasticsearch/src/main/java/org/apache/pekko/stream/connectors/elasticsearch/OpensearchApiVersion.java	4
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchConnectionSettings.scala	78
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchParams.scala	16
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchSourceSettings.scala	40
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchWriteSettings.scala	75
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/OpensearchConnectionSettings.scala	7
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/OpensearchParams.scala	4
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/OpensearchSourceSettings.scala	40
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/OpensearchWriteSettings.scala	35
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ReadResult.scala	25
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/SourceSettingsBase.scala	37
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/WriteMessage.scala	121
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/WriteSettingsBase.scala	26
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchApi.scala	22
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSimpleFlowStage.scala	123
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSourceStage.scala	265
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/NDJsonProtocol.scala	7
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/RestBulkApi.scala	50
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/RestBulkApiV5.scala	59
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/RestBulkApiV7.scala	52
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchFlow.scala	73
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSink.scala	16
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSource.scala	123
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/scaladsl/ElasticsearchFlow.scala	134
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/scaladsl/ElasticsearchSink.scala	12
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/scaladsl/ElasticsearchSource.scala	81
elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/testkit/MessageFactory.scala	35