Uses of Class
com.clickhouse.client.ClickHouseNode

Packages that use ClickHouseNode

Package	Description
com.clickhouse.client	Provides necessary classes to communicate with ClickHouse server.

Uses of ClickHouseNode in com.clickhouse.client

Fields in com.clickhouse.client declared as ClickHouseNode

Modifier and Type	Field	Description
protected ClickHouseNode	ClickHouseNodes.template	Template node.

Fields in com.clickhouse.client with type parameters of type ClickHouseNode

Modifier and Type	Field	Description
protected LinkedList<ClickHouseNode>	ClickHouseNodes.faultyNodes	List of faulty nodes.
protected LinkedList<ClickHouseNode>	ClickHouseNodes.nodes	List of healthy nodes.
protected Function<ClickHouseNodeSelector,ClickHouseNode>	ClickHouseRequest.server
protected BiConsumer<ClickHouseNode,ClickHouseNode>	ClickHouseRequest.serverListener
protected BiConsumer<ClickHouseNode,ClickHouseNode>	ClickHouseRequest.serverListener
protected AtomicReference<ClickHouseNode>	ClickHouseRequest.serverRef

Methods in com.clickhouse.client that return ClickHouseNode

Modifier and Type	Method	Description
ClickHouseNode	ClickHouseNode.apply(ClickHouseNodeSelector t)
ClickHouseNode	ClickHouseNodes.apply(ClickHouseNodeSelector t)
ClickHouseNode	ClickHouseNode.Builder.build()	Creates a new node.
protected ClickHouseNode	ClickHouseRequest.changeServer(ClickHouseNode currentServer, ClickHouseNode newServer)
protected ClickHouseNode	ClickHouseLoadBalancingPolicy.get(ClickHouseNodes manager)	Gets next node available in the list.
protected ClickHouseNode	ClickHouseLoadBalancingPolicy.get(ClickHouseNodes manager, ClickHouseNodeSelector t)	Gets next node available in the list according to the given node selector.
protected ClickHouseNode	ClickHouseNodes.get()	Gets next node available.
protected ClickHouseNode	AbstractClient.getServer()	Gets current server.
ClickHouseNode	ClickHouseRequest.getServer()	Gets the server currently connected to.
ClickHouseNode	ClickHouseTransaction.getServer()	Gets server of the transaction.
ClickHouseNode	ClickHouseNodes.getTemplate()
static ClickHouseNode	ClickHouseNode.of(String uri)	Creates a node object using given URI.
static ClickHouseNode	ClickHouseNode.of(String uri, ClickHouseNode template)	Creates a node object using given URI and template.
static ClickHouseNode	ClickHouseNode.of(String host, ClickHouseProtocol protocol, int port, String database, String... tags)	Creates a node object in one go.
static ClickHouseNode	ClickHouseNode.of(String uri, Map<?,?> options)	Creates a node object using given URI.
static ClickHouseNode	ClickHouseNode.of(URI uri, ClickHouseNode template)	Creates a node object using given URI.
protected ClickHouseNode	ClickHouseNode.probe()
protected ClickHouseNode	ClickHouseNode.setManager(ClickHouseNodeManager m)	Sets manager for this node.
protected ClickHouseNode	ClickHouseLoadBalancingPolicy.suggest(ClickHouseNodes manager, ClickHouseNode server, Throwable failure)	Sugguests a new node as replacement of the given one in order to recover from the failure, which is usually a connection error.
ClickHouseNode	ClickHouseNodeManager.suggestNode(ClickHouseNode server, Throwable failure)	Suggests a different node in order to recover from a failure, which is usually a connection error.
ClickHouseNode	ClickHouseNodes.suggestNode(ClickHouseNode server, Throwable failure)

Methods in com.clickhouse.client that return types with arguments of type ClickHouseNode

Modifier and Type	Method	Description
List<ClickHouseNode>	ClickHouseNodeManager.getFaultyNodes()	Gets a copy of faulty nodes.
List<ClickHouseNode>	ClickHouseNodeManager.getFaultyNodes(ClickHouseNodeSelector selector, int groupSize)	Gets a copy of filtered faulty nodes.
List<ClickHouseNode>	ClickHouseNodes.getFaultyNodes()
List<ClickHouseNode>	ClickHouseNodes.getFaultyNodes(ClickHouseNodeSelector selector, int groupSize)
List<ClickHouseNode>	ClickHouseNodeManager.getNodes()	Gets a copy of nodes, which in most cases are in healthy status.
List<ClickHouseNode>	ClickHouseNodeManager.getNodes(ClickHouseNodeSelector selector, int groupSize)	Gets a copy of filtered nodes.
List<ClickHouseNode>	ClickHouseNodes.getNodes()
List<ClickHouseNode>	ClickHouseNodes.getNodes(ClickHouseNodeSelector selector, int groupSize)
BiConsumer<ClickHouseNode,ClickHouseNode>	ClickHouseRequest.getServerListener()
BiConsumer<ClickHouseNode,ClickHouseNode>	ClickHouseRequest.getServerListener()

