module CassandraConnection
Public Instance Methods
get_session(host, port, keyspace, connect_timeout, username, password)
click to toggle source
# File lib/fluent/plugin/utils/cassandra_connection.rb, line 5 def get_session(host, port, keyspace, connect_timeout, username, password) hostNode = host.split(",") if self.username cluster = ::Cassandra.cluster(hosts: hostNode, port: port, connect_timeout: connect_timeout, username: username, password: password) else cluster = ::Cassandra.cluster(hosts: hostNode, port: port, connect_timeout: connect_timeout) end cluster.connect(keyspace) end