Package org.apache.beam.sdk.io.clickhouse

Class TableSchema

java.lang.Object

org.apache.beam.sdk.io.clickhouse.TableSchema

All Implemented Interfaces:

Serializable

public abstract class TableSchema
extends Object
implements Serializable

A descriptor for ClickHouse table schema.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TableSchema.Column	A column in ClickHouse table.
static class	TableSchema.ColumnType	A descriptor for a column type.
static enum	TableSchema.DefaultType	An enumeration of possible kinds of default values in ClickHouse.
static enum	TableSchema.TypeName	An enumeration of possible types in ClickHouse.

Constructor Summary

Constructors

Constructor	Description
TableSchema()

Method Summary

Modifier and Type	Method	Description
abstract List<TableSchema.Column>	columns()
static Schema.FieldType	getEquivalentFieldType(TableSchema.ColumnType columnType)	Returns Beam equivalent of ClickHouse column type.
static Schema	getEquivalentSchema(TableSchema tableSchema)	Returns Beam equivalent of ClickHouse schema.
static TableSchema	of(TableSchema.Column... columns)

Methods inherited from class java.lang.Object

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

Constructor Details

TableSchema

public TableSchema()

Method Details

columns

public abstract List<TableSchema.Column> columns()

of

public static TableSchema of(TableSchema.Column... columns)

getEquivalentSchema

public static Schema getEquivalentSchema(TableSchema tableSchema)

Returns Beam equivalent of ClickHouse schema.

Parameters:

tableSchema - schema of ClickHouse table

Returns:

Beam schema

getEquivalentFieldType

public static Schema.FieldType getEquivalentFieldType(TableSchema.ColumnType columnType)

Returns Beam equivalent of ClickHouse column type.

Parameters:

columnType - type of ClickHouse column

Returns:

Beam field type