- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Documentation path like ".*/docs/.*" 323 files: google-fcm/src/test/scala/docs/scaladsl/FcmExamples.scala google-fcm/src/test/java/docs/javadsl/FcmExamples.java avroparquet/src/test/scala/docs/scaladsl/AbstractAvroParquetBase.scala avroparquet/src/test/scala/docs/scaladsl/AvroParquetFlowSpec.scala avroparquet/src/test/scala/docs/scaladsl/AvroParquetSourceSpec.scala avroparquet/src/test/scala/docs/scaladsl/AvroParquetSinkSpec.scala avroparquet/src/test/java/docs/javadsl/AvroParquetSinkTest.java avroparquet/src/test/java/docs/javadsl/Examples.java avroparquet/src/test/scala-3/docs/scaladsl/AbstractAvroParquet.scala avroparquet/src/test/scala-2/docs/scaladsl/AbstractAvroParquet.scala solr/src/test/scala/docs/scaladsl/SolrSpec.scala solr/src/test/java/docs/javadsl/SolrTest.java huawei-push-kit/src/test/scala/docs/scaladsl/PushKitExamples.scala huawei-push-kit/src/test/java/docs/javadsl/PushKitExamples.java slick/src/test/scala/docs/scaladsl/SlickWithTryResultSpec.scala slick/src/test/scala/docs/scaladsl/SlickSpec.scala slick/src/test/scala/docs/scaladsl/DocSnippets.scala slick/src/test/java/docs/javadsl/DocSnippetFlowWithPassThrough.java slick/src/test/java/docs/javadsl/SlickTest.java slick/src/test/java/docs/javadsl/DocSnippetSink.java slick/src/test/java/docs/javadsl/DocSnippetSource.java slick/src/test/java/docs/javadsl/DocSnippetFlow.java slick/src/test/java/docs/javadsl/User.java csv/src/test/scala/docs/scaladsl/CsvParsingSpec.scala csv/src/test/scala/docs/scaladsl/CsvToMapSpec.scala csv/src/test/scala/docs/scaladsl/CsvSpec.scala csv/src/test/scala/docs/scaladsl/CsvFormattingSpec.scala csv/src/test/java/docs/javadsl/CsvFormattingTest.java csv/src/test/java/docs/javadsl/CsvToMapTest.java csv/src/test/java/docs/javadsl/CsvParsingTest.java mqtt-streaming/src/test/scala/docs/scaladsl/MqttSessionSpec.scala mqtt-streaming/src/test/scala/docs/scaladsl/MqttCodecSpec.scala mqtt-streaming/src/test/scala/docs/scaladsl/MqttActorSystemsSpec.scala mqtt-streaming/src/test/scala/docs/scaladsl/MqttFlowSpec.scala mqtt-streaming/src/test/java/docs/javadsl/MqttFlowTest.java google-cloud-storage/src/test/scala/docs/scaladsl/GCStorageSinkSpec.scala google-cloud-storage/src/test/scala/docs/scaladsl/GCStorageSourceSpec.scala google-cloud-storage/src/test/java/docs/javadsl/GCStorageTest.java unix-domain-socket/src/test/scala/docs/scaladsl/UnixDomainSocketSpec.scala unix-domain-socket/src/test/java/docs/javadsl/UnixDomainSocketTest.java google-cloud-bigquery-storage/src/test/scala/docs/scaladsl/ExampleReader.scala google-cloud-bigquery-storage/src/test/java/docs/javadsl/ExampleReader.java google-common/src/test/scala/docs/scaladsl/GoogleCommonDoc.scala google-common/src/test/java/docs/javadsl/GoogleCommonDoc.java json-streaming/src/test/scala/docs/scaladsl/JsonReaderTest.scala json-streaming/src/test/java/docs/javadsl/JsonReaderUsageTest.java text/src/test/scala/docs/scaladsl/CharsetCodingFlowsDoc.scala text/src/test/java/docs/javadsl/CharsetCodingFlowsDoc.java amqp/src/test/scala/docs/scaladsl/AmqpDocsSpec.scala amqp/src/test/java/docs/javadsl/AmqpDocsTest.java google-cloud-bigquery/src/test/scala/docs/scaladsl/BigQueryDoc.scala google-cloud-bigquery/src/test/java/docs/javadsl/BigQueryDoc.java file/src/test/scala/docs/scaladsl/TarArchiveSpec.scala file/src/test/scala/docs/scaladsl/DirectorySpec.scala file/src/test/scala/docs/scaladsl/ExecutableUtils.scala file/src/test/scala/docs/scaladsl/FileTailSourceExtrasSpec.scala file/src/test/scala/docs/scaladsl/ArchiveSpec.scala file/src/test/scala/docs/scaladsl/FileTailSourceSpec.scala file/src/test/scala/docs/scaladsl/LogRotatorSinkSpec.scala file/src/test/scala/docs/scaladsl/DirectoryChangesSourceSpec.scala file/src/test/java/docs/javadsl/DirectoryChangesSourceTest.java file/src/test/java/docs/javadsl/DirectoryTest.java file/src/test/java/docs/javadsl/FileTailSourceTest.java file/src/test/java/docs/javadsl/NestedTarReaderTest.java file/src/test/java/docs/javadsl/ArchiveTest.java file/src/test/java/docs/javadsl/LogRotatorSinkTest.java file/src/test/java/docs/javadsl/ArchiveHelper.java ironmq/src/test/scala/docs/scaladsl/IronMqDocsSpec.scala ironmq/src/test/java/docs/javadsl/IronMqDocsTest.java azure-storage-queue/src/test/scala/docs/scaladsl/AzureQueueSpec.scala azure-storage-queue/src/test/java/docs/javadsl/JavaDslTest.java mongodb/src/test/scala/docs/scaladsl/MongoSourceSpec.scala mongodb/src/test/scala/docs/scaladsl/MongoSinkSpec.scala mongodb/src/test/java/docs/javadsl/MongoSinkTest.java mongodb/src/test/java/docs/javadsl/DomainObject.java mongodb/src/test/java/docs/javadsl/Number.java mongodb/src/test/java/docs/javadsl/MongoSourceTest.java simple-codecs/src/test/scala/docs/scaladsl/RecordIOFramingSpec.scala simple-codecs/src/test/java/docs/javadsl/RecordIOFramingTest.java jms/src/test/scala/docs/scaladsl/JmsBufferedAckConnectorsSpec.scala jms/src/test/scala/docs/scaladsl/JmsSettingsSpec.scala jms/src/test/scala/docs/scaladsl/JmsIbmmqConnectorsSpec.scala jms/src/test/scala/docs/scaladsl/JmsConnectorsSpec.scala jms/src/test/scala/docs/scaladsl/JmsTxConnectorsSpec.scala jms/src/test/java/docs/javadsl/JmsConnectorsTest.java jms/src/test/java/docs/javadsl/JmsBufferedAckConnectorsTest.java jms/src/test/java/docs/javadsl/JmsIbmmqConnectorsTest.java jms/src/test/java/docs/javadsl/JmsSettingsTest.java jms/src/test/java/docs/javadsl/JmsTxConnectorsTest.java kudu/src/test/scala/docs/scaladsl/KuduTableSpec.scala kudu/src/test/java/docs/javadsl/KuduTableTest.java elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchSpec.scala elasticsearch/src/test/scala/docs/scaladsl/OpensearchV1Spec.scala elasticsearch/src/test/scala/docs/scaladsl/OpensearchConnectorBehaviour.scala elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchSpecUtils.scala elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchSpecBase.scala elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchConnectorBehaviour.scala elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchV5Spec.scala elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchV7Spec.scala elasticsearch/src/test/java/docs/javadsl/OpensearchV1Test.java elasticsearch/src/test/java/docs/javadsl/ElasticsearchParameterizedTest.java elasticsearch/src/test/java/docs/javadsl/OpensearchParameterizedTest.java elasticsearch/src/test/java/docs/javadsl/ElasticsearchV5Test.java elasticsearch/src/test/java/docs/javadsl/ElasticsearchTestBase.java elasticsearch/src/test/java/docs/javadsl/ElasticsearchV7Test.java ftp/src/test/scala/docs/scaladsl/FtpExamplesSpec.scala ftp/src/test/scala/docs/scaladsl/scalaExamples.scala ftp/src/test/java/docs/javadsl/FtpRemovingExample.java ftp/src/test/java/docs/javadsl/ConfigureCustomSSHClient.java ftp/src/test/java/docs/javadsl/FtpTraversingExample.java ftp/src/test/java/docs/javadsl/FtpMkdirExample.java ftp/src/test/java/docs/javadsl/FtpProcessAndMoveExample.java ftp/src/test/java/docs/javadsl/FtpWritingTest.java ftp/src/test/java/docs/javadsl/FtpMovingExample.java ftp/src/test/java/docs/javadsl/FtpRetrievingExample.java ftp/src/test/java/docs/javadsl/SftpRetrievingExample.java google-cloud-pub-sub-grpc/src/test/scala/docs/scaladsl/IntegrationSpec.scala google-cloud-pub-sub-grpc/src/test/scala/docs/scaladsl/ExampleApp.scala google-cloud-pub-sub-grpc/src/test/java/docs/javadsl/IntegrationTest.java hdfs/src/test/scala/docs/scaladsl/HdfsReaderSpec.scala hdfs/src/test/scala/docs/scaladsl/HdfsWriterSpec.scala hdfs/src/test/java/docs/javadsl/HdfsReaderTest.java hdfs/src/test/java/docs/javadsl/HdfsWriterTest.java spring-web/src/test/java/docs/javadsl/DemoApplication.java spring-web/src/test/java/docs/javadsl/SampleController.java aws-event-bridge/src/test/scala/docs/scaladsl/EventBridgePublisherSpec.scala aws-event-bridge/src/test/java/docs/javadsl/EventBridgePublisherTest.java geode/src/test/scala/docs/scaladsl/PersonPdxSerializer.scala geode/src/test/scala/docs/scaladsl/GeodeFlowSpec.scala geode/src/test/scala/docs/scaladsl/GeodeContinuousSourceSpec.scala geode/src/test/scala/docs/scaladsl/GeodeFiniteSourceSpec.scala geode/src/test/scala/docs/scaladsl/GeodeBaseSpec.scala geode/src/test/scala/docs/scaladsl/Model.scala geode/src/test/scala/docs/scaladsl/GeodeSinkSpec.scala geode/src/test/java/docs/javadsl/GeodeSinkTestCase.java geode/src/test/java/docs/javadsl/AnimalPdxSerializer.java geode/src/test/java/docs/javadsl/GeodeFiniteSourceTestCase.java geode/src/test/java/docs/javadsl/Animal.java geode/src/test/java/docs/javadsl/Person.java geode/src/test/java/docs/javadsl/GeodeFlowTestCase.java geode/src/test/java/docs/javadsl/GeodeBaseTestCase.java geode/src/test/java/docs/javadsl/PersonPdxSerializer.java geode/src/test/java/docs/javadsl/GeodeContinuousSourceTestCase.java sns/src/test/scala/docs/scaladsl/SnsPublisherSpec.scala sns/src/test/java/docs/javadsl/SnsPublisherTest.java influxdb/src/test/scala/docs/scaladsl/InfluxDbSourceSpec.scala influxdb/src/test/scala/docs/scaladsl/InfluxDbSpec.scala influxdb/src/test/scala/docs/scaladsl/InfluxDbSpecCpu.java influxdb/src/test/scala/docs/scaladsl/FlowSpec.scala influxdb/src/test/scala/docs/scaladsl/InfluxDbFlowCpu.java influxdb/src/test/scala/docs/scaladsl/InfluxDbSourceCpu.java influxdb/src/test/java/docs/javadsl/Cpu.java influxdb/src/test/java/docs/javadsl/InfluxDbSourceTest.java influxdb/src/test/java/docs/javadsl/TestConstants.java influxdb/src/test/java/docs/javadsl/TestUtils.java influxdb/src/test/java/docs/javadsl/InfluxDbTest.java influxdb/src/test/java/docs/javadsl/InfluxDbCpu.java influxdb/src/test/java/docs/javadsl/InfluxDbSourceCpu.java docs/src/main/paradox/reference.md docs/src/main/paradox/opensearch.md docs/src/main/paradox/data-transformations/compression.md docs/src/main/paradox/data-transformations/parsing-lines.md docs/src/main/paradox/data-transformations/csv.md docs/src/main/paradox/data-transformations/index.md docs/src/main/paradox/data-transformations/xml.md docs/src/main/paradox/data-transformations/text.md docs/src/main/paradox/data-transformations/json.md docs/src/main/paradox/data-transformations/simple-codecs.md docs/src/main/paradox/unix-domain-socket.md docs/src/main/paradox/examples/elasticsearch-samples.md docs/src/main/paradox/examples/index.md docs/src/main/paradox/examples/jms-samples.md docs/src/main/paradox/examples/ftp-samples.md docs/src/main/paradox/examples/mqtt-samples.md docs/src/main/paradox/sqs.md docs/src/main/paradox/influxdb.md docs/src/main/paradox/hbase.md docs/src/main/paradox/elasticsearch.md docs/src/main/paradox/pravega.md docs/src/main/paradox/spring-web.md docs/src/main/paradox/kinesis.md docs/src/main/paradox/kafka.md docs/src/main/paradox/release-notes/index.md docs/src/main/paradox/release-notes/releases-1.1.md docs/src/main/paradox/release-notes/releases-1.0.md docs/src/main/paradox/bluemix-cos.md docs/src/main/paradox/amqp.md docs/src/main/paradox/azure-storage-queue.md docs/src/main/paradox/kudu.md docs/src/main/paradox/solr.md docs/src/main/paradox/mongodb.md docs/src/main/paradox/google-cloud-pub-sub-grpc.md docs/src/main/paradox/index.md docs/src/main/paradox/google-common.md docs/src/main/paradox/external/grpc.md docs/src/main/paradox/external/http.md docs/src/main/paradox/external/tcp.md docs/src/main/paradox/jms/index.md docs/src/main/paradox/jms/producer.md docs/src/main/paradox/jms/browse.md docs/src/main/paradox/jms/ibm-mq.md docs/src/main/paradox/jms/consumer.md docs/src/main/paradox/couchbase.md docs/src/main/paradox/google-cloud-storage.md docs/src/main/paradox/sns.md docs/src/main/paradox/huawei-push-kit.md docs/src/main/paradox/mqttv5.md docs/src/main/paradox/udp.md docs/src/main/paradox/orientdb.md docs/src/main/paradox/mqtt.md docs/src/main/paradox/geode.md docs/src/main/paradox/s3.md docs/src/main/paradox/awslambda.md docs/src/main/paradox/hdfs.md docs/src/main/paradox/sse.md docs/src/main/paradox/avroparquet.md docs/src/main/paradox/google-fcm.md docs/src/main/paradox/mqtt-streaming.md docs/src/main/paradox/file.md docs/src/main/paradox/google-cloud-pub-sub.md docs/src/main/paradox/dynamodb.md docs/src/main/paradox/aws-event-bridge.md docs/src/main/paradox/ftp.md docs/src/main/paradox/overview.md docs/src/main/paradox/slick.md docs/src/main/paradox/aws-shared-configuration.md docs/src/main/paradox/external-components.md docs/src/main/paradox/google-cloud-bigquery.md docs/src/main/paradox/cassandra.md docs/src/main/paradox/google-cloud-bigquery-storage.md docs/src/main/paradox/other-docs/versioning.md docs/src/main/paradox/other-docs/snapshots.md docs/src/main/paradox/other-docs/webinars-presentations-articles.md docs/src/main/paradox/other-docs/index.md docs/src/main/paradox/ironmq.md docs/src/main/paradox/patterns.md awslambda/src/test/scala/docs/scaladsl/Examples.scala awslambda/src/test/scala/docs/scaladsl/AwsLambdaFlowSpec.scala awslambda/src/test/java/docs/javadsl/Examples.java awslambda/src/test/java/docs/javadsl/AwsLambdaFlowTest.java jakartams/src/test/scala/docs/scaladsl/JmsBufferedAckConnectorsSpec.scala jakartams/src/test/scala/docs/scaladsl/JmsSettingsSpec.scala jakartams/src/test/scala/docs/scaladsl/JmsIbmmqConnectorsSpec.scala jakartams/src/test/scala/docs/scaladsl/JmsConnectorsSpec.scala jakartams/src/test/scala/docs/scaladsl/JmsTxConnectorsSpec.scala jakartams/src/test/java/docs/javadsl/JmsConnectorsTest.java jakartams/src/test/java/docs/javadsl/JmsBufferedAckConnectorsTest.java jakartams/src/test/java/docs/javadsl/JmsIbmmqConnectorsTest.java jakartams/src/test/java/docs/javadsl/JmsSettingsTest.java jakartams/src/test/java/docs/javadsl/JmsTxConnectorsTest.java dynamodb/src/test/scala/docs/scaladsl/ExampleSpec.scala dynamodb/src/test/scala/docs/scaladsl/RetrySpec.scala dynamodb/src/test/java/docs/javadsl/RetryTest.java dynamodb/src/test/java/docs/javadsl/ExampleTest.java sse/src/test/scala/docs/scaladsl/EventSourceSpec.scala sse/src/test/java/docs/javadsl/EventSourceTest.java kinesis/src/test/scala/docs/scaladsl/KinesisSnippets.scala kinesis/src/test/scala/docs/scaladsl/KclSnippets.scala kinesis/src/test/scala/docs/scaladsl/KinesisFirehoseSnippets.scala kinesis/src/test/java/docs/javadsl/KinesisFirehoseSnippets.java kinesis/src/test/java/docs/javadsl/KinesisSnippets.java kinesis/src/test/java/docs/javadsl/KclSnippets.java pravega/src/test/scala/docs/scaladsl/PravegaSettingsSpec.scala pravega/src/test/scala/docs/scaladsl/Serializers.scala pravega/src/test/scala/docs/scaladsl/PravegaReadWriteDocs.scala pravega/src/test/scala/docs/scaladsl/Model.scala pravega/src/test/java/docs/javadsl/PravegaReadWriteDocs.java pravega/src/test/java/docs/javadsl/PravegaSettingsTestCase.java pravega/src/test/java/docs/javadsl/PravegaBaseTestCase.java xml/src/test/scala/docs/scaladsl/XmlSubtreeSpec.scala xml/src/test/scala/docs/scaladsl/XmlSubsliceSpec.scala xml/src/test/scala/docs/scaladsl/XmlCoalesceSpec.scala xml/src/test/scala/docs/scaladsl/XmlProcessingSpec.scala xml/src/test/scala/docs/scaladsl/XmlWritingSpec.scala xml/src/test/java/docs/javadsl/XmlParsingTest.java xml/src/test/java/docs/javadsl/XmlHelper.java xml/src/test/java/docs/javadsl/XmlWritingTest.java mqtt/src/test/scala/docs/scaladsl/MqttSinkSpec.scala mqtt/src/test/scala/docs/scaladsl/MqttSourceSpec.scala mqtt/src/test/scala/docs/scaladsl/MqttFlowSpec.scala mqtt/src/test/scala/docs/scaladsl/MqttSpecBase.scala mqtt/src/test/java/docs/javadsl/MqttSourceTest.java mqtt/src/test/java/docs/javadsl/MqttFlowTest.java couchbase/src/test/scala/docs/scaladsl/CouchbaseSourceSpec.scala couchbase/src/test/scala/docs/scaladsl/CouchbaseSessionExamplesSpec.scala couchbase/src/test/scala/docs/scaladsl/DiscoverySpec.scala couchbase/src/test/scala/docs/scaladsl/CouchbaseFlowSpec.scala couchbase/src/test/java/docs/javadsl/DiscoveryTest.java couchbase/src/test/java/docs/javadsl/CouchbaseExamplesTest.java reference/src/test/scala/docs/scaladsl/ReferenceSpec.scala reference/src/test/java/docs/javadsl/ReferenceTest.java hbase/src/test/scala/docs/scaladsl/HBaseStageSpec.scala hbase/src/test/java/docs/javadsl/HBaseStageTest.java cassandra/src/test/scala/docs/scaladsl/PekkoDiscoverySpec.scala cassandra/src/test/scala/docs/scaladsl/CassandraSourceSpec.scala cassandra/src/test/scala/docs/scaladsl/CassandraFlowSpec.scala cassandra/src/test/java/docs/javadsl/CassandraFlowTest.java cassandra/src/test/java/docs/javadsl/CassandraTestHelper.java cassandra/src/test/java/docs/javadsl/CassandraSourceTest.java udp/src/test/scala/docs/scaladsl/UdpSpec.scala udp/src/test/java/docs/javadsl/UdpTest.java sqs/src/test/scala/docs/scaladsl/SqsSourceSpec.scala sqs/src/test/scala/docs/scaladsl/SqsAckSpec.scala sqs/src/test/scala/docs/scaladsl/SqsPublishSpec.scala sqs/src/test/java/docs/javadsl/SqsAckTest.java sqs/src/test/java/docs/javadsl/SqsPublishTest.java sqs/src/test/java/docs/javadsl/SqsSourceTest.java mqttv5/src/test/scala/docs/scaladsl/MqttSinkSpec.scala mqttv5/src/test/scala/docs/scaladsl/MqttSourceSpec.scala mqttv5/src/test/scala/docs/scaladsl/MqttFlowSpec.scala mqttv5/src/test/scala/docs/scaladsl/MqttSpecBase.scala mqttv5/src/test/java/docs/javadsl/MqttSourceTest.java mqttv5/src/test/java/docs/javadsl/MqttFlowTest.java couchbase3/src/test/scala/docs/scaladsl/CouchbaseTestFlowSpec.scala couchbase3/src/test/scala/docs/scaladsl/CouchbaseTestSourceSpec.scala google-cloud-pub-sub/src/test/scala/docs/scaladsl/ExampleUsage.scala google-cloud-pub-sub/src/test/scala/docs/scaladsl/IntegrationSpec.scala google-cloud-pub-sub/src/test/java/docs/javadsl/ExampleUsageJava.java orientdb/src/test/scala/docs/scaladsl/OrientDbSpec.scala orientdb/src/test/java/docs/javadsl/OrientDbTest.java s3/src/test/scala/docs/scaladsl/S3SourceSpec.scala s3/src/test/scala/docs/scaladsl/S3SinkSpec.scala s3/src/test/java/docs/javadsl/S3Test.java - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Hidden files and folders path like ".*/[.][a-zA-Z0-9_]+.*" 5 files: .github/workflows/nightly-pekko-1.0-builds.yaml .github/workflows/nightly-builds.yaml .gitignore .asf.yaml .gitattributes - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Too long lines (1000+ characters) 2 files: google-cloud-bigquery/src/test/resources/BigQueryEndToEndSpec.json file/src/test/resources/akka_full_color.svg - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Too long file (1000000+ bytes) 1 files: git-history.txt - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -