org.apache.beam.sdk.io.clickhouse

Class TableSchema

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

public abstract class TableSchema
extends java.lang.Object
implements java.io.Serializable

A descriptor for ClickHouse table schema.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
TableSchema()

Method Summary

Modifier and Type	Method and Description
abstract java.util.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 Detail

TableSchema

public TableSchema()

Method Detail

columns

public abstract java.util.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