File tree Expand file tree Collapse file tree 1 file changed +0
-28
lines changed Expand file tree Collapse file tree 1 file changed +0
-28
lines changed Original file line number Diff line number Diff line change @@ -659,34 +659,6 @@ def _inner(connector_cls: type) -> type:
659659 return _inner
660660
661661
662- # Users will define a source spec class first (e.g. CustomSource), then provide a source connector like this:
663- #
664- # @cocoindex.op.source_connector(spec_cls=CustomSource, key_type=KeyType, value_type=ValueType)
665- # class CustomSourceConnector:
666- # @staticmethod
667- # async def create(spec: CustomSource) -> Self:
668- # # Initialize and return the connector instance
669- # ...
670- #
671- # async def list(self, options: SourceReadOptions) -> AsyncIterator[PartialSourceRow[KeyType, ValueType]]:
672- # # options.include_ordinal: whether to include ordinal information
673- # # options.include_content_version_fp: whether to include content version fingerprint
674- # # options.include_value: whether to include the actual value data
675- # ...
676- #
677- # async def get_value(self, key: KeyType, options: SourceReadOptions) -> PartialSourceRowData[ValueType]:
678- # # options.include_ordinal: must return ordinal if True
679- # # options.include_content_version_fp: may return fingerprint if efficient
680- # # options.include_value: must return value if True
681- # ...
682- #
683- # @staticmethod
684- # def provides_ordinal(executor: Self) -> bool:
685- # # Return True if this source can provide ordinal information
686- # # Called with the executor instance (not the spec)
687- # return False
688-
689-
690662########################################################
691663# Custom target connector
692664########################################################
You can’t perform that action at this time.
0 commit comments