Package com.clickhouse.client

Class ClickHouseDataStreamFactory

java.lang.Object

com.clickhouse.client.ClickHouseDataStreamFactory

public class ClickHouseDataStreamFactory
extends Object

Factory class for creating objects to handle data stream.

Constructor Summary

Constructors

Constructor	Description
ClickHouseDataStreamFactory()

Method Summary

Modifier and Type	Method	Description
ClickHousePipedStream	createPipedStream(ClickHouseConfig config)	Creates a piped stream.
static ClickHouseDataStreamFactory	getInstance()	Gets instance of the factory class.
ClickHouseDataProcessor	getProcessor(ClickHouseConfig config, ClickHouseInputStream input, OutputStream output, Map<String,Object> settings, List<ClickHouseColumn> columns)	Gets data processor according to given ClickHouseConfig and settings.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClickHouseDataStreamFactory

public ClickHouseDataStreamFactory()

Method Detail

getInstance

public static ClickHouseDataStreamFactory getInstance()

Gets instance of the factory class.

Returns:

instance of the factory class

getProcessor

public ClickHouseDataProcessor getProcessor(ClickHouseConfig config,
                                            ClickHouseInputStream input,
                                            OutputStream output,
                                            Map<String,Object> settings,
                                            List<ClickHouseColumn> columns)
                                     throws IOException

Gets data processor according to given ClickHouseConfig and settings.

Parameters:

config - non-null configuration containing information like ClickHouseFormat

input - input stream for deserialization, must not be null when output is null

output - output stream for serialization, must not be null when input is null

settings - nullable settings

columns - nullable list of columns

Returns:

data processor

Throws:

IOException - when failed to read columns from input stream

createPipedStream

public ClickHousePipedStream createPipedStream(ClickHouseConfig config)

Creates a piped stream.

Parameters:

config - non-null configuration

Returns:

piped stream