org.apache.beam.sdk.io.clickhouse

Class ClickHouseWriter

java.lang.Object

org.apache.beam.sdk.io.clickhouse.ClickHouseWriter

@Experimental(value=SOURCE_SINK)
public class ClickHouseWriter
extends java.lang.Object

Writes Rows and field values using ClickHouseRowBinaryStream.

Constructor Summary

Constructors

Constructor and Description
ClickHouseWriter()

Method Summary

Modifier and Type	Method and Description
static void	writeNullableValue(ru.yandex.clickhouse.util.ClickHouseRowBinaryStream stream, TableSchema.ColumnType columnType, java.lang.Object value)
static void	writeRow(ru.yandex.clickhouse.util.ClickHouseRowBinaryStream stream, TableSchema schema, Row row)
static void	writeValue(ru.yandex.clickhouse.util.ClickHouseRowBinaryStream stream, TableSchema.ColumnType columnType, java.lang.Object value)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClickHouseWriter

public ClickHouseWriter()

Method Detail

writeNullableValue

public static void writeNullableValue(ru.yandex.clickhouse.util.ClickHouseRowBinaryStream stream,
                                      TableSchema.ColumnType columnType,
                                      java.lang.Object value)
                               throws java.io.IOException

Throws:

java.io.IOException

writeValue

public static void writeValue(ru.yandex.clickhouse.util.ClickHouseRowBinaryStream stream,
                              TableSchema.ColumnType columnType,
                              java.lang.Object value)
                       throws java.io.IOException

Throws:

java.io.IOException

writeRow

public static void writeRow(ru.yandex.clickhouse.util.ClickHouseRowBinaryStream stream,
                            TableSchema schema,
                            Row row)
                     throws java.io.IOException

Throws:

java.io.IOException