All Classes Interface Summary Class Summary Enum Summary Exception Summary
| Class |
Description |
| AbstractByteArrayInputStream |
Byte-array backed input stream.
|
| AbstractByteArrayOutputStream |
|
| AbstractByteBufferInputStream |
|
| AbstractClient<T> |
Base class for implementing a thread-safe ClickHouse client.
|
| AdaptiveQueue<E> |
|
| ArrayByteFragment |
|
| BinaryStreamUtils |
Utility class for dealing with binary stream and data.
|
| BlockingInputStream |
|
| BlockingPipedOutputStream |
|
| ByteFragment |
|
| CaffeineCache<K,V> |
Cache based on Caffeine implementation.
|
| CapacityPolicy |
|
| CapacityPolicy.FixedCapacity |
|
| CapacityPolicy.LinearDynamicCapacity |
|
| ClickHouseAggregateFunction |
|
| ClickHouseArrayValue<T> |
Wrapper class of Array.
|
| ClickHouseBigDecimalValue |
Wraper class of BigDecimal.
|
| ClickHouseBigIntegerValue |
Wraper class of BigInteger.
|
| ClickHouseBitmap |
|
| ClickHouseBitmapValue |
Wraper class of Bitmap.
|
| ClickHouseBoolValue |
Wraper class of bool.
|
| ClickHouseBufferingMode |
Supported buffering mode for dealing with request and response.
|
| ClickHouseByteArrayValue |
Wrapper of byte[].
|
| ClickHouseByteBuffer |
This class represents a slice of a byte array.
|
| ClickHouseByteValue |
Wraper class of byte.
|
| ClickHouseCache<K,V> |
Wrapper interface depicts essential methods required by a client-side cache.
|
| ClickHouseChecker |
Utility class for validation.
|
| ClickHouseCityHash |
NOTE: The code is modified to be compatible with CityHash128 used in
ClickHouse
|
| ClickHouseClient |
A unified interface defines Java client for ClickHouse.
|
| ClickHouseClientBuilder |
|
| ClickHouseClientOption |
Generic client options.
|
| ClickHouseCluster |
|
| ClickHouseColumn |
This class represents a column defined in database.
|
| ClickHouseCompression |
Supported compression algoritms.
|
| ClickHouseConfig |
|
| ClickHouseConfigChangeListener<T> |
Configuration change listener.
|
| ClickHouseCredentials |
This encapsulates access token, certificate or user name password combination
for accessing ClickHouse.
|
| ClickHouseDataProcessor |
This defines a data processor for dealing with serialization and
deserialization of one or multiple ClickHouseFormat.
|
| ClickHouseDataStreamFactory |
Factory class for creating objects to handle data stream.
|
| ClickHouseDataType |
Basic ClickHouse data types.
|
| ClickHouseDataUpdater |
|
| ClickHouseDateTimeValue |
Wraper class of LocalDateTime.
|
| ClickHouseDateValue |
Wraper class of LocalDate.
|
| ClickHouseDefaults |
System-wide default options.
|
| ClickHouseDefaultSslContextProvider |
|
| ClickHouseDeferredValue<T> |
This class represents a deferred value.
|
| ClickHouseDeserializer<T extends ClickHouseValue> |
Functional interface for deserialization.
|
| ClickHouseDnsResolver |
Default DNS resolver.
|
| ClickHouseDoubleArrayValue |
Wrapper of double[].
|
| ClickHouseDoubleValue |
Wraper class of double.
|
| ClickHouseEmptyValue |
Wrapper class of Nothing.
|
| ClickHouseEnum |
|
| ClickHouseEnumValue |
Wraper class of enum.
|
| ClickHouseException |
Exception thrown from ClickHouse server.
|
| ClickHouseExternalTable |
"Attached" temporary table.
|
| ClickHouseExternalTable.Builder |
|
| ClickHouseFile |
Wrapper of File with additional information like compression
and format.
|
| ClickHouseFloatArrayValue |
Wrapper of float[].
|
| ClickHouseFloatValue |
Wraper class of float.
|
| ClickHouseFormat |
All formats supported by ClickHouse.
|
| ClickHouseGeoMultiPolygonValue |
Wraper class of MultiPolygon.
|
| ClickHouseGeoPointValue |
Wraper class of Point.
|
| ClickHouseGeoPolygonValue |
Wraper class of Polygon.
|
| ClickHouseGeoRingValue |
Wraper class of Ring.
|
| ClickHouseHealthCheckMethod |
|
| ClickHouseInputStream |
Extended input stream for read optimization.
|
| ClickHouseInstantValue |
Wraper class of Instant.
|
| ClickHouseIntArrayValue |
Wrapper of int[].
|
| ClickHouseIntegerValue |
Wraper class of int.
|
| ClickHouseIpv4Value |
Wraper class of Inet4Address.
|
| ClickHouseIpv6Value |
Wraper class of Inet6Address.
|
| ClickHouseLoadBalancingPolicy |
Load balancing policy.
|
| ClickHouseLongArrayValue |
Wrapper of long[].
|
| ClickHouseLongValue |
Wraper class of long.
|
| ClickHouseMapValue |
|
| ClickHouseNestedValue |
Wrapper class of Nested.
|
| ClickHouseNode |
This class depicts a ClickHouse server, essentially a combination of host,
port and protocol, for client to connect.
|
| ClickHouseNode.Builder |
Mutable and non-thread safe builder.
|
| ClickHouseNode.Status |
Node status.
|
| ClickHouseNodeManager |
Node manager is responsible for managing list of nodes and their status.
|
| ClickHouseNodes |
A generic node manager for managing one or more nodes which may or may not
belong to same cluster.
|
| ClickHouseNodeSelector |
This class maintains two immutable collections: preferred protocols and tags.
|
| ClickHouseObjectValue<T> |
|
| ClickHouseOffsetDateTimeValue |
Wraper class of OffsetDateTime.
|
| ClickHouseOption |
This defines a configuration option.
|
| ClickHouseOutputStream |
Extended output stream for write optimization.
|
| ClickHouseParameterizedQuery |
A parameterized query is a parsed query with parameters being extracted for
substitution.
|
| ClickHouseParameterizedQuery.QueryPart |
A part of query.
|
| ClickHousePipedOutputStream |
SPSC(Single-producer single-consumer) channel for streaming.
|
| ClickHousePipedStream |
Deprecated.
|
| ClickHouseProtocol |
This defines protocols can be used to connect to ClickHouse.
|
| ClickHouseRecord |
This defines a record returned from ClickHouse server.
|
| ClickHouseRecordTransformer |
|
| ClickHouseRenameMethod |
Methods for renaming.
|
| ClickHouseRequest<SelfT extends ClickHouseRequest<SelfT>> |
|
| ClickHouseRequest.Mutation |
Mutation request.
|
| ClickHouseRequestManager |
Request manager is responsible for generating query and session ID, as well
as transaction creation.
|
| ClickHouseResponse |
This encapsulates a server reponse.
|
| ClickHouseResponseSummary |
Summary of ClickHouse response.
|
| ClickHouseResponseSummary.Progress |
Progress of a query.
|
| ClickHouseResponseSummary.Statistics |
Statistics of a query.
|
| ClickHouseRowBinaryProcessor |
|
| ClickHouseRowBinaryProcessor.MappedFunctions |
|
| ClickHouseSerializer<T extends ClickHouseValue> |
Functional interface for serializtion.
|
| ClickHouseShortArrayValue |
Wrapper of short[].
|
| ClickHouseShortValue |
Wraper class of short.
|
| ClickHouseSimpleRecord |
Default implementation of ClickHouseRecord,
which is simply a combination of list of columns and array of values.
|
| ClickHouseSimpleResponse |
A simple response built on top of two lists: columns and records.
|
| ClickHouseSslContextProvider |
This interface defines how to build Netty SSL context based on given
configuration and target server.
|
| ClickHouseSslMode |
Defines supported SSL mode.
|
| ClickHouseStreamResponse |
A stream response from server.
|
| ClickHouseStringValue |
Wraper class of string.
|
| ClickHouseTabSeparatedProcessor |
|
| ClickHouseTabSeparatedProcessor.MappedFunctions |
|
| ClickHouseThreadFactory |
|
| ClickHouseTransaction |
This class represents a transaction in ClickHouse.
|
| ClickHouseTransaction.XID |
This class encapsulates transaction ID, which is defined as
Tuple(snapshotVersion UInt64, localTxCounter UInt64, hostId UUID).
|
| ClickHouseTransactionException |
|
| ClickHouseTupleValue |
Wrapper class of Tuple.
|
| ClickHouseUtils |
|
| ClickHouseUuidValue |
Wraper class of string.
|
| ClickHouseValue |
Wrapper of a value returned from ClickHouse.
|
| ClickHouseValues |
Help class for dealing with values.
|
| ClickHouseVersion |
Immutable ClickHouse version, which takes the form
Year(Major).Feature(Minor).Maintenance(Patch).Build.
|
| ClickHouseWriter |
|
| DeferredInputStream |
|
| EmptyInputStream |
Empty input stream produces nothing and it can never be closed.
|
| EmptyOutputStream |
Empty output stream consumes nothing and it can never be closed.
|
| FastByteArrayInputStream |
|
| FastByteArrayOutputStream |
|
| IterableByteArrayInputStream |
|
| IterableByteBufferInputStream |
|
| IterableMultipleInputStream<T> |
|
| IterableObjectInputStream<T> |
|
| JdkLogger |
Adaptor for JDK logger.
|
| JdkLoggerFactory |
Adaptor of JDK logger factory.
|
| JdkLruCache<K,V> |
A simple thread-safe LRU cache based on LinkedHashMap.
|
| JsonStreamUtils |
Utility class for reading and writing objects in JSON format.
|
| Logger |
Unified logger.
|
| LoggerFactory |
Unified factory class to get logger.
|
| LogMessage |
Log message with arguments and/or error.
|
| Lz4InputStream |
Reader from clickhouse in lz4.
|
| Lz4OutputStream |
|
| NonBlockingInputStream |
|
| NonBlockingPipedOutputStream |
|
| Slf4jLogger |
Adaptor for slf4j logger.
|
| Slf4jLoggerFactory |
Adaptor of slf4j logger factory.
|
| SrvResolver |
|
| StreamSplitter |
We have a stream of bytes and a separator as an input.
|
| WrappedInputStream |
|
| WrappedOutputStream |
|