path # lines of code number of updates days since first update days since last update first updated last updated e2e-test/log/src/integrationTest/java/com/amazon/dataprepper/integration/log/EndToEndBasicLogTest.java 120 4 84 13 2021-11-10 2022-01-20 e2e-test/log/src/integrationTest/resources/basic-grok-e2e-pipeline.yml 13 2 84 72 2021-11-10 2021-11-22 e2e-test/log/src/integrationTest/resources/data_prepper.yml 1 1 84 84 2021-11-10 2021-11-10 e2e-test/log/src/main/java/com/amazon/dataprepper/integration/log/ApacheLogFaker.java 38 2 84 13 2021-11-10 2022-01-20 e2e-test/trace/src/integrationTest/java/com/amazon/dataprepper/integration/trace/EndToEndServiceMapTest.java 224 2 91 13 2021-11-03 2022-01-20 e2e-test/trace/src/integrationTest/java/com/amazon/dataprepper/integration/trace/EndToEndRawSpanTest.java 242 2 91 13 2021-11-03 2022-01-20 e2e-test/trace/src/integrationTest/java/com/amazon/dataprepper/integration/trace/EndToEndTestSpan.java 57 2 91 41 2021-11-03 2021-12-23 e2e-test/trace/src/integrationTest/resources/service-map-e2e-pipeline.yml 25 1 91 91 2021-11-03 2021-11-03 e2e-test/trace/src/integrationTest/resources/raw-span-e2e-pipeline.yml 25 1 91 91 2021-11-03 2021-11-03 e2e-test/trace/src/integrationTest/resources/data_prepper.yml 1 1 91 91 2021-11-03 2021-11-03 e2e-test/trace/src/integrationTest/resources/raw-span-e2e-pipeline-latest-release.yml 26 1 91 91 2021-11-03 2021-11-03 data-prepper-plugins/key-value-processor/src/main/java/com/amazon/dataprepper/plugins/processor/keyvalue/KeyValueProcessor.java 153 2 15 9 2022-01-18 2022-01-24 data-prepper-plugins/key-value-processor/src/main/java/com/amazon/dataprepper/plugins/processor/keyvalue/KeyValueProcessorConfig.java 67 2 15 9 2022-01-18 2022-01-24 data-prepper-plugins/otel-trace-source/src/main/java/com/amazon/dataprepper/plugins/health/HealthGrpcService.java 13 5 427 14 2020-12-02 2022-01-19 data-prepper-plugins/otel-trace-source/src/main/java/com/amazon/dataprepper/plugins/source/oteltrace/OTelTraceGrpcService.java 51 13 427 14 2020-12-02 2022-01-19 data-prepper-plugins/otel-trace-source/src/main/java/com/amazon/dataprepper/plugins/source/oteltrace/OTelTraceSource.java 158 26 427 14 2020-12-02 2022-01-19 data-prepper-plugins/otel-trace-source/src/main/java/com/amazon/dataprepper/plugins/source/oteltrace/certificate/CertificateProviderFactory.java 48 2 119 14 2021-10-06 2022-01-19 data-prepper-plugins/otel-trace-source/src/main/java/com/amazon/dataprepper/plugins/source/oteltrace/OTelTraceSourceConfig.java 141 19 427 14 2020-12-02 2022-01-19 data-prepper-plugins/drop-events-processor/src/main/java/com/amazon/dataprepper/plugins/processor/drop/DropEventsProcessor.java 34 1 29 29 2022-01-04 2022-01-04 data-prepper-plugins/armeria-common/src/main/java/com/amazon/dataprepper/armeria/authentication/ArmeriaHttpAuthenticationProvider.java 6 1 82 82 2021-11-12 2021-11-12 data-prepper-plugins/armeria-common/src/main/java/com/amazon/dataprepper/armeria/authentication/GrpcAuthenticationProvider.java 6 1 82 82 2021-11-12 2021-11-12 data-prepper-plugins/armeria-common/src/main/java/com/amazon/dataprepper/armeria/authentication/HttpBasicAuthenticationConfig.java 20 2 89 82 2021-11-05 2021-11-12 data-prepper-plugins/armeria-common/src/main/java/com/amazon/dataprepper/plugins/HttpBasicArmeriaHttpAuthenticationProvider.java 36 1 82 82 2021-11-12 2021-11-12 data-prepper-plugins/armeria-common/src/main/java/com/amazon/dataprepper/plugins/UnauthenticatedArmeriaHttpAuthenticationProvider.java 10 1 82 82 2021-11-12 2021-11-12 data-prepper-plugins/armeria-common/src/main/java/com/amazon/dataprepper/plugins/UnauthenticatedGrpcAuthenticationProvider.java 19 1 82 82 2021-11-12 2021-11-12 data-prepper-plugins/armeria-common/src/main/java/com/amazon/dataprepper/plugins/GrpcBasicAuthenticationProvider.java 54 1 82 82 2021-11-12 2021-11-12 data-prepper-plugins/otel-trace-group-prepper/src/main/java/com/amazon/dataprepper/plugins/prepper/oteltracegroup/model/TraceGroup.java 49 8 299 41 2021-04-09 2021-12-23 data-prepper-plugins/otel-trace-group-prepper/src/main/java/com/amazon/dataprepper/plugins/prepper/oteltracegroup/OTelTraceGroupPrepper.java 171 16 308 14 2021-03-31 2022-01-19 data-prepper-plugins/otel-trace-group-prepper/src/main/java/com/amazon/dataprepper/plugins/prepper/oteltracegroup/OTelTraceGroupPrepperConfig.java 23 11 308 14 2021-03-31 2022-01-19 data-prepper-plugins/aggregate-processor/src/main/java/com/amazon/dataprepper/plugins/processor/aggregate/DefaultGroupState.java 4 1 6 6 2022-01-27 2022-01-27 data-prepper-plugins/aggregate-processor/src/main/java/com/amazon/dataprepper/plugins/processor/aggregate/GroupState.java 4 1 6 6 2022-01-27 2022-01-27 data-prepper-plugins/aggregate-processor/src/main/java/com/amazon/dataprepper/plugins/processor/aggregate/AggregateIdentificationKeysHasher.java 32 1 8 8 2022-01-25 2022-01-25 data-prepper-plugins/aggregate-processor/src/main/java/com/amazon/dataprepper/plugins/processor/aggregate/AggregateGroup.java 10 2 8 6 2022-01-25 2022-01-27 data-prepper-plugins/aggregate-processor/src/main/java/com/amazon/dataprepper/plugins/processor/aggregate/AggregateProcessor.java 65 3 26 6 2022-01-07 2022-01-27 data-prepper-plugins/aggregate-processor/src/main/java/com/amazon/dataprepper/plugins/processor/aggregate/AggregateAction.java 11 2 20 6 2022-01-13 2022-01-27 data-prepper-plugins/aggregate-processor/src/main/java/com/amazon/dataprepper/plugins/processor/aggregate/AggregateActionInput.java 4 1 6 6 2022-01-27 2022-01-27 data-prepper-plugins/aggregate-processor/src/main/java/com/amazon/dataprepper/plugins/processor/aggregate/actions/CombineAggregateAction.java 25 2 20 6 2022-01-13 2022-01-27 data-prepper-plugins/aggregate-processor/src/main/java/com/amazon/dataprepper/plugins/processor/aggregate/actions/RemoveDuplicatesAggregateAction.java 20 2 20 6 2022-01-13 2022-01-27 data-prepper-plugins/aggregate-processor/src/main/java/com/amazon/dataprepper/plugins/processor/aggregate/AggregateGroupManager.java 17 1 8 8 2022-01-25 2022-01-25 data-prepper-plugins/aggregate-processor/src/main/java/com/amazon/dataprepper/plugins/processor/aggregate/AggregateActionResponse.java 17 2 20 8 2022-01-13 2022-01-25 data-prepper-plugins/aggregate-processor/src/main/java/com/amazon/dataprepper/plugins/processor/aggregate/AggregateProcessorConfig.java 43 2 26 8 2022-01-07 2022-01-25 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/HashRing.java 83 5 393 14 2021-01-05 2022-01-19 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/discovery/AwsCloudMapPeerListProvider.java 161 4 194 41 2021-07-23 2021-12-23 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/discovery/DnsPeerListProvider.java 56 8 393 14 2021-01-05 2022-01-19 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/discovery/PeerListProvider.java 8 5 393 14 2021-01-05 2022-01-19 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/discovery/StaticPeerListProvider.java 44 8 393 14 2021-01-05 2022-01-19 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/discovery/DiscoveryMode.java 18 8 393 14 2021-01-05 2022-01-19 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/discovery/PeerListProviderFactory.java 15 10 393 14 2021-01-05 2022-01-19 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/discovery/DiscoveryUtils.java 8 5 194 41 2021-07-23 2021-12-23 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/PeerForwarderConfig.java 91 15 393 14 2021-01-05 2022-01-19 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/PeerForwarderUtils.java 33 8 393 14 2021-01-05 2022-01-19 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/PeerClientPool.java 60 11 393 14 2021-01-05 2022-01-19 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/certificate/CertificateProviderFactory.java 46 4 202 41 2021-07-15 2021-12-23 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/certificate/acm/ACMCertificateProvider.java 52 4 202 41 2021-07-15 2021-12-23 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/certificate/CertificateProviderConfig.java 43 5 202 41 2021-07-15 2021-12-23 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/certificate/s3/S3CertificateProvider.java 35 4 202 41 2021-07-15 2021-12-23 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/certificate/model/Certificate.java 11 4 202 41 2021-07-15 2021-12-23 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/certificate/CertificateProvider.java 5 4 202 41 2021-07-15 2021-12-23 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/certificate/file/FileCertificateProvider.java 27 5 202 41 2021-07-15 2021-12-23 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/PeerForwarder.java 181 15 393 14 2021-01-05 2022-01-19 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/PluginFactory.java 51 7 427 14 2020-12-02 2022-01-19 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/PluginException.java 13 6 427 14 2020-12-02 2022-01-19 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/buffer/BufferFactory.java 12 6 427 14 2020-12-02 2022-01-19 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/prepper/PrepperFactory.java 25 9 393 14 2021-01-05 2022-01-19 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/prepper/NoOpPrepper.java 25 11 393 14 2021-01-05 2022-01-19 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/prepper/StringPrepper.java 79 14 393 14 2021-01-05 2022-01-19 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/sink/SinkFactory.java 12 6 427 14 2020-12-02 2022-01-19 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/sink/StdOutSink.java 33 10 427 14 2020-12-02 2022-01-19 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/sink/FileSink.java 58 13 427 14 2020-12-02 2022-01-19 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/source/RandomStringSource.java 69 9 412 14 2020-12-17 2022-01-19 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/source/SourceFactory.java 12 6 427 14 2020-12-02 2022-01-19 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/source/file/FileSourceConfig.java 35 2 76 41 2021-11-18 2021-12-23 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/source/file/FileSource.java 92 2 76 14 2021-11-18 2022-01-19 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/source/file/FileFormat.java 21 2 76 41 2021-11-18 2021-12-23 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/source/StdInSource.java 66 7 427 14 2020-12-02 2022-01-19 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/certificate/acm/ACMCertificateProvider.java 145 3 119 41 2021-10-06 2021-12-23 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/certificate/s3/S3CertificateProvider.java 40 2 119 41 2021-10-06 2021-12-23 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/certificate/model/Certificate.java 16 2 119 41 2021-10-06 2021-12-23 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/certificate/CertificateProvider.java 5 2 119 41 2021-10-06 2021-12-23 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/certificate/file/FileCertificateProvider.java 33 3 119 41 2021-10-06 2021-12-23 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/PluginRepository.java 79 14 427 14 2020-12-02 2022-01-19 data-prepper-plugins/http-source/src/main/java/com/amazon/dataprepper/plugins/source/loghttp/LogHTTPService.java 82 7 127 14 2021-09-28 2022-01-19 data-prepper-plugins/http-source/src/main/java/com/amazon/dataprepper/plugins/source/loghttp/codec/JsonCodec.java 24 3 127 14 2021-09-28 2022-01-19 data-prepper-plugins/http-source/src/main/java/com/amazon/dataprepper/plugins/source/loghttp/codec/Codec.java 6 2 127 14 2021-09-28 2022-01-19 data-prepper-plugins/http-source/src/main/java/com/amazon/dataprepper/plugins/source/loghttp/HTTPSourceConfig.java 85 7 127 14 2021-09-28 2022-01-19 data-prepper-plugins/http-source/src/main/java/com/amazon/dataprepper/plugins/source/loghttp/LogThrottlingRejectHandler.java 29 3 127 14 2021-09-28 2022-01-19 data-prepper-plugins/http-source/src/main/java/com/amazon/dataprepper/plugins/source/loghttp/RequestExceptionHandler.java 45 2 107 14 2021-10-18 2022-01-19 data-prepper-plugins/http-source/src/main/java/com/amazon/dataprepper/plugins/source/loghttp/LogThrottlingStrategy.java 24 2 127 14 2021-09-28 2022-01-19 data-prepper-plugins/http-source/src/main/java/com/amazon/dataprepper/plugins/source/loghttp/certificate/CertificateProviderFactory.java 17 2 119 14 2021-10-06 2022-01-19 data-prepper-plugins/http-source/src/main/java/com/amazon/dataprepper/plugins/source/loghttp/HTTPSource.java 125 14 127 14 2021-09-28 2022-01-19 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/RetryConfiguration.java 32 3 287 14 2021-04-21 2022-01-19 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/BackOffUtils.java 28 3 287 14 2021-04-21 2022-01-19 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/ConnectionConfiguration.java 347 8 287 14 2021-04-21 2022-01-19 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/index/IndexConfiguration.java 216 7 120 14 2021-10-05 2022-01-19 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/index/IndexType.java 32 4 120 41 2021-10-05 2021-12-23 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/index/NoIsmPolicyManagement.java 39 2 113 41 2021-10-12 2021-12-23 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/index/IsmPolicyManagementStrategy.java 11 2 113 41 2021-10-12 2021-12-23 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/index/IsmPolicyManagement.java 138 3 113 41 2021-10-12 2021-12-23 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/index/IndexManagerFactory.java 53 6 120 28 2021-10-05 2022-01-05 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/index/IndexConstants.java 21 3 120 14 2021-10-05 2022-01-19 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/index/IndexManager.java 201 6 120 28 2021-10-05 2022-01-05 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/BulkRetryStrategy.java 147 3 287 14 2021-04-21 2022-01-19 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/RequestFunction.java 5 3 287 14 2021-04-21 2022-01-19 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/OpenSearchSink.java 183 14 287 14 2021-04-21 2022-01-19 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/AwsRequestSigningApacheInterceptor.java 143 3 175 161 2021-08-11 2021-08-25 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/OpenSearchSinkConfiguration.java 35 5 287 14 2021-04-21 2022-01-19 data-prepper-plugins/grok-prepper/src/main/java/com/amazon/dataprepper/plugins/prepper/grok/GrokPrepper.java 249 19 134 14 2021-09-21 2022-01-19 data-prepper-plugins/grok-prepper/src/main/java/com/amazon/dataprepper/plugins/prepper/grok/GrokPrepperConfig.java 95 6 134 14 2021-09-21 2022-01-19 data-prepper-plugins/service-map-stateful/src/main/java/com/amazon/dataprepper/plugins/prepper/ServiceMapStatefulPrepper.java 266 25 393 14 2021-01-05 2022-01-19 data-prepper-plugins/service-map-stateful/src/main/java/com/amazon/dataprepper/plugins/prepper/ServiceMapRelationship.java 154 6 393 14 2021-01-05 2022-01-19 data-prepper-plugins/service-map-stateful/src/main/java/com/amazon/dataprepper/plugins/prepper/OTelHelper.java 16 5 393 14 2021-01-05 2022-01-19 data-prepper-plugins/service-map-stateful/src/main/java/com/amazon/dataprepper/plugins/prepper/ServiceMapPrepperConfig.java 6 8 393 14 2021-01-05 2022-01-19 data-prepper-plugins/mapdb-prepper-state/src/main/java/com/amazon/dataprepper/plugins/prepper/state/MapDbPrepperState.java 112 15 393 14 2021-01-05 2022-01-19 data-prepper-plugins/otel-trace-raw-prepper/src/main/java/com/amazon/dataprepper/plugins/prepper/oteltrace/OtelTraceRawPrepperConfig.java 7 13 330 14 2021-03-09 2022-01-19 data-prepper-plugins/otel-trace-raw-prepper/src/main/java/com/amazon/dataprepper/plugins/prepper/oteltrace/OTelTraceRawPrepper.java 213 27 393 14 2021-01-05 2022-01-19 data-prepper-plugins/otel-trace-raw-prepper/src/main/java/com/amazon/dataprepper/plugins/prepper/oteltrace/model/RawSpan.java 105 21 393 14 2021-01-05 2022-01-19 data-prepper-plugins/otel-trace-raw-prepper/src/main/java/com/amazon/dataprepper/plugins/prepper/oteltrace/model/RawSpanSet.java 20 6 373 14 2021-01-25 2022-01-19 data-prepper-plugins/otel-trace-raw-prepper/src/main/java/com/amazon/dataprepper/plugins/prepper/oteltrace/model/OTelProtoHelper.java 114 18 393 14 2021-01-05 2022-01-19 data-prepper-plugins/otel-trace-raw-prepper/src/main/java/com/amazon/dataprepper/plugins/prepper/oteltrace/model/RawLink.java 40 6 393 14 2021-01-05 2022-01-19 data-prepper-plugins/otel-trace-raw-prepper/src/main/java/com/amazon/dataprepper/plugins/prepper/oteltrace/model/TraceGroup.java 78 10 315 41 2021-03-24 2021-12-23 data-prepper-plugins/otel-trace-raw-prepper/src/main/java/com/amazon/dataprepper/plugins/prepper/oteltrace/model/RawSpanBuilder.java 131 9 393 14 2021-01-05 2022-01-19 data-prepper-plugins/otel-trace-raw-prepper/src/main/java/com/amazon/dataprepper/plugins/prepper/oteltrace/model/RawEvent.java 30 6 393 14 2021-01-05 2022-01-19 data-prepper-plugins/blocking-buffer/src/main/java/com/amazon/dataprepper/plugins/buffer/blockingbuffer/BlockingBuffer.java 130 11 359 14 2021-02-08 2022-01-19 data-prepper-benchmarks/service-map-stateful-benchmarks/src/jmh/java/com/amazon/dataprepper/benchmarks/prepper/ServiceMapStatefulPrepperBenchmarks.java 160 6 393 13 2021-01-05 2022-01-20 data-prepper-benchmarks/mapdb-benchmarks/src/jmh/java/com/amazon/dataprepper/benchmarks/prepper/state/MapDbPrepperStateBenchmarks.java 66 6 393 13 2021-01-05 2022-01-20 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/PipelineConnector.java 64 12 427 79 2020-12-02 2021-11-15 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/common/FutureHelperResult.java 43 5 427 79 2020-12-02 2021-11-15 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/common/FutureHelper.java 29 7 427 79 2020-12-02 2021-11-15 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/common/PipelineThreadFactory.java 27 5 427 79 2020-12-02 2021-11-15 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/common/PipelineThreadPoolExecutor.java 55 11 427 64 2020-12-02 2021-11-30 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/Pipeline.java 144 28 427 64 2020-12-02 2021-11-30 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/ProcessWorker.java 74 20 427 64 2020-12-02 2021-11-30 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/server/DataPrepperServer.java 25 26 419 12 2020-12-10 2022-01-21 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/server/ShutdownHandler.java 28 8 414 79 2020-12-15 2021-11-15 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/server/config/DataPrepperServerConfiguration.java 99 1 12 12 2022-01-21 2022-01-21 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/server/CloudWatchMeterRegistryProvider.java 42 5 271 12 2021-05-07 2022-01-21 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/server/DataPrepperCoreAuthenticationProvider.java 6 2 84 79 2021-11-10 2021-11-15 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/server/PrometheusMetricsHandler.java 30 16 419 12 2020-12-10 2022-01-21 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/server/SslUtil.java 27 6 342 79 2021-02-25 2021-11-15 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/server/HttpServerProvider.java 54 1 12 12 2022-01-21 2022-01-21 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/server/HttpBasicAuthenticationConfig.java 20 2 84 79 2021-11-10 2021-11-15 data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/server/ListPipelinesHandler.java 45 7 414 12 2020-12-15 2022-01-21 data-prepper-core/src/main/java/com/amazon/dataprepper/DataPrepper.java 65 34 427 27 2020-12-02 2022-01-06 data-prepper-core/src/main/java/com/amazon/dataprepper/plugin/PluginApplicationContext.java 14 1 9 9 2022-01-24 2022-01-24 data-prepper-core/src/main/java/com/amazon/dataprepper/plugin/PluginCreator.java 77 6 119 9 2021-10-06 2022-01-24 data-prepper-core/src/main/java/com/amazon/dataprepper/plugin/PluginArgumentsContext.java 66 4 92 27 2021-11-02 2022-01-06 data-prepper-core/src/main/java/com/amazon/dataprepper/plugin/PluginProvider.java 5 3 119 79 2021-10-06 2021-11-15 data-prepper-core/src/main/java/com/amazon/dataprepper/plugin/PluginProviderLoader.java 23 3 119 9 2021-10-06 2022-01-24 data-prepper-core/src/main/java/com/amazon/dataprepper/plugin/ClasspathPluginProvider.java 47 3 119 79 2021-10-06 2021-11-15 data-prepper-core/src/main/java/com/amazon/dataprepper/plugin/PluginConfigurationConverter.java 38 4 100 9 2021-10-25 2022-01-24 data-prepper-core/src/main/java/com/amazon/dataprepper/plugin/DefaultPluginFactory.java 78 9 119 9 2021-10-06 2022-01-24 data-prepper-core/src/main/java/com/amazon/dataprepper/plugins/HttpBasicDataPrepperCoreAuthenticationProvider.java 37 2 84 79 2021-11-10 2021-11-15 data-prepper-core/src/main/java/com/amazon/dataprepper/plugins/UnauthenticatedDataPrepperCoreAuthenticationProvider.java 12 2 84 79 2021-11-10 2021-11-15 data-prepper-core/src/main/java/com/amazon/dataprepper/parser/ParseException.java 12 5 427 79 2020-12-02 2021-11-15 data-prepper-core/src/main/java/com/amazon/dataprepper/parser/config/PipelineParserConfiguration.java 12 1 27 27 2022-01-06 2022-01-06 data-prepper-core/src/main/java/com/amazon/dataprepper/parser/config/DataPrepperArgs.java 61 2 27 12 2022-01-06 2022-01-21 data-prepper-core/src/main/java/com/amazon/dataprepper/parser/config/MetricsConfig.java 128 2 27 12 2022-01-06 2022-01-21 data-prepper-core/src/main/java/com/amazon/dataprepper/parser/config/DataPrepperAppConfiguration.java 51 2 27 12 2022-01-06 2022-01-21 data-prepper-core/src/main/java/com/amazon/dataprepper/parser/model/DataPrepperConfiguration.java 78 21 411 27 2020-12-18 2022-01-06 data-prepper-core/src/main/java/com/amazon/dataprepper/parser/model/PipelineConfiguration.java 151 15 427 64 2020-12-02 2021-11-30 data-prepper-core/src/main/java/com/amazon/dataprepper/parser/model/MetricRegistryType.java 5 6 265 12 2021-05-13 2022-01-21 data-prepper-core/src/main/java/com/amazon/dataprepper/parser/PipelineParser.java 186 25 427 27 2020-12-02 2022-01-06 data-prepper-core/src/main/java/com/amazon/dataprepper/parser/PipelineConfigurationValidator.java 107 7 427 79 2020-12-02 2021-11-15 data-prepper-core/src/main/java/com/amazon/dataprepper/DataPrepperExecute.java 23 16 427 27 2020-12-02 2022-01-06 data-prepper-api/src/main/java/com/amazon/dataprepper/prepper/state/PrepperState.java 15 12 393 79 2021-01-05 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/PluginType.java 30 11 427 79 2020-12-02 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/buffer/SizeOverflowException.java 6 3 121 78 2021-10-04 2021-11-16 data-prepper-api/src/main/java/com/amazon/dataprepper/model/buffer/Buffer.java 13 18 427 72 2020-12-02 2021-11-22 data-prepper-api/src/main/java/com/amazon/dataprepper/model/buffer/AbstractBuffer.java 97 23 427 78 2020-12-02 2021-11-16 data-prepper-api/src/main/java/com/amazon/dataprepper/model/prepper/AbstractPrepper.java 11 6 407 72 2020-12-22 2021-11-22 data-prepper-api/src/main/java/com/amazon/dataprepper/model/prepper/Prepper.java 6 9 407 72 2020-12-22 2021-11-22 data-prepper-api/src/main/java/com/amazon/dataprepper/model/sink/Sink.java 7 9 427 79 2020-12-02 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/sink/AbstractSink.java 24 5 427 79 2020-12-02 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/configuration/PipelineModel.java 83 6 90 64 2021-11-04 2021-11-30 data-prepper-api/src/main/java/com/amazon/dataprepper/model/configuration/PluginSetting.java 124 17 427 27 2020-12-02 2022-01-06 data-prepper-api/src/main/java/com/amazon/dataprepper/model/configuration/PipelineDescription.java 5 1 27 27 2022-01-06 2022-01-06 data-prepper-api/src/main/java/com/amazon/dataprepper/model/configuration/PluginModel.java 66 2 90 79 2021-11-04 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/configuration/PipelinesDataFlowModel.java 20 2 81 79 2021-11-13 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/plugin/PluginFactory.java 10 3 119 79 2021-10-06 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/plugin/InvalidPluginConfigurationException.java 6 1 28 28 2022-01-05 2022-01-05 data-prepper-api/src/main/java/com/amazon/dataprepper/model/plugin/PluginInvocationException.java 6 2 119 79 2021-10-06 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/plugin/InvalidPluginDefinitionException.java 9 3 119 79 2021-10-06 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/plugin/NoPluginFoundException.java 6 2 119 79 2021-10-06 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/log/JacksonLog.java 23 2 103 79 2021-10-22 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/log/Log.java 4 3 114 79 2021-10-11 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/annotations/DataPrepperPluginConstructor.java 11 2 92 79 2021-11-02 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/annotations/DataPrepperPlugin.java 18 12 427 72 2020-12-02 2021-11-22 data-prepper-api/src/main/java/com/amazon/dataprepper/model/annotations/SingleThread.java 11 6 342 72 2021-02-25 2021-11-22 data-prepper-api/src/main/java/com/amazon/dataprepper/model/source/Source.java 7 5 427 79 2020-12-02 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/record/Record.java 20 6 427 4 2020-12-02 2022-01-29 data-prepper-api/src/main/java/com/amazon/dataprepper/model/record/RecordMetadata.java 29 6 427 4 2020-12-02 2022-01-29 data-prepper-api/src/main/java/com/amazon/dataprepper/model/processor/AbstractProcessor.java 36 3 72 13 2021-11-22 2022-01-20 data-prepper-api/src/main/java/com/amazon/dataprepper/model/processor/Processor.java 9 8 427 13 2020-12-02 2022-01-20 data-prepper-api/src/main/java/com/amazon/dataprepper/model/event/EventType.java 21 2 103 79 2021-10-22 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/event/Event.java 14 8 114 23 2021-10-11 2022-01-10 data-prepper-api/src/main/java/com/amazon/dataprepper/model/event/JacksonEvent.java 258 12 107 23 2021-10-18 2022-01-10 data-prepper-api/src/main/java/com/amazon/dataprepper/model/event/EventMetadata.java 8 4 114 79 2021-10-11 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/event/DefaultEventMetadata.java 53 3 107 79 2021-10-18 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/trace/SpanEvent.java 8 2 113 79 2021-10-12 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/trace/DefaultLink.java 87 2 92 79 2021-11-02 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/trace/Span.java 24 4 113 43 2021-10-12 2021-12-21 data-prepper-api/src/main/java/com/amazon/dataprepper/model/trace/TraceGroupFields.java 6 2 113 79 2021-10-12 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/trace/JacksonSpan.java 254 3 92 43 2021-11-02 2021-12-21 data-prepper-api/src/main/java/com/amazon/dataprepper/model/trace/Link.java 9 2 113 79 2021-10-12 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/trace/DefaultTraceGroupFields.java 61 3 92 43 2021-11-02 2021-12-21 data-prepper-api/src/main/java/com/amazon/dataprepper/model/trace/DefaultSpanEvent.java 74 2 92 79 2021-11-02 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/model/CheckpointState.java 10 8 373 79 2021-01-25 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/metrics/MetricNames.java 18 19 427 79 2020-12-02 2021-11-15 data-prepper-api/src/main/java/com/amazon/dataprepper/metrics/PluginMetrics.java 52 17 427 79 2020-12-02 2021-11-15 release/docker/config/default-data-prepper-config.yaml 10 2 96 84 2021-10-29 2021-11-10 deployment-template/k8s/data-prepper-k8s.yaml 119 6 323 72 2021-03-16 2021-11-22 deployment-template/eks/ingress.yaml 25 5 324 303 2021-03-15 2021-04-05 deployment-template/ec2/data-prepper-ec2-deployment-cfn.yaml 216 27 365 48 2021-02-02 2021-12-16 research/zipkin-opensearch-to-otel/src/main/java/com/amazon/dataprepper/research/zipkin/ZipkinOpenSearchToOtelPrepper.java 149 2 110 13 2021-10-15 2022-01-20 research/zipkin-opensearch-to-otel/src/main/java/com/amazon/dataprepper/research/zipkin/OpenSearchReader.java 65 2 110 13 2021-10-15 2022-01-20 research/zipkin-opensearch-to-otel/src/main/java/com/amazon/dataprepper/research/zipkin/ZipkinOpenSearchToOtel.java 85 3 110 13 2021-10-15 2022-01-20 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/exception/LogstashParsingException.java 6 2 89 41 2021-11-05 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/exception/LogstashGrammarException.java 6 2 89 41 2021-11-05 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/exception/LogstashMappingException.java 9 2 83 41 2021-11-11 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/exception/LogstashConfigurationException.java 9 3 89 41 2021-11-05 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/model/LogstashAttribute.java 36 2 100 41 2021-10-25 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/model/LogstashValueType.java 9 2 100 41 2021-10-25 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/model/LogstashConfiguration.java 27 2 100 41 2021-10-25 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/model/LogstashPlugin.java 37 2 100 41 2021-10-25 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/model/LogstashAttributeValue.java 36 2 100 41 2021-10-25 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/model/LogstashPluginType.java 23 3 100 41 2021-10-25 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/LogstashConfigConverter.java 46 4 81 41 2021-11-13 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/parser/ModelConvertingLogstashVisitor.java 139 3 79 41 2021-11-15 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/mapping/GrokLogstashPluginAttributesMapper.java 92 4 82 77 2021-11-12 2021-11-17 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/mapping/LogstashAttributesMappings.java 6 1 82 82 2021-11-12 2021-11-12 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/mapping/DefaultLogstashPluginAttributesMapper.java 14 2 82 77 2021-11-12 2021-11-17 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/mapping/LogstashPluginMapper.java 39 3 85 41 2021-11-09 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/mapping/GrokNamedCapturesUtil.java 45 2 81 41 2021-11-13 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/mapping/AbstractLogstashPluginAttributesMapper.java 49 3 77 41 2021-11-17 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/mapping/AttributesMapperProvider.java 19 1 82 82 2021-11-12 2021-11-12 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/mapping/LogstashMapper.java 30 3 82 41 2021-11-12 2021-12-23 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/mapping/LogstashMappingModel.java 30 3 85 82 2021-11-09 2021-11-12 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/mapping/AttributesMapperCreator.java 23 2 82 78 2021-11-12 2021-11-16 data-prepper-logstash-configuration/src/main/java/org/opensearch/dataprepper/logstash/mapping/LogstashPluginAttributesMapper.java 7 1 82 82 2021-11-12 2021-11-12 data-prepper-logstash-configuration/src/main/antlr/Logstash.g4 95 1 89 89 2021-11-05 2021-11-05 data-prepper-logstash-configuration/src/main/resources/org/opensearch/dataprepper/logstash/mapping/elasticsearch.mapping.yaml 8 1 83 83 2021-11-11 2021-11-11 data-prepper-logstash-configuration/src/main/resources/org/opensearch/dataprepper/logstash/mapping/drop.mapping.yaml 1 1 23 23 2022-01-10 2022-01-10 data-prepper-logstash-configuration/src/main/resources/org/opensearch/dataprepper/logstash/mapping/kv.mapping.yaml 9 1 9 9 2022-01-24 2022-01-24 data-prepper-logstash-configuration/src/main/resources/org/opensearch/dataprepper/logstash/mapping/grok.mapping.yaml 12 2 83 82 2021-11-11 2021-11-12 data-prepper-logstash-configuration/src/main/resources/org/opensearch/dataprepper/logstash/mapping/http.mapping.yaml 11 1 83 83 2021-11-11 2021-11-11 data-prepper-logstash-configuration/src/main/resources/org/opensearch/dataprepper/logstash/mapping/amazon_es.mapping.yaml 8 1 83 83 2021-11-11 2021-11-11 data-prepper-logstash-configuration/src/main/resources/org/opensearch/dataprepper/logstash/mapping/opensearch.mapping.yaml 7 1 42 42 2021-12-22 2021-12-22