dagger
Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.
File Explorer
Download Latest Version (.zip)- build.yml
- dependencies-publish.yml
- docs.yml
- integration.yml
- package.yml
- python_release.yml
- python_validation.yml
- checkstyle.xml
- suppressions.xml
- Configuration.java
- Constants.java
- DaggerContext.java
- FieldDescriptorCache.java
- StencilClientOrchestrator.java
- StreamInfo.java
- Transformer.java
- DaggerDeserializationException.java
- DaggerSerializationException.java
- DataTypeNotSupportedException.java
- EnumFieldNotFoundException.java
- InvalidColumnMappingException.java
- InvalidDataTypeException.java
- InvalidJSONSchemaException.java
- SimpleGroupParsingException.java
- DaggerContextException.java
- DescriptorNotFoundException.java
- Aspects.java
- AspectType.java
- CounterStatsManager.java
- GaugeStatsManager.java
- MeterStatsManager.java
- JsonDeserializer.java
- JsonType.java
- SimpleGroupDeserializer.java
- SimpleGroupValidation.java
- ProtoDeserializer.java
- ProtoType.java
- KafkaProtoSerializer.java
- ProtoSerializer.java
- EnumHandler.java
- MapHandler.java
- MessageHandler.java
- StructMessageHandler.java
- TimestampHandler.java
- BooleanHandler.java
- ByteStringHandler.java
- DoubleHandler.java
- FloatHandler.java
- IntegerHandler.java
- LongHandler.java
- PrimitiveHandler.java
- PrimitiveHandlerFactory.java
- StringHandler.java
- RepeatedEnumHandler.java
- RepeatedMessageHandler.java
- RepeatedPrimitiveHandler.java
- RepeatedStructMessageHandler.java
- PrimitiveTypeHandler.java
- RowFactory.java
- TypeHandler.java
- TypeHandlerFactory.java
- TypeInformationFactory.java
- DaggerDeserializer.java
- DaggerInternalTypeInformation.java
- DataTypes.java
- AggregateUdf.java
- ScalarUdf.java
- TableUdf.java
- UdfFactory.java
- LastColumnWatermark.java
- NoWatermark.java
- RowtimeFieldWatermark.java
- StreamWatermarkAssigner.java
- WatermarkStrategyDefinition.java
- ConfigurationTest.java
- DaggerContextTestBase.java
- FieldDescriptorCacheTest.java
- StencilClientOrchestratorTest.java
- TestAspects.java
- CounterStatsManagerTest.java
- GaugeStatsManagerTest.java
- MeterStatsManagerTest.java
- JsonDeserializerTest.java
- JsonTypeTest.java
- SimpleGroupDeserializerTest.java
- SimpleGroupValidationTest.java
- ProtoDeserializerTest.java
- ProtoTypeTest.java
- KafkaProtoSerializerTest.java
- ProtoSerializerTest.java
- EnumHandlerTest.java
- MapHandlerTest.java
- MessageHandlerTest.java
- StructMessageHandlerTest.java
- TimestampHandlerTest.java
- BooleanHandlerTest.java
- ByteStringHandlerTest.java
- DoubleHandlerTest.java
- FloatHandlerTest.java
- IntegerHandlerTest.java
- LongHandlerTest.java
- PrimitiveHandlerFactoryTest.java
- StringHandlerTest.java
- RepeatedEnumHandlerTest.java
- RepeatedMessageHandlerTest.java
- RepeatedPrimitiveHandlerTest.java
- RepeatedStructMessageHandlerTest.java
- PrimitiveTypeHandlerTest.java
- RowFactoryTest.java
- TypeHandlerFactoryTest.java
- TypeInformationFactoryTest.java
- StreamWatermarkAssignerTest.java
- sample_message.txt
- TestGrpc.proto
- TestLogMessage.proto
- TestMessage.proto
- build.gradle
- local.properties
- CommandlineConfigurationProvider.java
- ConfigurationProvider.java
- ConfigurationProviderFactory.java
- EnvironmentConfigurationProvider.java
- FileConfigurationProvider.java
- KafkaEnvironmentVariables.java
- DaggerDeserializerFactory.java
- DaggerDeserializerProvider.java
- JsonDeserializerProvider.java
- ProtoDeserializerProvider.java
- SimpleGroupDeserializerProvider.java
- BigQueryWriterException.java
- ChannelNotAvailableException.java
- ConsumerLagNotZeroException.java
- DaggerConfigurationException.java
- GrpcFailureException.java
- HttpFailureException.java
- InfluxWriteException.java
- InputOutputMappingException.java
- InvalidConfigurationException.java
- InvalidDaggerSourceException.java
- InvalidGrpcBodyException.java
- InvalidHttpVerbException.java
- InvalidLongbowDurationException.java
- InvalidTimeRangeException.java
- ParquetFileSourceReaderInitializationException.java
- PathParserNotProvidedException.java
- RecordsNotConsumedException.java
- ThorCommandFailedException.java
- TransformClassNotDefinedException.java
- UDFFactoryClassNotDefinedException.java
- ChronologyOrderedSplitAssignerAspects.java
- ExternalSourceAspects.java
- LongbowReaderAspects.java
- LongbowWriterAspects.java
- ParquetReaderAspects.java
- TelemetryAspects.java
- DaggerCounterManager.java
- DaggerGaugeManager.java
- DaggerHistogramManager.java
- MeasurementManager.java
- Counter.java
- Gauge.java
- Histogram.java
- ComponentTags.java
- GlobalTags.java
- StatsDTag.java
- DaggerMetricsConfig.java
- DaggerStatsDReporter.java
- SerializedStatsDReporterSupplier.java
- StatsDErrorReporter.java
- ErrorReporter.java
- ErrorReporterFactory.java
- ErrorStatsReporter.java
- NoOpErrorReporter.java
- TelemetryPublisher.java
- TelemetrySubscriber.java
- TelemetryTypes.java
- DescriptorManager.java
- EndpointHandler.java
- FetchOutputDecorator.java
- InitializationDecorator.java
- OutputMapping.java
- PostResponseTelemetry.java
- RowManager.java
- SchemaConfig.java
- ValidRecordsDecorator.java
- EsAsyncConnector.java
- EsResponseHandler.java
- EsSourceConfig.java
- EsSourceConfigBuilder.java
- EsStreamDecorator.java
- DynamicMessageMarshaller.java
- GrpcClient.java
- GrpcRequestHandler.java
- GrpcAsyncConnector.java
- GrpcResponseHandler.java
- GrpcSourceConfig.java
- GrpcSourceConfigBuilder.java
- GrpcStreamDecorator.java
- HttpGetRequestHandler.java
- HttpPostRequestHandler.java
- HttpPutRequestHandler.java
- HttpRequestFactory.java
- HttpRequestHandler.java
- HttpAsyncConnector.java
- HttpResponseHandler.java
- HttpSourceConfig.java
- HttpStreamDecorator.java
- PgAsyncConnector.java
- PgResponseHandler.java
- PgSourceConfig.java
- PgSourceConfigBuilder.java
- PgStreamDecorator.java
- AsyncConnector.java
- ExternalMetricConfig.java
- ExternalPostProcessor.java
- ExternalSourceConfig.java
- ConstantInternalConfigProcessor.java
- CurrentTimestampFunction.java
- InvalidFunction.java
- JsonPayloadFunction.java
- FunctionInternalConfigProcessor.java
- FunctionProcessor.java
- FunctionProcessorFactory.java
- InvalidInternalConfigProcessor.java
- SqlInternalAutoFieldImport.java
- SqlInternalConfigProcessor.java
- SqlInternalFieldFactory.java
- SqlInternalFieldImport.java
- SqlConfigTypePathParser.java
- SqlInternalFieldConfig.java
- InternalConfigHandlerFactory.java
- InternalConfigProcessor.java
- InternalDecorator.java
- InternalPostProcessor.java
- InternalSourceConfig.java
- ColumnModifier.java
- LongbowReadColumnModifier.java
- LongbowWriteColumnModifier.java
- NoOpColumnModifier.java
- LongbowData.java
- LongbowDataFactory.java
- LongbowProtoData.java
- LongbowTableData.java
- LongbowReaderException.java
- LongbowWriterException.java
- OutputIdentity.java
- OutputSynchronizer.java
- ReaderOutputLongbowData.java
- ReaderOutputProtoData.java
- ReaderOutputRow.java
- WriterOutputRow.java
- LongbowReader.java
- LongbowWriter.java
- LongbowAbsoluteRange.java
- LongbowDurationRange.java
- LongbowRange.java
- LongbowRangeFactory.java
- ProtoBytePutRequest.java
- ProtoByteScanRequest.java
- PutRequestFactory.java
- ScanRequestFactory.java
- TablePutRequest.java
- TableScanRequest.java
- LongbowStore.java
- PutRequest.java
- ScanRequest.java
- LongbowType.java
- LongbowValidator.java
- AsyncProcessor.java
- LongbowFactory.java
- LongbowProcessor.java
- LongbowSchema.java
- MetricsTelemetryExporter.java
- TelemetryProcessor.java
- TableTransformConfig.java
- TransformConfig.java
- TransformerUtils.java
- TransformProcessor.java
- FilterDecorator.java
- MapDecorator.java
- PostProcessor.java
- Preprocessor.java
- SourceConfig.java
- StreamDecorator.java
- Validator.java
- ColumnNameManager.java
- ParentPostProcessor.java
- PostProcessorConfig.java
- PostProcessorFactory.java
- PreProcessorConfig.java
- PreProcessorFactory.java
- PreProcessorOrchestrator.java
- BigQuerySink.java
- BigQuerySinkBuilder.java
- BigQuerySinkWriter.java
- InfluxError.java
- LateRecordDropError.java
- NoError.java
- ValidError.java
- ValidException.java
- ErrorHandler.java
- InfluxDBFactoryWrapper.java
- InfluxDBSink.java
- InfluxDBWriter.java
- KafkaJsonSerializerBuilder.java
- KafkaProtoSerializerBuilder.java
- KafkaSerializationSchemaFactory.java
- KafkaSerializerBuilder.java
- LogSink.java
- LogSinkWriter.java
- SinkOrchestrator.java
- DaggerSASLMechanismAdaptor.java
- DaggerSecurityProtocolAdaptor.java
- DaggerSSLKeyStoreFileTypeAdaptor.java
- DaggerSSLProtocolAdaptor.java
- DaggerSSLTrustStoreFileTypeAdaptor.java
- FileDateRangeAdaptor.java
- SourceParquetFilePathsAdapter.java
- SourceDetails.java
- SourceName.java
- SourceType.java
- TimeRange.java
- TimeRangePool.java
- StreamConfig.java
- StreamConfigValidator.java
- FlinkKafkaConsumerCustom.java
- FlinkKafkaConsumerDaggerSource.java
- KafkaDaggerSource.java
- HourDatePathParser.java
- PathParser.java
- ParquetReader.java
- ReaderProvider.java
- ChronologyOrderedSplitAssigner.java
- IndexOrderedSplitAssigner.java
- InstantEnrichedSplit.java
- ParquetDaggerSource.java
- ParquetFileRecordFormat.java
- ParquetFileSource.java
- SourceParquetReadOrderStrategy.java
- SourceParquetSchemaMatchStrategy.java
- DaggerSource.java
- DaggerSourceFactory.java
- Stream.java
- StreamsFactory.java
- Constants.java
- KafkaProtoSQLProcessor.java
- StreamManager.java
- core-site.xml
- log4j.properties
- logback.xml
- CommandlineConfigurationProviderTest.java
- EnvironmentConfigurationProviderTest.java
- FileConfigurationProvideTest.java
- ConfigurationProviderFactoryTest.java
- KafkaEnvironmentVariablesTest.java
- DaggerDeserializerFactoryTest.java
- JsonDeserializerProviderTest.java
- ProtoDeserializerProviderTest.java
- SimpleGroupDeserializerProviderTest.java
- DaggerCounterManagerTest.java
- DaggerGaugeManagerTest.java
- DaggerHistogramManagerTest.java
- StatsDTagTest.java
- DaggerMetricsConfigTest.java
- DaggerStatsDReporterTest.java
- StatsDErrorReporterTest.java
- ErrorReporterFactoryTest.java
- ErrorStatsReporterTest.java
- DescriptorManagerTest.java
- EndpointHandlerTest.java
- FetchOutputDecoratorTest.java
- InitializationDecoratorTest.java
- OutputMappingTest.java
- RowManagerTest.java
- SchemaConfigTest.java
- ValidRecordsDecoratorTest.java
- EsAsyncConnectorTest.java
- EsResponseHandlerTest.java
- EsSourceConfigTest.java
- EsStreamDecoratorTest.java
- DynamicMessageMarshallerTest.java
- GrpcClientTest.java
- GrpcRequestHandlerTest.java
- GrpcAsyncConnectorTest.java
- GrpcResponseHandlerTest.java
- GrpcSourceConfigTest.java
- GrpcStreamDecoratorTest.java
- HttpGetRequestHandlerTest.java
- HttpPostRequestHandlerTest.java
- HttpRequestFactoryTest.java
- HttpAsyncConnectorTest.java
- HttpResponseHandlerTest.java
- HttpSourceConfigTest.java
- HttpStreamDecoratorTest.java
- PgAsyncConnectorTest.java
- PgResponseHandlerTest.java
- PgSourceConfigTest.java
- PgStreamDecoratorTest.java
- ExternalPostProcessorTest.java
- ExternalSourceConfigTest.java
- ConstantInternalConfigProcessorTest.java
- CurrentTimestampFunctionTest.java
- InvalidFunctionTest.java
- JsonPayloadFunctionTest.java
- FunctionInternalConfigProcessorTest.java
- FunctionProcessorFactoryTest.java
- InvalidInternalConfigProcessorTest.java
- SqlInternalAutoFieldImportTest.java
- SqlInternalConfigProcessorTest.java
- SqlInternalFieldFactoryTest.java
- SqlInternalFieldImportTest.java
- SqlConfigTypePathParserTest.java
- InternalConfigHandlerFactoryTest.java
- InternalDecoratorTest.java
- InternalPostProcessorTest.java
- InternalSourceConfigTest.java
- LongbowDataFactoryTest.java
- LongbowProtoDataTest.java
- LongbowTableDataTest.java
- OutputLongbowDataTest.java
- OutputProtoDataTest.java
- OutputSynchronizerTest.java
- LongbowReaderTest.java
- LongbowWriterTest.java
- LongbowAbsoluteRangeTest.java
- LongbowDurationRangeTest.java
- ProtoBytePutRequestTest.java
- ProtoByteScanRequestTest.java
- PutRequestFactoryTest.java
- ScanRequestFactoryTest.java
- TablePutRequestTest.java
- TableScanRequestTest.java
- LongbowValidatorTest.java
- LongbowFactoryTest.java
- LongbowProcessorTest.java
- LongbowReadColumnModifierTest.java
- LongbowSchemaTest.java
- LongbowWriteColumnModifierTest.java
- MetricsTelemetryExporterTest.java
- TelemetryProcessorTest.java
- MockTransformer.java
- TransformConfigTest.java
- TransformProcessorTest.java
- ParentPostProcessorTest.java
- PostProcessorConfigTest.java
- PostProcessorFactoryTest.java
- PreProcessorFactoryTest.java
- PreProcessorOrchestratorTest.java
- BigQuerySinkBuilderTest.java
- BigQuerySinkTest.java
- BigQuerySinkWriterTest.java
- LateRecordDropErrorTest.java
- NoErrorTest.java
- ValidErrorTest.java
- ValidExceptionTest.java
- InfluxDBSinkTest.java
- InfluxDBWriterTest.java
- KafkaJsonSerializerBuilderTest.java
- KafkaProtoSerializerBuilderTest.java
- KafkaSerializationSchemaFactoryTest.java
- SinkOrchestratorTest.java
- DaggerSASLMechanismAdaptorTest.java
- DaggerSecurityProtocolAdaptorTest.java
- DaggerSSLKeyStoreFileTypeAdaptorTest.java
- DaggerSSLProtocolAdaptorTest.java
- DaggerSSLTrustStoreFileTypeAdaptorTest.java
- FileDateRangeAdaptorTest.java
- SourceParquetFilePathsAdapterTest.java
- TimeRangePoolTest.java
- TimeRangeTest.java
- StreamConfigTest.java
- FlinkKafkaConsumerCustomTest.java
- FlinkKafkaConsumerDaggerSourceTest.java
- KafkaDaggerSourceTest.java
- HourDatePathParserTest.java
- ParquetReaderTest.java
- ChronologyOrderedSplitAssignerTest.java
- ParquetDaggerSourceTest.java
- ParquetFileRecordFormatTest.java
- ParquetFileSourceTest.java
- DaggerSourceFactoryTest.java
- StreamsFactoryTest.java
- StreamTest.java
- StreamManagerTest.java
- broken-message
- multiple_row_groups_test_file.parquet
- test_file.parquet
- build.gradle
- Constants.java
- ArrayAggregationException.java
- ArrayOperateException.java
- BucketDoesNotExistException.java
- InvalidHashFieldException.java
- InvalidNumberOfArgumentsException.java
- KeyDoesNotExistException.java
- LongbowException.java
- MadZeroException.java
- MedianNotFound.java
- OddNumberOfArgumentsException.java
- PythonFilesEmptyException.java
- PythonFilesFormatException.java
- RowHashException.java
- TagDoesNotExistException.java
- FeatureWithTypeHandler.java
- FilterAspects.java
- FieldHasher.java
- IntegerFieldHasher.java
- LongFieldHasher.java
- RowHasher.java
- StringFieldHasher.java
- UnsupportedDataTypeHasher.java
- FieldHasherFactory.java
- PathReader.java
- ClearColumnTransformer.java
- DeDuplicationTransformer.java
- FeatureTransformer.java
- FeatureWithTypeTransformer.java
- HashTransformer.java
- InvalidRecordFilterTransformer.java
- SQLTransformer.java
- ArrayAccumulator.java
- DistinctCountAccumulator.java
- FeatureAccumulator.java
- FeatureWithTypeAccumulator.java
- PercentileAccumulator.java
- BigDecimalValueTransformer.java
- BooleanValueTransformer.java
- ByteValueTransformer.java
- DoubleValueTransformer.java
- FloatValueTransformer.java
- IntegerValueTransformer.java
- LongValueTransformer.java
- NullValueTransformer.java
- StringValueTransformer.java
- TimestampValueTransformer.java
- ValueEnum.java
- ValueTransformer.java
- ValueTransformerFactory.java
- FeatureUtils.java
- CollectArray.java
- DistinctCount.java
- Features.java
- FeaturesWithType.java
- PercentileAggregator.java
- FunctionFactory.java
- GcsClient.java
- GcsFileSource.java
- LocalFileSource.java
- FileSource.java
- FileSourceFactory.java
- FileType.java
- FileTypeFactory.java
- PythonFileType.java
- ZipFileType.java
- PythonUdfConfig.java
- PythonUdfManager.java
- GcsClient.java
- GcsDataStore.java
- DataStore.java
- Cache.java
- MapCache.java
- SetCache.java
- DartAspects.java
- CustomDescriptor.java
- Element.java
- RowElement.java
- ValueElement.java
- MessageReader.java
- AggregationExpression.java
- Expression.java
- OperationExpression.java
- ArrayAggregateProcessor.java
- ArrayOperateProcessor.java
- ArrayProcessor.java
- LongbowArrayType.java
- MessageParser.java
- ProtoToRow.java
- ArrayAggregate.java
- ArrayOperate.java
- ByteToString.java
- CondEq.java
- DartContains.java
- DartGet.java
- Distance.java
- ElementAt.java
- EndOfMonth.java
- EndOfWeek.java
- ExponentialMovingAverage.java
- Filters.java
- FormatTimeInZone.java
- GeoHash.java
- JsonDelete.java
- JsonQuery.java
- JsonUpdate.java
- LinearTrend.java
- ListContains.java
- MapGet.java
- S2AreaInKm2.java
- S2Id.java
- SelectFields.java
- SingleFeatureWithType.java
- Split.java
- StartOfMonth.java
- StartOfWeek.java
- TimeInDate.java
- TimestampFromUnix.java
- Mad.java
- Point.java
- HistogramBucket.java
- OutlierMad.java
- FeatureWithTypeHandlerTest.java
- IntegerFieldHasherTest.java
- LongFieldHasherTest.java
- RowHasherTest.java
- StringFieldHasherTest.java
- UnsupportedDataTypeHasherTest.java
- FieldHasherFactoryTest.java
- PathReaderTest.java
- ClearColumnTransformerTest.java
- DeDuplicationTransformerTest.java
- FeatureTransformerTest.java
- FeatureWithTypeTransformerTest.java
- HashTransformerTest.java
- InvalidRecordFilterTransformerTest.java
- SQLTransformerTest.java
- ArrayAccumulatorTest.java
- DistinctCountAccumulatorTest.java
- FeatureAccumulatorTest.java
- FeatureWithTypeAccumulatorTest.java
- PercentileAccumulatorTest.java
- BigDecimalValueTransformerTest.java
- BooleanValueTransformerTest.java
- ByteValueTransformerTest.java
- DoubleValueTransformerTest.java
- FloatValueTransformerTest.java
- IntegerValueTransformerTest.java
- LongValueTransformerTest.java
- NullValueTransformerTest.java
- StringValueTransformerTest.java
- TimestampValueTransformerTest.java
- FeatureUtilsTest.java
- CollectArrayTest.java
- DistinctCountTest.java
- FeaturesTest.java
- FeaturesWithTypeTest.java
- PercentileAggregatorTest.java
- FunctionFactoryTest.java
- GcsClientTest.java
- GcsFileSourceTest.java
- LocalFileSourceTest.java
- FileSourceFactoryTest.java
- FileTypeFactoryTest.java
- PythonFileTypeTest.java
- ZipFileTypeTest.java
- PythonUdfConfigTest.java
- PythonUdfManagerTest.java
- GcsDataStoreTest.java
- CacheTest.java
- MapCacheTest.java
- SetCacheTest.java
- CustomDescriptorTest.java
- ElementTest.java
- RowElementTest.java
- ValueElementTest.java
- MessageReaderTest.java
- AggregationExpressionTest.java
- OperationExpressionTest.java
- ArrayAggregateProcessorTest.java
- ArrayOperateProcessorTest.java
- MessageParserTest.java
- ArrayAggregateTest.java
- ArrayOperateTest.java
- ByteToStringTest.java
- CondEqTest.java
- DartContainsTest.java
- DartGetTest.java
- DistanceTest.java
- ElementAtTest.java
- EndOfMonthTest.java
- EndOfWeekTest.java
- ExponentialMovingAverageTest.java
- FiltersTest.java
- FormatTimeInZoneTest.java
- GeoHashTest.java
- JsonDeleteTest.java
- JsonQueryTest.java
- JsonUpdateTest.java
- LinearTrendTest.java
- ListContainsTest.java
- MapGetTest.java
- S2AreaInKm2Test.java
- S2IdTest.java
- SelectFieldsTest.java
- SingleFeatureWithTypeTest.java
- SplitTest.java
- StartOfMonthTest.java
- StartOfWeekTest.java
- TimeInDateTest.java
- TimestampFromUnixTest.java
- MadTest.java
- HistogramBucketTest.java
- OutlierMadTest.java
- python_udf.zip
- test_no_py.zip
- test_udf.py
- build.gradle
- sample_data.txt
- __init__.py
- multiply_test.py
- sample_test.py
- __init__.py
- __init__.py
- multiply.py
- sample.py
- requirements.txt
- EsExternalPostProcessorIntegrationTest.java
- GrpcExternalPostProcessorIntegrationTest.java
- HttpExternalPostProcessorIntegrationTest.java
- PostGresExternalPostProcessorIntegrationTest.java
- build.gradle
- 2023-05-23-intro-dagger-docs.md
- authors.yaml
- DARTS.md
- longbow.md
- longbow_plus.md
- overview.md
- post_processor.md
- pre_processor.md
- security.md
- architecture.md
- basics.md
- lifecycle.md
- overview.md
- add_transformer.md
- add_udf.md
- contribution.md
- development.md
- aggregation_tumble_window.md
- deduplication_transformer.md
- distance_java_udf.md
- elasticsearch_enrichment.md
- kafka_inner_join.md
- overview.md
- choose_source.md
- create_dagger.md
- deployment.md
- monitoring.md
- overview.md
- query_examples.md
- quickstart.md
- troubleshooting.md
- use_transformer.md
- use_udf.md
- configuration.md
- metrics.md
- overview.md
- transformers.md
- udfs.md
- 20220504_python_udf.md
- api_monitoring.md
- feature_ingestion.md
- overview.md
- stream_enrichment.md
- intro.md
- roadmap.md
- Container.js
- GridBlock.js
- custom.css
- theme.css
- help.js
- index.js
- dagger-grafana-dashboard.json
- dagger_lifecycle.drawio
- dagger_lifecycle.png
- dagger_overview.drawio
- dagger_overview.png
- dagger_system_design.drawio
- dagger_system_design.png
- api-monitoring.png
- api-status.png
- dart-contains.png
- dart-get.png
- enrichment.png
- external-http-post-processor.png
- external-internal-post-processor.png
- external-internal-transformer-post-processor.png
- favicon.ico
- homebanner.svg
- logo-n.svg
- longbow.png
- longbowplus-reader.png
- longbowplus-writer.png
- pattern.svg
- pre-processor.png
- query.svg
- sliding.png
- tumble.png
- gojek.png
- goto.png
- jago.png
- mapan.png
- midtrans.png
- moka.png
- paylater.png
- .nojekyll
- .gitignore
- babel.config.js
- docusaurus.config.js
- package-lock.json
- package.json
- README.md
- sidebars.js
- gradle-wrapper.jar
- gradle-wrapper.properties
- kafkafeeder.sh
- local.properties
- sample_message.txt
- TestLogMessage.proto
- compose.yaml
- kafkafeeder.sh
- local.properties
- sample_message.txt
- TestLogMessage.proto
- compose.yaml
- README.md
- EnrichedBookingLogMessage.proto
- TestLogMessage.proto
- kafkafeeder.sh
- local.properties
- sample_message.txt
- seed1.json
- compose.yaml
- README.md
- kafkafeeder.sh
- local.properties
- sample_message.txt
- TestLogMessage.proto
- compose.yaml
- README.md
- kafkafeeder.sh
- local.properties
- sample_message.txt
- TestLogMessage.proto
- compose.yaml
- README.md
- kafkafeeder.sh
- local.properties
- sample_message.txt
- TestLogMessage.proto
- compose.yaml
- README.md
- .gitignore
- build.gradle
- gradle.properties
- gradlew
- gradlew.bat
- LICENSE
- README.md
- settings.gradle
- version.txt
// repository documentation
Was this content helpful?
(0 ratings)
