Class: TencentCloud::Ckafka::V20190819::ClickHouseParam

Inherits:
TencentCloud::Common::AbstractModel
  • Object
show all
Defined in:
lib/v20190819/models.rb

Overview

ClickHouse类型入参

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(cluster = nil, database = nil, table = nil, schema = nil, resource = nil, ip = nil, port = nil, username = nil, password = nil, servicevip = nil, uniqvpcid = nil, selfbuilt = nil, dropinvalidmessage = nil, type = nil, dropcls = nil, batchsize = nil, consumerfetchminbytes = nil, consumerfetchmaxwaitms = nil) ⇒ ClickHouseParam

Returns a new instance of ClickHouseParam.



869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
# File 'lib/v20190819/models.rb', line 869

def initialize(cluster=nil, database=nil, table=nil, schema=nil, resource=nil, ip=nil, port=nil, username=nil, password=nil, servicevip=nil, uniqvpcid=nil, selfbuilt=nil, dropinvalidmessage=nil, type=nil, dropcls=nil, batchsize=nil, consumerfetchminbytes=nil, consumerfetchmaxwaitms=nil)
  @Cluster = cluster
  @Database = database
  @Table = table
  @Schema = schema
  @Resource = resource
  @Ip = ip
  @Port = port
  @UserName = username
  @Password = password
  @ServiceVip = servicevip
  @UniqVpcId = uniqvpcid
  @SelfBuilt = selfbuilt
  @DropInvalidMessage = dropinvalidmessage
  @Type = type
  @DropCls = dropcls
  @BatchSize = batchsize
  @ConsumerFetchMinBytes = consumerfetchminbytes
  @ConsumerFetchMaxWaitMs = consumerfetchmaxwaitms
end

Instance Attribute Details

#BatchSizeObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def BatchSize
  @BatchSize
end

#ClusterObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def Cluster
  @Cluster
end

#ConsumerFetchMaxWaitMsObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def ConsumerFetchMaxWaitMs
  @ConsumerFetchMaxWaitMs
end

#ConsumerFetchMinBytesObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def ConsumerFetchMinBytes
  @ConsumerFetchMinBytes
end

#DatabaseObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def Database
  @Database
end

#DropClsObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def DropCls
  @DropCls
end

#DropInvalidMessageObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def DropInvalidMessage
  @DropInvalidMessage
end

#IpObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def Ip
  @Ip
end

#PasswordObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def Password
  @Password
end

#PortObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def Port
  @Port
end

#ResourceObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def Resource
  @Resource
end

#SchemaObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def Schema
  @Schema
end

#SelfBuiltObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def SelfBuilt
  @SelfBuilt
end

#ServiceVipObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def ServiceVip
  @ServiceVip
end

#TableObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def Table
  @Table
end

#TypeObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def Type
  @Type
end

#UniqVpcIdObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def UniqVpcId
  @UniqVpcId
end

#UserNameObject

提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。 提高该参数值,有利于减少往 ClickHouse 投递的次数,但在错误消息过多及网络不稳定等极端情况下时,可能导致频繁重试影响效率。

Parameters:

  • Cluster:

    ClickHouse的集群

  • Database:

    ClickHouse的数据库名

  • Table:

    ClickHouse的数据表名

  • Schema:

    ClickHouse的schema

  • Resource:

    实例资源

  • Ip:

    ClickHouse的连接ip

  • Port:

    ClickHouse的连接port

  • UserName:

    ClickHouse的用户名

  • Password:

    ClickHouse的密码

  • ServiceVip:

    实例vip

  • UniqVpcId:

    实例的vpcId

  • SelfBuilt:

    是否为自建集群

  • DropInvalidMessage:

    ClickHouse是否抛弃解析失败的消息,默认为true

  • Type:

    ClickHouse 类型,emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""

  • DropCls:

    当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效

  • BatchSize:

    每批次投递到 ClickHouse 表消息数量,默认为 1000 条。

  • ConsumerFetchMinBytes:

    每次从 topic 中拉取消息大小,默认为 1MB,即至少要从 topic 中批量拉取 1MB 消息,才进行数据投递到 ClickHouse 操作。

  • ConsumerFetchMaxWaitMs:

    每次从 topic 拉取消息最大等待时间,当超过当前最大等待时间时,即使没有拉取到 ConsumerFetchMinBytes 大小,也将进行 ClickHouse 投递操作。



867
868
869
# File 'lib/v20190819/models.rb', line 867

def UserName
  @UserName
end

Instance Method Details

#deserialize(params) ⇒ Object



890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
# File 'lib/v20190819/models.rb', line 890

def deserialize(params)
  @Cluster = params['Cluster']
  @Database = params['Database']
  @Table = params['Table']
  unless params['Schema'].nil?
    @Schema = []
    params['Schema'].each do |i|
      clickhouseschema_tmp = ClickHouseSchema.new
      clickhouseschema_tmp.deserialize(i)
      @Schema << clickhouseschema_tmp
    end
  end
  @Resource = params['Resource']
  @Ip = params['Ip']
  @Port = params['Port']
  @UserName = params['UserName']
  @Password = params['Password']
  @ServiceVip = params['ServiceVip']
  @UniqVpcId = params['UniqVpcId']
  @SelfBuilt = params['SelfBuilt']
  @DropInvalidMessage = params['DropInvalidMessage']
  @Type = params['Type']
  unless params['DropCls'].nil?
    @DropCls = DropCls.new
    @DropCls.deserialize(params['DropCls'])
  end
  @BatchSize = params['BatchSize']
  @ConsumerFetchMinBytes = params['ConsumerFetchMinBytes']
  @ConsumerFetchMaxWaitMs = params['ConsumerFetchMaxWaitMs']
end