org.apache.beam.sdk.io.clickhouse

Class TableSchema.ColumnType

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

TableSchema

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

A descriptor for a column type.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static TableSchema.ColumnType	BOOL
static TableSchema.ColumnType	DATE
static TableSchema.ColumnType	DATETIME
static TableSchema.ColumnType	FLOAT32
static TableSchema.ColumnType	FLOAT64
static TableSchema.ColumnType	INT16
static TableSchema.ColumnType	INT32
static TableSchema.ColumnType	INT64
static TableSchema.ColumnType	INT8
static TableSchema.ColumnType	STRING
static TableSchema.ColumnType	TUPLE
static TableSchema.ColumnType	UINT16
static TableSchema.ColumnType	UINT32
static TableSchema.ColumnType	UINT64
static TableSchema.ColumnType	UINT8

Constructor Summary

Constructors

Constructor and Description
ColumnType()

Method Summary

Modifier and Type	Method and Description
static TableSchema.ColumnType	array(TableSchema.ColumnType arrayElementType)
abstract @Nullable TableSchema.ColumnType	arrayElementType()
static org.apache.beam.sdk.io.clickhouse.TableSchema.ColumnType.Builder	builder()
static TableSchema.ColumnType	enum16(java.util.Map<java.lang.String,java.lang.Integer> enumValues)
static TableSchema.ColumnType	enum8(java.util.Map<java.lang.String,java.lang.Integer> enumValues)
abstract @Nullable java.util.Map<java.lang.String,java.lang.Integer>	enumValues()
static TableSchema.ColumnType	fixedString(int size)
abstract @Nullable java.lang.Integer	fixedStringSize()
abstract boolean	nullable()
static TableSchema.ColumnType	nullable(TableSchema.TypeName typeName)
static TableSchema.ColumnType	of(TableSchema.TypeName typeName)
static TableSchema.ColumnType	parse(java.lang.String str) Parse string with ClickHouse type to TableSchema.ColumnType.
static java.lang.Object	parseDefaultExpression(TableSchema.ColumnType columnType, java.lang.String value) Get default value of a column based on expression.
static TableSchema.ColumnType	tuple(java.util.Map<java.lang.String,TableSchema.ColumnType> elements)
abstract @Nullable java.util.Map<java.lang.String,TableSchema.ColumnType>	tupleTypes()
abstract TableSchema.TypeName	typeName()
TableSchema.ColumnType	withNullable(boolean nullable)

Methods inherited from class java.lang.Object

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

Field Detail

DATE

public static final TableSchema.ColumnType DATE

DATETIME

public static final TableSchema.ColumnType DATETIME

FLOAT32

public static final TableSchema.ColumnType FLOAT32

FLOAT64

public static final TableSchema.ColumnType FLOAT64

INT8

public static final TableSchema.ColumnType INT8

INT16

public static final TableSchema.ColumnType INT16

INT32

public static final TableSchema.ColumnType INT32

INT64

public static final TableSchema.ColumnType INT64

STRING

public static final TableSchema.ColumnType STRING

UINT8

public static final TableSchema.ColumnType UINT8

UINT16

public static final TableSchema.ColumnType UINT16

UINT32

public static final TableSchema.ColumnType UINT32

UINT64

public static final TableSchema.ColumnType UINT64

BOOL

public static final TableSchema.ColumnType BOOL

TUPLE

public static final TableSchema.ColumnType TUPLE

Constructor Detail

ColumnType

public ColumnType()

Method Detail

nullable

public abstract boolean nullable()

typeName

public abstract TableSchema.TypeName typeName()

enumValues

public abstract @Nullable java.util.Map<java.lang.String,java.lang.Integer> enumValues()

fixedStringSize

public abstract @Nullable java.lang.Integer fixedStringSize()

arrayElementType

public abstract @Nullable TableSchema.ColumnType arrayElementType()

tupleTypes

public abstract @Nullable java.util.Map<java.lang.String,TableSchema.ColumnType> tupleTypes()

withNullable

public TableSchema.ColumnType withNullable(boolean nullable)

of

public static TableSchema.ColumnType of(TableSchema.TypeName typeName)

nullable

public static TableSchema.ColumnType nullable(TableSchema.TypeName typeName)

fixedString

public static TableSchema.ColumnType fixedString(int size)

enum8

public static TableSchema.ColumnType enum8(java.util.Map<java.lang.String,java.lang.Integer> enumValues)

enum16

public static TableSchema.ColumnType enum16(java.util.Map<java.lang.String,java.lang.Integer> enumValues)

array

public static TableSchema.ColumnType array(TableSchema.ColumnType arrayElementType)

tuple

public static TableSchema.ColumnType tuple(java.util.Map<java.lang.String,TableSchema.ColumnType> elements)

parse

public static TableSchema.ColumnType parse(java.lang.String str)

Parse string with ClickHouse type to TableSchema.ColumnType.

Parameters:

str - string representation of ClickHouse type

Returns:

type of ClickHouse column

parseDefaultExpression

public static java.lang.Object parseDefaultExpression(TableSchema.ColumnType columnType,
                                                      java.lang.String value)

Get default value of a column based on expression.

E.g., "CREATE TABLE hits(id Int32, count Int32 DEFAULT <str>)"

Parameters:

columnType - type of ClickHouse expression

value - ClickHouse expression

Returns:

value of ClickHouse expression

builder

public static org.apache.beam.sdk.io.clickhouse.TableSchema.ColumnType.Builder builder()