Qdrant Connector (experimental)

QdrantConnector

Bases: Connector

Qdrant vector DB connector (stub).

Path format: qdrant://host:port/collection or qdrant+https://host/collection. Requires optional dependency qdrant-client for real IO.

read

read(spark: SparkSession, source: Any, *, fmt: Optional[str] = None, schema: Optional[Any] = None, source_config: Optional[Mapping[str, Any]] = None, options: Optional[Mapping[str, Any]] = None, **kwargs: Any) -> DataFrame

Read vectors/payloads from Qdrant (not yet implemented).

Source code in src/spark_fuse/io/qdrant.py

def read(
    self,
    spark: SparkSession,
    source: Any,
    *,
    fmt: Optional[str] = None,
    schema: Optional[Any] = None,
    source_config: Optional[Mapping[str, Any]] = None,
    options: Optional[Mapping[str, Any]] = None,
    **kwargs: Any,
) -> DataFrame:
    """Read vectors/payloads from Qdrant (not yet implemented)."""
    raise NotImplementedError(
        "Qdrant read is not implemented in the stub. Install 'qdrant-client' and use a specialized reader."
    )

validate_path

validate_path(path: str) -> bool

Return True if path looks like a supported Qdrant URI.

Source code in src/spark_fuse/io/qdrant.py

def validate_path(self, path: str) -> bool:
    """Return True if `path` looks like a supported Qdrant URI."""
    return bool(_QDRANT_RE.match(path))

write

write(df: DataFrame, path: str, *, fmt: Optional[str] = None, mode: str = 'append', **options: Any) -> None

Write vectors/payloads to Qdrant (not yet implemented).

Source code in src/spark_fuse/io/qdrant.py

def write(
    self,
    df: DataFrame,
    path: str,
    *,
    fmt: Optional[str] = None,
    mode: str = "append",
    **options: Any,
) -> None:
    """Write vectors/payloads to Qdrant (not yet implemented)."""
    raise NotImplementedError(
        "Qdrant write is not implemented in the stub. Install 'qdrant-client' and implement upsert per collection schema."
    )