Zingg Pipes
Last updated
Last updated
Zingg Pipes are an abstraction for a data source from which Zingg fetches data for matching or to which Zingg writes its output. This lets users connect to literally any datastore that has a Spark connector.
The pipe is an easy way to specify properties and formats for the Spark connector of the relevant datasource. Zingg pipes can be configured through the config passed to the program by outlining the datastore connection properties.
Pipes can be configured for the data or the output attributes on the .
Each pipe has the following attributes
unique name to identify the data store
One of the Spark supported connector formats. jdbc/avro/parquet etc
Properties to be passed to spark.read and spark.write.
Let us look at some common datasources and their configurations.