airbyte_cdk.sources.declarative.stream_slicers

View Source

1#
2# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
3#
4
5from airbyte_cdk.sources.declarative.stream_slicers.stream_slicer import StreamSlicer
6
7__all__ = ["StreamSlicer"]

class StreamSlicer(airbyte_cdk.sources.streams.concurrent.partitions.stream_slicer.StreamSlicer, airbyte_cdk.sources.declarative.requesters.request_options.request_options_provider.RequestOptionsProvider, abc.ABC): View Source

16class StreamSlicer(ConcurrentStreamSlicer, RequestOptionsProvider, ABC):
17    """
18    Slices the stream into a subset of records.
19    Slices enable state checkpointing and data retrieval parallelization.
20
21    The stream slicer keeps track of the cursor state as a dict of cursor_field -> cursor_value
22
23    See the stream slicing section of the docs for more information.
24    """
25
26    pass

Slices the stream into a subset of records. Slices enable state checkpointing and data retrieval parallelization.

The stream slicer keeps track of the cursor state as a dict of cursor_field -> cursor_value

See the stream slicing section of the docs for more information.

Inherited Members

airbyte_cdk.sources.streams.concurrent.partitions.stream_slicer.StreamSlicer: stream_slices
airbyte_cdk.sources.declarative.requesters.request_options.request_options_provider.RequestOptionsProvider: get_request_params; get_request_headers; get_request_body_data; get_request_body_json