Skip to content

Commit

Permalink
#469 Update README with new features.
Browse files Browse the repository at this point in the history
  • Loading branch information
yruslan committed Aug 20, 2024
1 parent d71da04 commit 118a8c5
Showing 1 changed file with 16 additions and 2 deletions.
18 changes: 16 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -465,7 +465,15 @@ pramen.sources = [
format = "parquet"
minimum.records = 0
# If true, fails the pipeline is there is no data any time when it is expected
fail.if.no.data = false
# If true, fails the pipeline is there is no data for jobs trying to catch late data
fail.if.no.late.data = false
# If true, fails the pipeline is there is no data for jobs checking new data as expected
fail.if.no.new.data = false
}
]
```
Expand Down Expand Up @@ -534,10 +542,16 @@ is determined by the pipeline configuration.
# SQL queries that do not start with "SELECT".
use.jdbc.native = false
# Consider the pipeline as failed if at least one table has no data at the scheduled time.
# Consider the pipeline as failed if at least one table has no data at the scheduled time (new or late).
# Useful for auto-retrying ingestion pipelines.
fail.if.no.data = false
# If true, fails the pipeline is there is no data for jobs trying to catch late data
fail.if.no.late.data = false
# If true, fails the pipeline is there is no data for jobs checking new data as expected
fail.if.no.new.data = false
# One of: auto (default), always, never
# - When 'auto', an identifier will be quoted if it contains invalid characters. This includes any characters
# outside the scope of A-Z, a-z, 0-9, and underscore (_).
Expand Down Expand Up @@ -1952,7 +1966,7 @@ Here is an example configuration for a JDBC source:
# You can override any of source settings here
source {
minimum.records = 1000
fail.if.no.data = true
fail.if.no.new.data = true
has.information.date.column = true
use.jdbc.native = true
information.date.column = "info_date"
Expand Down

0 comments on commit 118a8c5

Please sign in to comment.