Methods in com.clickhouse.client with parameters of type ClickHouseNode

Modifier and Type	Method	Description
static ClickHouseNode.Builder	ClickHouseNode.builder(ClickHouseNode base)	Gets builder for creating a new node based on the given one.
protected ClickHouseNode	ClickHouseRequest.changeServer(ClickHouseNode currentServer, ClickHouseNode newServer)
protected boolean	AbstractClient.checkConnection(T connection, ClickHouseNode requestServer, ClickHouseNode currentServer, ClickHouseRequest<?> request)	Checks if the underlying connection can be reused.
protected abstract boolean	AbstractClient.checkHealth(ClickHouseNode server, int timeout)
ClickHouseRequest<?>	AbstractClient.connect(ClickHouseNode node)
default ClickHouseRequest<?>	ClickHouseClient.connect(ClickHouseNode node)	Connects to a ClickHouse server.
ClickHouseTransaction	ClickHouseRequestManager.createTransaction(ClickHouseNode server, int timeout)	Creates a new transaction.
static CompletableFuture<ClickHouseResponseSummary>	ClickHouseClient.dump(ClickHouseNode server, String tableOrQuery, ClickHouseFile file)	Dumps a table or query result from server into a file.
static CompletableFuture<ClickHouseResponseSummary>	ClickHouseClient.dump(ClickHouseNode server, String tableOrQuery, ClickHouseFormat format, ClickHouseCompression compression, OutputStream output)	Dumps a table or query result from server into output stream.
static CompletableFuture<ClickHouseResponseSummary>	ClickHouseClient.dump(ClickHouseNode server, String tableOrQuery, ClickHouseFormat format, ClickHouseCompression compression, String file)	Dumps a table or query result from server into a file.
static ClickHouseException	ClickHouseException.forCancellation(Exception e, ClickHouseNode server)	Creates an exception for cancellation.
boolean	ClickHouseNode.isSameEndpoint(ClickHouseNode node)	Checks if the given node has same base URI as current one.
static CompletableFuture<ClickHouseResponseSummary>	ClickHouseClient.load(ClickHouseNode server, String table, ClickHouseFile file)	Loads data from given file into a table.
static CompletableFuture<ClickHouseResponseSummary>	ClickHouseClient.load(ClickHouseNode server, String table, ClickHouseFormat format, ClickHouseCompression compression, ClickHouseWriter writer)	Loads data from a custom writer into a table using specified format and compression algorithm.
static CompletableFuture<ClickHouseResponseSummary>	ClickHouseClient.load(ClickHouseNode server, String table, ClickHouseFormat format, ClickHouseCompression compression, InputStream input)	Loads data from input stream into a table using specified format and compression algorithm.
static CompletableFuture<ClickHouseResponseSummary>	ClickHouseClient.load(ClickHouseNode server, String table, ClickHouseFormat format, ClickHouseCompression compression, String file)	Loads data from a file into table using specified format and compression algorithm.
boolean	ClickHouseNodeSelector.match(ClickHouseNode node)	Checks if the given node matches any of preferred protocols and tags.
protected abstract T	AbstractClient.newConnection(T connection, ClickHouseNode server, ClickHouseRequest<?> request)	Creates a new connection and optionally close existing connection.
static ClickHouseCluster	ClickHouseCluster.of(ClickHouseNode node, ClickHouseNode... more)	Creates cluster object from list of nodes.
static ClickHouseCluster	ClickHouseCluster.of(String cluster, ClickHouseNode node, ClickHouseNode... more)	Creates cluster object from list of nodes.
static ClickHouseException	ClickHouseException.of(String message, ClickHouseNode server)	Creates an exception to encapsulate the given error message.
static ClickHouseException	ClickHouseException.of(Throwable e, ClickHouseNode server)	Creates an exception to encapsulate cause of the given exception.
static ClickHouseNode	ClickHouseNode.of(String uri, ClickHouseNode template)	Creates a node object using given URI and template.
static ClickHouseNode	ClickHouseNode.of(URI uri, ClickHouseNode template)	Creates a node object using given URI.
boolean	AbstractClient.ping(ClickHouseNode server, int timeout)
default boolean	ClickHouseClient.ping(ClickHouseNode server, int timeout)	Tests if the given server is alive or not.
static CompletableFuture<List<ClickHouseResponseSummary>>	ClickHouseClient.send(ClickHouseNode server, String sql, ClickHouseValue[] templates, Object[]... params)	Sends SQL query along with template objects and raw parameters to specified server.
static CompletableFuture<List<ClickHouseResponseSummary>>	ClickHouseClient.send(ClickHouseNode server, String sql, String... more)	Sends one or more SQL queries to specified server, and execute them one by one.
static CompletableFuture<List<ClickHouseResponseSummary>>	ClickHouseClient.send(ClickHouseNode server, String sql, String[][] params)	Sends SQL query along with stringified parameters to specified server.
static CompletableFuture<List<ClickHouseResponseSummary>>	ClickHouseClient.send(ClickHouseNode server, String sql, List<ClickHouseColumn> columns, Object[]... params)	Sends SQL query along with raw parameters(e.g.
static CompletableFuture<ClickHouseResponseSummary>	ClickHouseClient.send(ClickHouseNode server, String sql, Map<String,String> params)	Sends SQL query along with stringified parameters to specified server.
protected ClickHouseNode	ClickHouseLoadBalancingPolicy.suggest(ClickHouseNodes manager, ClickHouseNode server, Throwable failure)	Sugguests a new node as replacement of the given one in order to recover from the failure, which is usually a connection error.
ClickHouseNode	ClickHouseNodeManager.suggestNode(ClickHouseNode server, Throwable failure)	Suggests a different node in order to recover from a failure, which is usually a connection error.
ClickHouseNode	ClickHouseNodes.suggestNode(ClickHouseNode server, Throwable failure)
protected void	ClickHouseLoadBalancingPolicy.update(ClickHouseNodes manager, ClickHouseNode node, ClickHouseNode.Status status)	Updates node status to one of ClickHouseNode.Status.
void	ClickHouseNodeManager.update(ClickHouseNode node, ClickHouseNode.Status status)	Updates node status to one of ClickHouseNode.Status.
void	ClickHouseNodes.update(ClickHouseNode node, ClickHouseNode.Status status)

Method parameters in com.clickhouse.client with type arguments of type ClickHouseNode

Modifier and Type	Method	Description
ClickHouseRequest<?>	AbstractClient.connect(Function<ClickHouseNodeSelector,ClickHouseNode> nodeFunc)
default ClickHouseRequest<?>	ClickHouseClient.connect(Function<ClickHouseNodeSelector,ClickHouseNode> nodeFunc)	Connects to a ClickHouse server defined by the given Function.
static ClickHouseCluster	ClickHouseCluster.of(String cluster, Collection<ClickHouseNode> nodes)
protected void	ClickHouseNodes.queryClusterNodes(Collection<ClickHouseNode> seeds, Collection<ClickHouseNode> allNodes, Collection<ClickHouseNode> newHealthyNodes, Collection<ClickHouseNode> newFaultyNodes, Collection<ClickHouseNode> useless)
SelfT	ClickHouseRequest.setServerListener(BiConsumer<ClickHouseNode,ClickHouseNode> listener)	Sets thread-safe server change listener.
SelfT	ClickHouseRequest.setServerListener(BiConsumer<ClickHouseNode,ClickHouseNode> listener)	Sets thread-safe server change listener.

Constructors in com.clickhouse.client with parameters of type ClickHouseNode

Constructor	Description
ClickHouseException(int code, String message, ClickHouseNode server)	Constructs an exception without cause.
ClickHouseException(int code, Throwable cause, ClickHouseNode server)	Constructs an exception with cause.
ClickHouseNodes(Collection<ClickHouseNode> nodes, ClickHouseNode template)	Default constructor.
ClickHouseTransaction(ClickHouseNode server, int timeout, boolean implicit)	Constructs a unique transaction in ClickHouseTransaction.ACTIVE state.
ClickHouseTransaction(ClickHouseNode server, String sessionId, int timeout, ClickHouseTransaction.XID id)	Constructs a transaction in ClickHouseTransaction.NEW state, hence ClickHouseTransaction.begin() or ClickHouseTransaction.begin(Map) must be called before commit/rollback and ClickHouseTransaction.isImplicit() is always false.

Constructor parameters in com.clickhouse.client with type arguments of type ClickHouseNode

Constructor	Description
ClickHouseCluster(String cluster, Collection<ClickHouseNode> nodes)	Constructs cluster object using policy and list of nodes.
ClickHouseNodes(Collection<ClickHouseNode> nodes, ClickHouseNode template)	Default constructor.
ClickHouseRequest(ClickHouseClient client, Function<ClickHouseNodeSelector,ClickHouseNode> server, AtomicReference<ClickHouseNode> ref, Map<ClickHouseOption,Serializable> options, boolean sealed)
ClickHouseRequest(ClickHouseClient client, Function<ClickHouseNodeSelector,ClickHouseNode> server, AtomicReference<ClickHouseNode> ref, Map<ClickHouseOption,Serializable> options, boolean sealed)