Module Values_0.SnowflakeNodeDataSource

Specifies configuration for Snowflake nodes in Glue Studio.

Sourcetype nonrec t = {
  1. sourceType : GenericLimitedString.t option;
    (*

    Specifies how retrieved data is specified. Valid values: "table", "query".

    *)
  2. connection : Option_.t option;
    (*

    Specifies a Glue Data Catalog Connection to a Snowflake endpoint.

    *)
  3. schema : GenericString.t option;
    (*

    Specifies a Snowflake database schema for your node to use.

    *)
  4. table : GenericString.t option;
    (*

    Specifies a Snowflake table for your node to use.

    *)
  5. database : GenericString.t option;
    (*

    Specifies a Snowflake database for your node to use.

    *)
  6. tempDir : EnclosedInStringProperty.t option;
    (*

    Not currently used.

    *)
  7. iamRole : Option_.t option;
    (*

    Not currently used.

    *)
  8. additionalOptions : AdditionalOptions.t option;
    (*

    Specifies additional options passed to the Snowflake connector. If options are specified elsewhere in this node, this will take precedence.

    *)
  9. sampleQuery : GenericString.t option;
    (*

    A SQL string used to retrieve data with the query sourcetype.

    *)
  10. preAction : GenericString.t option;
    (*

    A SQL string run before the Snowflake connector performs its standard actions.

    *)
  11. postAction : GenericString.t option;
    (*

    A SQL string run after the Snowflake connector performs its standard actions.

    *)
  12. action : GenericString.t option;
    (*

    Specifies what action to take when writing to a table with preexisting data. Valid values: append, merge, truncate, drop.

    *)
  13. upsert : BooleanValue.t option;
    (*

    Used when Action is append. Specifies the resolution behavior when a row already exists. If true, preexisting rows will be updated. If false, those rows will be inserted.

    *)
  14. mergeAction : GenericLimitedString.t option;
    (*

    Specifies a merge action. Valid values: simple, custom. If simple, merge behavior is defined by MergeWhenMatched and MergeWhenNotMatched. If custom, defined by MergeClause.

    *)
  15. mergeWhenMatched : GenericLimitedString.t option;
    (*

    Specifies how to resolve records that match preexisting data when merging. Valid values: update, delete.

    *)
  16. mergeWhenNotMatched : GenericLimitedString.t option;
    (*

    Specifies how to process records that do not match preexisting data when merging. Valid values: insert, none.

    *)
  17. mergeClause : GenericString.t option;
    (*

    A SQL statement that specifies a custom merge behavior.

    *)
  18. stagingTable : GenericString.t option;
    (*

    The name of a staging table used when performing merge or upsert append actions. Data is written to this table, then moved to table by a generated postaction.

    *)
  19. selectedColumns : OptionList.t option;
    (*

    Specifies the columns combined to identify a record when detecting matches for merges and upserts. A list of structures with value, label and description keys. Each structure describes a column.

    *)
  20. autoPushdown : BooleanValue.t option;
    (*

    Specifies whether automatic query pushdown is enabled. If pushdown is enabled, then when a query is run on Spark, if part of the query can be "pushed down" to the Snowflake server, it is pushed down. This improves performance of some queries.

    *)
  21. tableSchema : OptionList.t option;
    (*

    Manually defines the target schema for the node. A list of structures with value , label and description keys. Each structure defines a column.

    *)
}
Sourceval make : ?sourceType:??? -> ?connection:??? -> ?schema:??? -> ?table:??? -> ?database:??? -> ?tempDir:??? -> ?iamRole:??? -> ?additionalOptions:??? -> ?sampleQuery:??? -> ?preAction:??? -> ?postAction:??? -> ?action:??? -> ?upsert:??? -> ?mergeAction:??? -> ?mergeWhenMatched:??? -> ?mergeWhenNotMatched:??? -> ?mergeClause:??? -> ?stagingTable:??? -> ?selectedColumns:??? -> ?autoPushdown:??? -> ?tableSchema:??? -> unit -> t
Sourceval to_value : t -> [> `Structure of (string * [> `Boolean of BooleanValue.t | `List of [> `Structure of (string * [> `String of EnclosedInStringProperty.t ]) list ] list | `Map of ([> `String of EnclosedInStringProperty.t ] * [> `String of EnclosedInStringProperty.t ]) list | `String of GenericLimitedString.t | `Structure of (string * [> `String of EnclosedInStringProperty.t ]) list ]) list ]
Sourceval to_query : t -> Awso.Client.Query.t
Sourceval of_xml : Awso.Xml.t -> t
Sourceval of_string : string -> t
Sourceval of_json : Yojson.Safe.t -> t
Sourceval to_json : t -> Yojson.Safe.t