Databricks SDK for JavaScript
    Preparing search index...

    Interface StreamSource

    A Stream entity used as a data source for a feature.

    interface StreamSource {
        dataframeSchema?: string;
        filterCondition?: string;
        fullName?: string;
        transformationSql?: string;
    }
    Index

    Properties

    dataframeSchema? filterCondition? fullName? transformationSql?

    Properties

    dataframeSchema?: string

    Schema of the resulting dataframe after transformations, in Spark StructType JSON format (from df.schema.json()). Any subsequent functions operate against this dataframe.

    filterCondition?: string

    The filter condition applied to the source data before aggregation.

    fullName?: string

    Three-part full name of the Stream (catalog.schema.stream).

    transformationSql?: string

    The pipeline runs these SQL statements immediately after conversion into the schema specified on the Stream object.

    Settings

    Member Visibility

    On This Page

    Properties