Package org.apache.beam.sdk.extensions.sql.example

Class BeamSqlDataCatalogExample

java.lang.Object

org.apache.beam.sdk.extensions.sql.example.BeamSqlDataCatalogExample

public class BeamSqlDataCatalogExample
extends Object

Example pipeline that uses Google Cloud Data Catalog to retrieve the table metadata.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BeamSqlDataCatalogExample.DCExamplePipelineOptions	Pipeline options to specify the query and the output for the example.

Constructor Summary

Constructors

Constructor	Description
BeamSqlDataCatalogExample()

Method Summary

Modifier and Type	Method	Description
static void	main(String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BeamSqlDataCatalogExample

public BeamSqlDataCatalogExample()

Method Details

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception