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

Class BeamSqlDataCatalogExample

java.lang.Object

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

public class BeamSqlDataCatalogExample
extends java.lang.Object

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

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
BeamSqlDataCatalogExample()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamSqlDataCatalogExample

public BeamSqlDataCatalogExample()

Method Detail

main

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

Throws:

java.lang.Exception