examples
π Examples of use cases that utilize Decodable, as well as demos for related open-source projects such as Apache Flink, Debezium, and Postgres.
νμΌ νμκΈ°
μ΅μ’ λ²μ λ€μ΄λ‘λ (.zip)- ecom.sql
- docker-compose.yaml
- ngrok.yml
- README.md
- Dockerfile
- flink-inserts.sql
- postgresql.conf.sample
- public_inventory.sql
- ArrayAccumulator.java
- ArrayAggr.java
- docker-compose.yaml
- flink-tables.sql
- pom.xml
- README.md
- dp.decodable.yaml.j2
- s3.sh.j2
- .gitignore
- Makefile
- README.md
- hive-site.xml
- Dockerfile
- flink-sql-history
- hive-site.xml
- Dockerfile
- docker-compose.yml
- README.adoc
- hive-site.xml
- Dockerfile
- flink-sql-history
- iceberg_jdbc.sql
- docker-compose.yml
- README.adoc
- Dockerfile
- public_inventory.sql
- docker-compose.yaml
- README.md
- change_stream.json
- pipeline.sql
- postgres.sql
- .gitignore
- Makefile
- README.md
- Dockerfile
- entrypoint.sh
- README.adoc
- confluent.jpg
- current-demo.jpg
- pg-view.jpg
- clickstream.json
- clickstream_users_last_click.sql
- Makefile
- README.md
- sample.json
- datagen-01.yaml
- count-messages.yaml
- example-workflow.yaml
- README.adoc
- covid.py
- requirements.txt
- covid_cleanse.sql
- kafka.json.template
- .gitignore
- Makefile
- README.md
- .gitignore
- load.js
- Makefile
- package-lock.json
- package.json
- README.md
- sample.json
- stream.png
- 00_init.sql
- decodable-resources.yaml
- docker-compose.yaml
- ngrok.yml
- README.md
- Dockerfile
- mysql-to-es.yaml
- inventory.orig.sql
- sink_elasticsearch.sql
- src_mysql.sql
- diagram.excalidraw.png
- docker-compose.yml
- README.adoc
- hive-site.xml
- Dockerfile
- hive-site.xml
- Dockerfile
- kafka-retail.json
- delta-flink.sql
- docker-compose.yml
- kafka-to-delta.sql
- notes.adoc
- basic.yaml
- custom-job-ha.yaml
- custom-job-s3.yaml
- custom-job.yaml
- logging-job.yaml
- savepoint.yaml
- deploy-ingress-nginx.yaml
- heimdall.yaml
- DataStreamJob.java
- Dockerfile
- pom.xml
- elastic-flow.yaml
- elastic-output.yaml
- elastic.yaml
- kibana.yaml
- logging.yaml
- minio-deployment.yaml
- minio-pvc.yaml
- minio-service.yaml
- helm-values.yaml
- kind-cluster.yml
- README.md
- NameGen.java
- README.md
- schema.json
- examples_repo.webp
- .gitignore
- influxdb.png
- lambda_function.py
- Makefile
- README.md
- requirements.txt
- sample.json
- hive-site.xml
- Dockerfile
- hive-site.xml
- Dockerfile
- kafkaflinkicebergminio.excalidraw.png
- kafka-retail.json
- docker-compose.yml
- kafka-to-iceberg-multi-statement.sql
- kafka-to-iceberg.sql
- ksl-demo.adoc
- README.md
- config.json
- config_normalised.json
- docker-compose.yml
- README.md
- .gitignore
- docker-compose.yml
- README.adoc
- Dockerfile
- public_inventory.sql
- docker-compose.yaml
- pom.xml
- README.md
- README.md
- materialize_crypto_raw.sql
- pipeline.sql
- transform.sql
- .gitignore
- crypto.py
- Makefile
- requirements.txt
- sample.json
- MOCK_DATA.csv
- sample.json
- overlay.sql
- regex.sql
- loader.py
- Makefile
- README.md
- systemdb.png
- filter.cleanse.sql
- materialize.sql
- .gitignore
- commands.sql
- kinesis.py
- Makefile
- README.md
- requirements.txt
- sample.json
- .gitignore
- data.json
- Makefile
- README.md
- bad.json
- evolved.json
- good.json
- odp.jpg
- sow.jpg
- employee.json
- model.sh.j2
- Makefile
- README.md
- .gitignore
- commands.sql
- kinesis.py
- Makefile
- ojdbc11.jar
- README.md
- requirements.txt
- sample.json
- process.example.json
- processes.schema.json
- suspicious.json
- cleanse.sql
- noise.sql
- suspicious.sql
- consumer.py
- Makefile
- pulsar.ext
- README.md
- requirements.txt
- osquery-schema.json
- suspicious.cleanse.sql
- osquery-table.json.j2
- .gitignore
- Makefile
- README.md
- eclipse-formatter-config.xml
- license.txt
- inventory.sql
- create-multiple-postgresql-databases.sh
- AdvanceSlotMain.java
- AuditState.java
- AuditMain.java
- MessageDeserializer.java
- ChangeEvent.java
- Message.java
- OutboxMain.java
- .dontdelete
- docker-compose-multi-db.yml
- docker-compose-outbox.yml
- docker-compose.yml
- pom.xml
- README.md
- docker-compose.yaml
- postgres-connector.json
- README.md
- omd-pg.yaml
- omd-sf.yaml
- pg-secret.yaml
- sf-secret.yaml
- postgresql.conf.sample
- replication-config.sql
- config.json
- docker-compose.yml
- README.adoc
- .gitignore
- decodable-apis.postman_collection.json
- Makefile
- README.md
- Makefile
- README.md
- App.java
- build.gradle
- gradle-wrapper.jar
- gradle-wrapper.properties
- .gitattributes
- .gitignore
- gradlew
- gradlew.bat
- settings.gradle
- pulsar.py
- .gitignore
- Makefile
- README.md
- Dockerfile
- Dockerfile.pyflink-base
- kind-config.yaml
- pyflink-hello-world.yaml
- pyflink_hello_world.py
- README.md
- .secret_kafka_bootstrap_servers
- .secret_kafka_password
- .secret_kafka_user_name
- decodable-resources.yaml
- main.py
- Makefile
- README.md
- requirements.txt
- compose.dev.yaml
- Containerfile
- devcontainer.json
- job_config
- job_config.prod
- download_flink_jars.sh
- build.sh
- decodable-resources.yaml
- main.py
- Makefile
- requirements.txt
- hello_datastream_api.py
- hello_table_api.py
- hello_table_api_sql.py
- vector_index_def.json
- init.sql
- .gitignore
- compose.yaml
- ngrok.yml
- README.md
- data_sample.json
- Dockerfile
- generate.sh
- vector_index_def.json
- init.sql
- 01_pyflink_vector_ingestion_overview.png
- 02_pyflink_vector_ingestion_operational_database.png
- 03_pyflink_vector_ingestion_pyflink_decodable.png
- 04_pyflink_vector_ingestion_vector_store.png
- pyflink_vector_ingestion_illustrations.excalidraw
- 01_login_signup.png
- 02_dashboard.png
- .gitignore
- MavenWrapperDownloader.java
- Dockerfile.jvm
- Dockerfile.legacy-jar
- Dockerfile.native
- Dockerfile.native-micro
- HuggingFaceEmbeddingResource.java
- LocalEmbeddingResource.java
- .dockerignore
- .gitignore
- Dockerfile
- download_model.sh
- mvnw
- mvnw.cmd
- pom.xml
- README.md
- job_config
- .gitignore
- build.sh
- decodable-resources.yaml
- Dockerfile.builder
- main.py
- Makefile
- requirements.txt
- .gitignore
- MavenWrapperDownloader.java
- Dockerfile.jvm
- Dockerfile.legacy-jar
- Dockerfile.native
- Dockerfile.native-micro
- Review.java
- ReviewProjection.java
- Review.java
- EmbeddingModelService.java
- ReviewResource.java
- SearchResource.java
- .dockerignore
- .gitignore
- mvnw
- mvnw.cmd
- pom.xml
- README.md
- .gitignore
- compose.yaml
- ngrok.yml
- README.md
- cli-output.png
- create-run-config.png
- edit-config.png
- include.png
- job-sql.png
- output.png
- pom.xml
- README.md
- custom-trust-policy.png
- external-schema.png
- iam.png
- .gitignore
- commands.sql
- README.md
- requirements.txt
- add-trigger.png
- s3-event-not.png
- .gitignore
- lambda.py
- README.md
- airline_tracking.md
- extract_flight_data.sql
- flights-raw.json
- flights-summary.json
- overview.png
- pipeline1.png
- aggregate_and_filter.sql
- claim_adjudication.md
- claims-raw.json
- claims-summary.json
- extract_claims_data.sql
- overview.png
- pipeline1.png
- pipeline2.png
- call_log.json
- call_log.xml
- clickstream.json
- customer_360.json
- customer_360.md
- overview.png
- pipeline1.png
- pipeline2.png
- standardize_call_log.sql
- standardize_clickstream.sql
- cdp.json
- customer_data_platform.md
- geolocation.json
- overview.png
- pipeline1.png
- pipeline2.png
- point_of_sales.json
- standardize_geolocation.sql
- standardize_pos.sql
- coinbase_btc_usd_ticker.json
- coinbase_exchange_transactions.sql
- coinbase_transaction_summary.json
- coinbase_transaction_summary.sql
- financial_analysis.md
- overview.png
- pipeline1.png
- pipeline2.png
- calculate_delivery_progress.sql
- extract_delivery_data.sql
- food_delivery.json
- food_delivery.md
- food_delivery.xml
- food_delivery_status.json
- overview.png
- pipeline1.png
- pipeline2.png
- calculate_pointer_statistics.sql
- calculate_pointer_velocity.sql
- extract_pointer_records.sql
- fraud_detection.md
- moonsense_pointer_stats.json
- moonsense_raw.json
- overview.png
- parse_moonsense_data.sql
- pipeline1.png
- pipeline2.png
- pipeline3.png
- pipeline4.png
- consolidate_device_measurements.sql
- device_raw.json
- device_summary.json
- extract_monitoring_data.sql
- healthcare_monitoring.md
- overview.png
- pipeline1.png
- pipeline2.png
- calculate_distance_and_elapsed_time.sql
- extract_tracking_data.sql
- overview.png
- pipeline1.png
- pipeline2.png
- shipping_logistics.md
- tracking-raw.json
- tracking_summary.json
- aggregate_player_action_statistics.sql
- events_raw.json
- events_summary.json
- extract_player_action_events.sql
- overview.png
- pipeline1.png
- pipeline2.png
- sporting_events.md
- extract_adjustment_data.sql
- inventory_adjustments_summary.json
- inventory_requests.json
- overview.png
- pipeline1.png
- pipeline2.png
- summarize_inventory_adjustments.sql
- warehouse_inventory.md
- aggregate_clickstream_data.sql
- clickstream-raw.json
- clickstream_summary.json
- overview.png
- pipeline1.png
- website_clickstream.md
- README.md
- sample_datagen.html
- maven-wrapper.jar
- maven-wrapper.properties
- FruitEnricherJob.java
- HttpServiceEnricher.java
- FruitEnriched.java
- FruitIntake.java
- Nutritions.java
- log4j2.xml
- .gitignore
- mvnw
- mvnw.cmd
- pom.xml
- high-level-example-overview.png
- full_example.yaml
- fruit_intake_generator.sh
- README.md
- maven-wrapper.jar
- maven-wrapper.properties
- 01_flink-job-high-level-showing-external-service-dependencies.webp
- FruitEnricherJob.java
- FruitNutritionMapper.java
- HttpNutritionEnricher.java
- NutritionEnricher.java
- FruitEnriched.java
- FruitIntake.java
- Nutritions.java
- log4j2.xml
- FruitEnricherJobIntegrationTest.java
- FruitEnricherJobTest.java
- HttpNutritionEnricherTest.java
- MockNutritionEnricherTest.java
- TestData.java
- .gitignore
- mvnw
- mvnw.cmd
- pom.xml
- README.md
- decodable_wikipedia.datasource
- wiki_flatten.sql
- decodable_wikipedia_pipe_activity.pipe
- decodable_wikipedia_pipe_activity_by_author.pipe
- decodable_wikipedia_pipe_by_author.pipe
- .gitignore
- author.html
- Makefile
- README.md
- requirements.txt
- wiki.html
- wiki.py
- Dockerfile
- docker-compose.yml
- flink-postgres.excalidraw
- hive-site.xml
- Dockerfile.hive239
- Dockerfile.hive313
- Dockerfile.no-hive
- .gitignore
- docker-compose.yml
- hive-site.xml
- Dockerfile
- flink-sql-history
- hive-site.xml
- Dockerfile
- docker-compose.yml
- hive-site.xml
- Dockerfile
- flink-sql-history
- hive-site.xml
- Dockerfile
- docker-compose.yml
- README.md
- CdcEvent.java
- TxBuffer.java
- TxDataCollection.java
- TxMetaData.java
- TxMetaDataCustom.java
- TxStatus.java
- DeserializationSchemaCdcEvents.java
- SerializationSchemaTxBuffer.java
- TxBufferTypeInfoFactory.java
- TxDataCollectionTypeInfoFactory.java
- CdcTxBuffer.java
- CdcTxBufferingJob.java
- CdcTxBufferingLogic.java
- TxEventsFilter.java
- TxIdKeySelector.java
- .gitignore
- mvnw
- mvnw.cmd
- pom.xml
- example_db_transaction_captured_by_dbz.png
- flink_job_cdc_events_tx_agg.png
- compose.yaml
- README.md
- helper.py
- input.xml
- xml.jpg
- pipeline.sql
- Makefile
- README.md
- .gitignore
- LICENSE
- README.md
// repository documentation
Was this content helpful?
(0 ratings)
