@Experimental(value=SOURCE_SINK) public abstract class TableSchema extends java.lang.Object implements java.io.Serializable
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 and Description |
---|
TableSchema() |
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) |
public abstract java.util.List<TableSchema.Column> columns()
public static TableSchema of(TableSchema.Column... columns)
public static Schema getEquivalentSchema(TableSchema tableSchema)
tableSchema
- schema of ClickHouse tablepublic static Schema.FieldType getEquivalentFieldType(TableSchema.ColumnType columnType)
columnType
- type of ClickHouse column