@@ -1394,27 +1394,27 @@ definitions:
13941394 type :
13951395 type : string
13961396 enum : [DeclarativeStream]
1397+ name :
1398+ title : Name
1399+ description : The stream name.
1400+ type : string
1401+ default : " "
1402+ example :
1403+ - " Users"
13971404 retriever :
13981405 title : Retriever
13991406 description : Component used to coordinate how records are extracted across stream slices and request pages.
14001407 anyOf :
1408+ - " $ref " : " #/definitions/SimpleRetriever"
14011409 - " $ref " : " #/definitions/AsyncRetriever"
14021410 - " $ref " : " #/definitions/CustomRetriever"
1403- - " $ref " : " #/definitions/SimpleRetriever"
14041411 incremental_sync :
14051412 title : Incremental Sync
14061413 description : Component used to fetch data incrementally based on a time field in the data.
14071414 anyOf :
1408- - " $ref " : " #/definitions/CustomIncrementalSync"
14091415 - " $ref " : " #/definitions/DatetimeBasedCursor"
14101416 - " $ref " : " #/definitions/IncrementingCountCursor"
1411- name :
1412- title : Name
1413- description : The stream name.
1414- type : string
1415- default : " "
1416- example :
1417- - " Users"
1417+ - " $ref " : " #/definitions/CustomIncrementalSync"
14181418 primary_key :
14191419 title : Primary Key
14201420 description : The primary key of the stream.
@@ -1912,6 +1912,17 @@ definitions:
19121912 - " /products"
19131913 - " /quotes/{{ stream_partition['id'] }}/quote_line_groups"
19141914 - " /trades/{{ config['symbol_id'] }}/history"
1915+ http_method :
1916+ title : HTTP Method
1917+ description : The HTTP method used to fetch data from the source (can be GET or POST).
1918+ type : string
1919+ enum :
1920+ - GET
1921+ - POST
1922+ default : GET
1923+ examples :
1924+ - GET
1925+ - POST
19151926 authenticator :
19161927 title : Authenticator
19171928 description : Authentication method to use for requests sent to the API.
@@ -1926,24 +1937,6 @@ definitions:
19261937 - " $ref " : " #/definitions/SelectiveAuthenticator"
19271938 - " $ref " : " #/definitions/CustomAuthenticator"
19281939 - " $ref " : " #/definitions/LegacySessionTokenAuthenticator"
1929- error_handler :
1930- title : Error Handler
1931- description : Error handler component that defines how to handle errors.
1932- anyOf :
1933- - " $ref " : " #/definitions/DefaultErrorHandler"
1934- - " $ref " : " #/definitions/CompositeErrorHandler"
1935- - " $ref " : " #/definitions/CustomErrorHandler"
1936- http_method :
1937- title : HTTP Method
1938- description : The HTTP method used to fetch data from the source (can be GET or POST).
1939- type : string
1940- enum :
1941- - GET
1942- - POST
1943- default : GET
1944- examples :
1945- - GET
1946- - POST
19471940 request_body_data :
19481941 title : Request Body Payload (Non-JSON)
19491942 description : Specifies how to populate the body of the request with a non-JSON payload. Plain text will be sent as is, whereas objects will be converted to a urlencoded form.
@@ -2021,6 +2014,13 @@ definitions:
20212014 - query : ' last_event_time BETWEEN TIMESTAMP "{{ stream_interval.start_time }}" AND TIMESTAMP "{{ stream_interval.end_time }}"'
20222015 - searchIn : " {{ ','.join(config.get('search_in', [])) }}"
20232016 - sort_by[asc] : updated_at
2017+ error_handler :
2018+ title : Error Handler
2019+ description : Error handler component that defines how to handle errors.
2020+ anyOf :
2021+ - " $ref " : " #/definitions/DefaultErrorHandler"
2022+ - " $ref " : " #/definitions/CompositeErrorHandler"
2023+ - " $ref " : " #/definitions/CustomErrorHandler"
20242024 use_cache :
20252025 title : Use Cache
20262026 description : Enables stream requests caching. This field is automatically set by the CDK.
@@ -3395,14 +3395,26 @@ definitions:
33953395 type :
33963396 type : string
33973397 enum : [SimpleRetriever]
3398- record_selector :
3399- description : Component that describes how to extract records from a HTTP response.
3400- " $ref " : " #/definitions/RecordSelector"
34013398 requester :
34023399 description : Requester component that describes how to prepare HTTP requests to send to the source API.
34033400 anyOf :
34043401 - " $ref " : " #/definitions/HttpRequester"
34053402 - " $ref " : " #/definitions/CustomRequester"
3403+ decoder :
3404+ title : Decoder
3405+ description : Component decoding the response so records can be extracted.
3406+ anyOf :
3407+ - " $ref " : " #/definitions/CsvDecoder"
3408+ - " $ref " : " #/definitions/GzipDecoder"
3409+ - " $ref " : " #/definitions/JsonDecoder"
3410+ - " $ref " : " #/definitions/JsonlDecoder"
3411+ - " $ref " : " #/definitions/IterableDecoder"
3412+ - " $ref " : " #/definitions/XmlDecoder"
3413+ - " $ref " : " #/definitions/ZipfileDecoder"
3414+ - " $ref " : " #/definitions/CustomDecoder"
3415+ record_selector :
3416+ description : Component that describes how to extract records from a HTTP response.
3417+ " $ref " : " #/definitions/RecordSelector"
34063418 paginator :
34073419 description : Paginator component that describes how to navigate through the API's pages.
34083420 anyOf :
@@ -3428,18 +3440,6 @@ definitions:
34283440 - " $ref " : " #/definitions/SubstreamPartitionRouter"
34293441 - " $ref " : " #/definitions/GroupingPartitionRouter"
34303442 - " $ref " : " #/definitions/CustomPartitionRouter"
3431- decoder :
3432- title : Decoder
3433- description : Component decoding the response so records can be extracted.
3434- anyOf :
3435- - " $ref " : " #/definitions/CsvDecoder"
3436- - " $ref " : " #/definitions/GzipDecoder"
3437- - " $ref " : " #/definitions/JsonDecoder"
3438- - " $ref " : " #/definitions/JsonlDecoder"
3439- - " $ref " : " #/definitions/IterableDecoder"
3440- - " $ref " : " #/definitions/XmlDecoder"
3441- - " $ref " : " #/definitions/ZipfileDecoder"
3442- - " $ref " : " #/definitions/CustomDecoder"
34433443 $parameters :
34443444 type : object
34453445 additionalProperties : true
0 commit comments