Package io.github.flink.gcp.connector.bigquery

Class BigQueryLineage

java.lang.Object

io.github.flink.gcp.connector.bigquery.BigQueryLineage

@Internal
public final class BigQueryLineage
extends Object

Inspects configured BigQuery resources without evaluating a resolver or opening a client.

Method Summary

Modifier and Type	Method	Description
static List<ResourceIdentifier>	resources(DestinationResolver<?> resolver)	Returns a fixed output without invoking user destination resolution.
static List<ResourceIdentifier>	resources(TableDestination table)	Returns the configured input, or no physical resource for an arbitrary query.

Methods inherited from class java.lang.Object

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

Method Details

resources

public static List<ResourceIdentifier> resources(@Nullable
 TableDestination table)

Returns the configured input, or no physical resource for an arbitrary query.

resources

public static List<ResourceIdentifier> resources(DestinationResolver<?> resolver)

Returns a fixed output without invoking user destination resolution.