airbyte_cdk.sources.declarative.stream_slicers.stream_slicer
1# 2# Copyright (c) 2023 Airbyte, Inc., all rights reserved. 3# 4 5from abc import ABC 6 7from airbyte_cdk.sources.declarative.requesters.request_options.request_options_provider import ( 8 RequestOptionsProvider, 9) 10from airbyte_cdk.sources.streams.concurrent.partitions.stream_slicer import ( 11 StreamSlicer as ConcurrentStreamSlicer, 12) 13 14 15class StreamSlicer(ConcurrentStreamSlicer, RequestOptionsProvider, ABC): 16 """ 17 Slices the stream into a subset of records. 18 Slices enable state checkpointing and data retrieval parallelization. 19 20 The stream slicer keeps track of the cursor state as a dict of cursor_field -> cursor_value 21 22 See the stream slicing section of the docs for more information. 23 """ 24 25 pass
class
StreamSlicer(airbyte_cdk.sources.streams.concurrent.partitions.stream_slicer.StreamSlicer, airbyte_cdk.sources.declarative.requesters.request_options.request_options_provider.RequestOptionsProvider, abc.ABC):
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.