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

Class TableCreateOptions.Builder

java.lang.Object

io.github.flink.gcp.connector.bigquery.sink.TableCreateOptions.Builder

Enclosing class:

TableCreateOptions

@Public
public static final class TableCreateOptions.Builder
extends Object

Builder for TableCreateOptions.

Method Summary

Modifier and Type	Method	Description
TableCreateOptions	build()	Builds the options.
TableCreateOptions.Builder	clusteredFields(List<String> fields)	Clusters the table on the given columns, in precedence order (at most four).
TableCreateOptions.Builder	timePartitioning(TableCreateOptions.TimePartitioningType type)	Partitions the table on ingestion time with the given granularity.
TableCreateOptions.Builder	timePartitioning(TableCreateOptions.TimePartitioningType type, String field)	Partitions the table on the given TIMESTAMP, DATE or DATETIME column with the given granularity — the three column types BigQuery partitions on.
TableCreateOptions.Builder	timePartitioningExpiration(Duration expiration)	Sets the partition expiration; partitions older than this are deleted by BigQuery.

Methods inherited from class java.lang.Object

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

Method Details

timePartitioning

public TableCreateOptions.Builder timePartitioning(TableCreateOptions.TimePartitioningType type)

Partitions the table on ingestion time with the given granularity.

Parameters:

type - the partitioning granularity

Returns:

this builder

timePartitioning

public TableCreateOptions.Builder timePartitioning(TableCreateOptions.TimePartitioningType type,
 String field)

Partitions the table on the given TIMESTAMP, DATE or DATETIME column with the given granularity — the three column types BigQuery partitions on.

Parameters:

type - the partitioning granularity

field - the column to partition on

Returns:

this builder

timePartitioningExpiration

public TableCreateOptions.Builder timePartitioningExpiration(Duration expiration)

Sets the partition expiration; partitions older than this are deleted by BigQuery. Requires time partitioning to be configured.

Parameters:

expiration - the partition expiration, at least 1 ms

Returns:

this builder

clusteredFields

public TableCreateOptions.Builder clusteredFields(List<String> fields)

Clusters the table on the given columns, in precedence order (at most four).

Parameters:

fields - the clustering columns

Returns:

this builder

build

public TableCreateOptions build()

Builds the options.

Returns:

the options