Commit b87a139
authored
File tree
- .claude/commands
- .github
- scripts
- workflows
- buildSrc
- src
- main
- groovy
- java/org/opensearch/dataprepper/gradle
- compatibility
- end_to_end
- release
- test/java/org/opensearch/dataprepper/gradle
- compatibility
- release
- data-prepper-api
- src
- main/java/org/opensearch/dataprepper/model
- acknowledgements
- buffer
- configuration
- event
- host
- test
- java/org/opensearch/dataprepper/model
- buffer
- configuration
- event
- host
- resources
- org/opensearch/dataprepper/model/configuration
- sample_pipelines
- data-prepper-core
- src
- integrationTest/java/org/opensearch/dataprepper
- integration
- plugins
- plugin
- test/framework
- main
- java/org/opensearch/dataprepper
- core
- acknowledgements
- breaker
- meter
- parser
- config
- model
- peerforwarder
- certificate
- client
- codec
- discovery
- exception
- model
- server
- pipeline
- buffer
- common
- router
- server
- config
- sourcecoordination
- enhanced
- logging
- plugins
- resources
- META-INF/services
- test
- java/org/opensearch/dataprepper
- core
- acknowledgements
- breaker
- meter
- parser
- config
- model
- peerforwarder
- certificate
- client
- codec
- discovery
- exception
- server
- pipeline
- buffer
- common
- router
- server
- config
- sourcecoordination
- enhanced
- logging
- plugins
- resources
- data-prepper-expression/src
- main
- antlr
- java/org/opensearch/dataprepper/expression
- test/java/org/opensearch/dataprepper/expression
- util
- data-prepper-logstash-configuration/src/test/resources/org/opensearch/dataprepper/logstash
- data-prepper-pipeline-parser/src
- main/java/org/opensearch/dataprepper/pipeline/parser
- rule
- transformer
- test
- java/org/opensearch/dataprepper/pipeline/parser
- rule
- transformer
- resources/transformation
- rules
- templates/testSource
- data-prepper-plugins
- avro-codecs
- aws-plugin-api
- aws-plugin/src
- main/java/org/opensearch/dataprepper/plugins/aws
- test/java/org/opensearch/dataprepper/plugins/aws
- common
- src
- main/java/org/opensearch/dataprepper
- common/sink
- plugins/accumulator
- test/java/org/opensearch/dataprepper/common/sink
- drop-events-processor/src
- main/java/org/opensearch/dataprepper/plugins/processor/drop
- test/java/org/opensearch/dataprepper/plugins/processor/drop
- dynamodb-source-coordination-store
- dynamodb-source/src
- main/java/org/opensearch/dataprepper/plugins/source/dynamodb/export
- test/java/org/opensearch/dataprepper/plugins/source/dynamodb/export
- encryption-plugin/src
- main/java/org/opensearch/dataprepper/plugins/encryption
- test/java/org/opensearch/dataprepper/plugins/encryption
- geoip-processor
- grok-processor
- http-common/src/main/java/org/opensearch/dataprepper/plugins/server
- http-sink
- src
- integrationTest/java/org/opensearch/dataprepper/plugins/sink/http
- main/java/org/opensearch/dataprepper/plugins/sink/http
- certificate
- configuration
- dlq
- handler
- service
- util
- test/java/org/opensearch/dataprepper/plugins/sink/http
- certificate
- configuration
- dlq
- handler
- service
- util
- http-source
- src
- main/java/org/opensearch/dataprepper/plugins/source/loghttp
- test/java/org/opensearch/dataprepper/plugins/source/loghttp
- iceberg-source
- docker
- src
- integrationTest/java/org/opensearch/dataprepper/plugins/source/iceberg
- main/java/org/opensearch/dataprepper/plugins/source/iceberg
- coordination
- partition
- state
- leader
- worker
- test/java/org/opensearch/dataprepper/plugins/source/iceberg
- coordination
- partition
- leader
- worker
- kafka-plugins
- src
- integrationTest/java/org/opensearch/dataprepper/plugins/kafka
- sink
- source
- main/java/org/opensearch/dataprepper/plugins/kafka
- buffer
- configuration
- consumer
- producer
- source
- util
- test/java/org/opensearch/dataprepper/plugins/kafka
- buffer
- consumer
- producer
- source
- util
- kinesis-source/src
- main/java/org/opensearch/dataprepper/plugins/kinesis/source
- converter
- processor
- test/java/org/opensearch/dataprepper/plugins/kinesis/source
- converter
- mongodb/src
- main/java/org/opensearch/dataprepper/plugins/mongo
- documentdb
- leader
- stream
- test/java/org/opensearch/dataprepper/plugins/mongo
- documentdb
- leader
- stream
- mutate-event-processors
- src
- main/java/org/opensearch/dataprepper/plugins/processor/mutateevent
- test
- java/org/opensearch/dataprepper/plugins/processor/mutateevent
- resources/org/opensearch/dataprepper/plugins/processor/mutateevent
- newline-codecs/src
- main/java/org/opensearch/dataprepper/plugins/codec/newline
- test/java/org/opensearch/dataprepper/plugins/codec/newline
- opensearch
- src
- integrationTest/java/org/opensearch/dataprepper/plugins/sink/opensearch
- main
- java/org/opensearch/dataprepper/plugins
- sink/opensearch
- bulk
- configuration
- index
- source/opensearch
- configuration
- worker
- client
- model
- resources
- index-template
- test/java/org/opensearch/dataprepper/plugins
- sink/opensearch
- bulk
- configuration
- index
- source/opensearch
- configuration
- worker/client
- model
- otel-apm-service-map-processor
- src
- main/java/org/opensearch/dataprepper/plugins/processor/otel_apm_service_map
- model
- internal
- utils
- test/java/org/opensearch/dataprepper/plugins/processor/otel_apm_service_map
- model
- internal
- utils
- otel-logs-source
- src
- main/java/org/opensearch/dataprepper/plugins/source/otellogs
- certificate
- http
- test/java/org/opensearch/dataprepper/plugins/source/otellogs
- otel-metrics-raw-processor
- otel-metrics-source
- src/main/java/org/opensearch/dataprepper/plugins/source/otelmetrics
- otel-proto-common
- src
- main
- java/org/opensearch/dataprepper/plugins/otel/common
- resources
- test/java/org/opensearch/dataprepper/plugins/otel/common
- otel-trace-raw-processor
- src
- main
- java/org/opensearch/dataprepper/plugins/processor/oteltrace
- model
- resources
- test
- java/org/opensearch/dataprepper/plugins/processor/oteltrace
- model
- resources
- otel-trace-source
- src
- main/java/org/opensearch/dataprepper/plugins/source/oteltrace
- grpc
- http
- test/java/org/opensearch/dataprepper/plugins/source/oteltrace
- http
- otlp-source/src/main/java/org/opensearch/dataprepper/plugins/source/otlp/certificate
- parse-json-processor/src/main/java/org/opensearch/dataprepper/plugins/codec/json
- prometheus-sink
- src
- integrationTest/java/org/opensearch/dataprepper/plugins/sink/prometheus
- main/java/org/opensearch/dataprepper/plugins/sink/prometheus
- configuration
- service
- test/java/org/opensearch/dataprepper/plugins/sink/prometheus
- configuration
- service
- prometheus-source
- src
- integrationTest/java/org/opensearch/dataprepper/plugins/source/prometheus
- main/java/org/opensearch/dataprepper/plugins/source/prometheus
- test
- java/org/opensearch/dataprepper/plugins/source/prometheus
- resources
- rds-source
- src
- main
- java/org/opensearch/dataprepper/plugins/source/rds
- configuration
- converter
- datatype/mysql/handler
- export
- stream
- resources/org/opensearch/dataprepper/transforms
- rules
- templates
- test/java/org/opensearch/dataprepper/plugins/source/rds
- converter
- datatype/mysql/handler
- export
- rss-source
- s3-enrich-processor
- src
- main/java/org/opensearch/dataprepper/plugins/s3_enrich/processor
- cache
- client
- configuration
- s3source
- ownership
- test/java/org/opensearch/dataprepper/plugins/s3_enrich/processor
- cache
- s3source
- ownership
- s3-sink
- src
- integrationTest/java/org/opensearch/dataprepper/plugins/sink/s3
- main/java/org/opensearch/dataprepper/plugins
- codec/parquet
- sink/s3
- accumulator
- configuration
- grouping
- test/java/org/opensearch/dataprepper/plugins
- codec/parquet
- sink/s3
- accumulator
- configuration
- grouping
- s3-source
- src
- integrationTest/java/org/opensearch/dataprepper/plugins/source/s3
- main/java/org/opensearch/dataprepper/plugins/source/s3
- configuration
- test/java/org/opensearch/dataprepper/plugins/source/s3
- parser
- saas-source-plugins
- atlassian-commons
- confluence-source
- crowdstrike-source
- jira-source
- microsoft-office365-source/src
- main/java/org/opensearch/dataprepper/plugins/source/microsoft_office365
- auth
- configuration
- service
- test/java/org/opensearch/dataprepper/plugins/source/microsoft_office365
- service
- source-crawler/src
- main/java/org/opensearch/dataprepper/plugins/source/source_crawler
- base
- coordination/state
- metrics
- test/java/org/opensearch/dataprepper/plugins/source/source_crawler
- base
- coordination/state
- metrics
- sqs-sink/src
- integrationTest/java/org/opensearch/dataprepper/plugins/sink/sqs
- main/java/org/opensearch/dataprepper/plugins/sink/sqs
- test/java/org/opensearch/dataprepper/plugins/sink/sqs
- docs
- e2e-test/log
- src/integrationTest
- java/org/opensearch/dataprepper/integration/log
- resources
- examples/trace-analytics-sample-app/sample-app
- jenkins
- performance-test
- src
- gatling/java/org/opensearch/dataprepper/test/performance
- tools
- main/java/org/opensearch/dataprepper/test/data/generation
- test/java/org/opensearch/dataprepper/test/data/generation
- release
- docker
- maven
- release-notes
- script
- changelog
- release-notes
- smoke-tests
- staging-resources-cdk
- testing/aws-testing-cdk
- lib
- common
- s3
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
| 86 | + | |
| 87 | + | |
| 88 | + | |
| 89 | + | |
| 90 | + | |
| 91 | + | |
| 92 | + | |
| 93 | + | |
| 94 | + | |
| 95 | + | |
| 96 | + | |
| 97 | + | |
| 98 | + | |
| 99 | + | |
| 100 | + | |
| 101 | + | |
| 102 | + | |
| 103 | + | |
| 104 | + | |
| 105 | + | |
| 106 | + | |
| 107 | + | |
| 108 | + | |
| 109 | + | |
| 110 | + | |
| 111 | + | |
| 112 | + | |
| 113 | + | |
| 114 | + | |
| 115 | + | |
| 116 | + | |
| 117 | + | |
| 118 | + | |
| 119 | + | |
| 120 | + | |
| 121 | + | |
| 122 | + | |
| 123 | + | |
| 124 | + | |
| 125 | + | |
| 126 | + | |
| 127 | + | |
| 128 | + | |
| 129 | + | |
| 130 | + | |
| 131 | + | |
| 132 | + | |
| 133 | + | |
| 134 | + | |
| 135 | + | |
| 136 | + | |
| 137 | + | |
| 138 | + | |
| 139 | + | |
| 140 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
126 | 126 | | |
127 | 127 | | |
128 | 128 | | |
129 | | - | |
130 | | - | |
131 | | - | |
132 | | - | |
133 | | - | |
| 129 | + | |
| 130 | + | |
| 131 | + | |
134 | 132 | | |
135 | 133 | | |
136 | 134 | | |
| |||
139 | 137 | | |
140 | 138 | | |
141 | 139 | | |
142 | | - | |
143 | | - | |
144 | | - | |
145 | | - | |
146 | | - | |
147 | 140 | | |
148 | 141 | | |
149 | 142 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
66 | 66 | | |
67 | 67 | | |
68 | 68 | | |
69 | | - | |
| 69 | + | |
| 70 | + | |
70 | 71 | | |
71 | 72 | | |
72 | 73 | | |
| |||
0 commit comments