序列化表格

软件包 com.taobao.common.store.util

类 com.taobao.common.store.util.BytesKey 继承 Object 实现 Serializable

serialVersionUID: -6296965387124592707L

序列化字段

data

byte[] data

类 com.taobao.common.store.util.LRUHashMap 继承 LinkedHashMap<K,V> 实现 Serializable

serialVersionUID: 438971390573954L

序列化字段

maxCapacity

int maxCapacity

enableLRU

boolean enableLRU

软件包 com.taobao.metamorphosis

类 com.taobao.metamorphosis.AppendMessageErrorException 继承 RuntimeException 实现 Serializable

类 com.taobao.metamorphosis.Message 继承 Object 实现 Serializable

serialVersionUID: -1L

序列化字段

id

long id

topic

String topic

data

byte[] data

attribute

String attribute

flag

int flag

partition

Partition partition

软件包 com.taobao.metamorphosis.client

类 com.taobao.metamorphosis.client.MetaClientConfig 继承 Object 实现 Serializable

serialVersionUID: -1L

序列化字段

serverUrl

String serverUrl

diamondPartitionsDataId

String diamondPartitionsDataId

从diamond获取partitions配置的dataId，默认为"metamorphosis.partitions"

diamondPartitionsGroup

String diamondPartitionsGroup

从diamond获取partitions配置的group，默认为DEFAULT_GROUP

zkConfig

ZkUtils.ZKConfig zkConfig

recoverMessageIntervalInMills

long recoverMessageIntervalInMills

recover本地消息的时间间隔

recoverThreadCount

int recoverThreadCount

partitionsInfo

Properties partitionsInfo

类 com.taobao.metamorphosis.client.StatsResult 继承 Object 实现 Serializable

serialVersionUID: -778206989144188141L

序列化字段

result

Map<K,V> result

软件包 com.taobao.metamorphosis.client.consumer

类 com.taobao.metamorphosis.client.consumer.ConsumerConfig 继承 MetaClientConfig 实现 Serializable

serialVersionUID: -1L

序列化字段

fetchRunnerCount

int fetchRunnerCount

maxDelayFetchTimeInMills

long maxDelayFetchTimeInMills

maxDelayFetchTimeWhenExceptionInMills

long maxDelayFetchTimeWhenExceptionInMills

已过时。

fetchTimeoutInMills

long fetchTimeoutInMills

consumerId

String consumerId

partition

String partition

offset

long offset

group

String group

commitOffsetPeriodInMills

long commitOffsetPeriodInMills

maxFetchRetries

int maxFetchRetries

alwaysConsumeFromMaxOffset

boolean alwaysConsumeFromMaxOffset

loadBalanceStrategyType

LoadBalanceStrategy.Type loadBalanceStrategyType

maxIncreaseFetchDataRetries

int maxIncreaseFetchDataRetries

类 com.taobao.metamorphosis.client.consumer.TopicPartitionRegInfo 继承 Object 实现 Serializable

serialVersionUID: -1L

序列化字段

topic

String topic

partition

Partition partition

offset

AtomicLong offset

messageId

long messageId

modified

boolean modified

软件包 com.taobao.metamorphosis.client.consumer.storage

类 com.taobao.metamorphosis.client.consumer.storage.JDBCUtils.CannotGetConnectionException 继承 RuntimeException 实现 Serializable

serialVersionUID: -1L

软件包 com.taobao.metamorphosis.client.extension.producer

类 com.taobao.metamorphosis.client.extension.producer.AsyncMetaMessageProducer.MetaMessageOverflowException 继承 com.taobao.gecko.service.exception.NotifyRemotingException 实现 Serializable

serialVersionUID: -1842231102008256662L

类 com.taobao.metamorphosis.client.extension.producer.AvailablePartitionNumException 继承 MetaClientException 实现 Serializable

serialVersionUID: 8087499474643513774L

软件包 com.taobao.metamorphosis.cluster

类 com.taobao.metamorphosis.cluster.Partition 继承 Object 实现 Serializable

serialVersionUID: -1L

序列化字段

brokerId

int brokerId

partition

int partition

partStr

String partStr

attributes

ConcurrentHashMap<K,V> attributes

软件包 com.taobao.metamorphosis.cluster.json

类 com.taobao.metamorphosis.cluster.json.TopicBroker 继承 Object 实现 Serializable

serialVersionUID: 1L

序列化字段

numParts

int numParts

broker

String broker

软件包 com.taobao.metamorphosis.exception

类 com.taobao.metamorphosis.exception.GetRecoverStorageErrorException 继承 RuntimeException 实现 Serializable

serialVersionUID: 1L

类 com.taobao.metamorphosis.exception.InvalidBrokerException 继承 RuntimeException 实现 Serializable

serialVersionUID: -1L

类 com.taobao.metamorphosis.exception.InvalidCheckSumException 继承 IllegalArgumentException 实现 Serializable

serialVersionUID: 1L

类 com.taobao.metamorphosis.exception.InvalidConsumerConfigException 继承 IllegalArgumentException 实现 Serializable

serialVersionUID: 1L

类 com.taobao.metamorphosis.exception.InvalidMessageException 继承 MetaClientException 实现 Serializable

serialVersionUID: -1L

类 com.taobao.metamorphosis.exception.InvalidOffsetStorageException 继承 IllegalArgumentException 实现 Serializable

serialVersionUID: 1L

类 com.taobao.metamorphosis.exception.InvalidSystemClock 继承 RuntimeException 实现 Serializable

类 com.taobao.metamorphosis.exception.MetaClientException 继承 Exception 实现 Serializable

serialVersionUID: -1L

类 com.taobao.metamorphosis.exception.MetaCodecException 继承 RuntimeException 实现 Serializable

serialVersionUID: -1L

类 com.taobao.metamorphosis.exception.MetaOpeartionTimeoutException 继承 MetaClientException 实现 Serializable

serialVersionUID: -1L

类 com.taobao.metamorphosis.exception.NetworkException 继承 MetaClientException 实现 Serializable

serialVersionUID: 1L

类 com.taobao.metamorphosis.exception.TransactionInProgressException 继承 MetaClientException 实现 Serializable

serialVersionUID: -1L

类 com.taobao.metamorphosis.exception.UnknowCodecTypeException 继承 RuntimeException 实现 Serializable

serialVersionUID: 1L

软件包 com.taobao.metamorphosis.metaslave

类 com.taobao.metamorphosis.metaslave.SubscribeMasterMessageException 继承 RuntimeException 实现 Serializable

serialVersionUID: 3449735809236405427L

软件包 com.taobao.metamorphosis.server.exception

类 com.taobao.metamorphosis.server.exception.IllegalTopicException 继承 RuntimeException 实现 Serializable

类 com.taobao.metamorphosis.server.exception.MetamorphosisException 继承 Exception 实现 Serializable

类 com.taobao.metamorphosis.server.exception.MetamorphosisServerStartupException 继承 RuntimeException 实现 Serializable

serialVersionUID: -1L

类 com.taobao.metamorphosis.server.exception.ServiceStartupException 继承 RuntimeException 实现 Serializable

类 com.taobao.metamorphosis.server.exception.UnknownDeletePolicyException 继承 RuntimeException 实现 Serializable

serialVersionUID: 4426831758552509034L

类 com.taobao.metamorphosis.server.exception.WrongPartitionException 继承 IllegalArgumentException 实现 Serializable

软件包 com.taobao.metamorphosis.server.transaction

类 com.taobao.metamorphosis.server.transaction.LocalTransaction 继承 Transaction 实现 Serializable

serialVersionUID: 3488724356970710207L

序列化字段

xid

LocalTransactionId xid

类 com.taobao.metamorphosis.server.transaction.Transaction 继承 Object 实现 Serializable

serialVersionUID: -5907949950359568586L

序列化字段

state

byte state

类 com.taobao.metamorphosis.server.transaction.XATransaction 继承 Transaction 实现 Serializable

serialVersionUID: -7059382594250215928L

序列化字段

xid

XATransactionId xid

软件包 com.taobao.metamorphosis.server.transaction.store

类 com.taobao.metamorphosis.server.transaction.store.JournalLocation 继承 Object 实现 Serializable

serialVersionUID: -1L

序列化字段

number

int number

offset

long offset

类 com.taobao.metamorphosis.server.transaction.store.TransactionCommands.AppendMessageCommand 继承 com.google.protobuf.GeneratedMessage 实现 Serializable

serialVersionUID: 0L

序列化方法

writeReplace

protected Object writeReplace()
                       throws ObjectStreamException

抛出：

ObjectStreamException

序列化字段

unknownFields

com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

messageId_

long messageId_

putCommand_

com.google.protobuf.ByteString putCommand_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

类 com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TransactionOperation 继承 com.google.protobuf.GeneratedMessage 实现 Serializable

serialVersionUID: 0L

序列化方法

writeReplace

protected Object writeReplace()
                       throws ObjectStreamException

抛出：

ObjectStreamException

序列化字段

unknownFields

com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

type_

TransactionCommands.TransactionType type_

wasPrepared_

boolean wasPrepared_

transactionId_

Object transactionId_

dataLength_

int dataLength_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

类 com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TxCommand 继承 com.google.protobuf.GeneratedMessage 实现 Serializable

serialVersionUID: 0L

序列化方法

writeReplace

protected Object writeReplace()
                       throws ObjectStreamException

抛出：

ObjectStreamException

序列化字段

unknownFields

com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

cmdType_

TransactionCommands.TxCommandType cmdType_

cmdContent_

com.google.protobuf.ByteString cmdContent_

force_

boolean force_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

软件包 com.taobao.metamorphosis.server.utils

类 com.taobao.metamorphosis.server.utils.CopyOnWriteMap 继承 Object 实现 Serializable

serialVersionUID: 788933834504546710L

序列化字段

internalMap

Map<K,V> internalMap

类 com.taobao.metamorphosis.server.utils.MetaConfig 继承 Config 实现 Serializable

serialVersionUID: -1L

序列化字段

brokerId

int brokerId

dataPath

String dataPath

serverPort

int serverPort

dashboardHttpPort

int dashboardHttpPort

hostName

String hostName

numPartitions

int numPartitions

unflushThreshold

int unflushThreshold

unflushInterval

int unflushInterval

maxSegmentSize

int maxSegmentSize

maxTransferSize

int maxTransferSize

topics

List<E> topics

slaveConfig

SlaveConfig slaveConfig

getProcessThreadCount

int getProcessThreadCount

putProcessThreadCount

int putProcessThreadCount

zkConfig

ZkUtils.ZKConfig zkConfig

deletePolicy

String deletePolicy

topicConfigMap

ConcurrentHashMap<K,V> topicConfigMap

propertyChangeSupport

PropertyChangeSupport propertyChangeSupport

lastModified

long lastModified

path

String path

appClassPath

String appClassPath

App class path.

maxCheckpoints

int maxCheckpoints

checkpointInterval

long checkpointInterval

maxTxTimeoutTimerCapacity

int maxTxTimeoutTimerCapacity

flushTxLogAtCommit

int flushTxLogAtCommit

maxTxTimeoutInSeconds

int maxTxTimeoutInSeconds

dataLogPath

String dataLogPath

deleteWhen

String deleteWhen

全局的删除crontab表达式，每天早上6点和晚上6点执行

quartzThreadCount

int quartzThreadCount

quartz使用的线程池大小

configFileChecksum

long configFileChecksum

acceptPublish

boolean acceptPublish

acceptSubscribe

boolean acceptSubscribe

stat

boolean stat

updateConsumerOffsets

boolean updateConsumerOffsets

loadMessageStoresInParallel

boolean loadMessageStoresInParallel

closedPartitionMap

Map<K,V> closedPartitionMap

类 com.taobao.metamorphosis.server.utils.SlaveConfig 继承 Config 实现 Serializable

serialVersionUID: 1L

序列化字段

slaveId

int slaveId

slaveGroup

String slaveGroup

slaveMaxDelayInMills

long slaveMaxDelayInMills

autoSyncMasterConfig

boolean autoSyncMasterConfig

软件包 com.taobao.metamorphosis.storm.scheme

类 com.taobao.metamorphosis.storm.scheme.StringScheme 继承 Object 实现 Serializable

软件包 com.taobao.metamorphosis.storm.spout

类 com.taobao.metamorphosis.storm.spout.MetaSpout 继承 backtype.storm.topology.base.BaseRichSpout 实现 Serializable

serialVersionUID: 4382748324382L

序列化字段

metaClientConfig

MetaClientConfig metaClientConfig

consumerConfig

ConsumerConfig consumerConfig

scheme

backtype.storm.spout.Scheme scheme

软件包 com.taobao.metamorphosis.tools.monitor

类 com.taobao.metamorphosis.tools.monitor.InitException 继承 Exception 实现 Serializable

serialVersionUID: 5811163916323040678L

软件包 com.taobao.metamorphosis.tools.utils

类 com.taobao.metamorphosis.tools.utils.JMXClientException 继承 Exception 实现 Serializable

serialVersionUID: -7410016800727397507L

类 com.taobao.metamorphosis.tools.utils.RemoteExecuteException 继承 RuntimeException 实现 Serializable

serialVersionUID: -7410016800727397507L

软件包 com.taobao.metamorphosis.transaction

类 com.taobao.metamorphosis.transaction.LocalTransactionId 继承 TransactionId 实现 Serializable

serialVersionUID: -8264253260623180909L

序列化字段

sessionId

String sessionId

value

long value

类 com.taobao.metamorphosis.transaction.NullTransactionId 继承 TransactionId 实现 Serializable

serialVersionUID: -4764469311016709764L

类 com.taobao.metamorphosis.transaction.TransactionId 继承 Object 实现 Serializable

serialVersionUID: 2157471469471230263L

类 com.taobao.metamorphosis.transaction.XATransactionId 继承 TransactionId 实现 Serializable

serialVersionUID: 7130168769221529970L

序列化字段

formatId

int formatId

branchQualifier

byte[] branchQualifier

globalTransactionId

byte[] globalTransactionId

uniqueQualifier

String uniqueQualifier

软件包 com.taobao.metamorphosis.utils

类 com.taobao.metamorphosis.utils.ZkUtils.ZKConfig 继承 Config 实现 Serializable

serialVersionUID: -1L

序列化字段

zkRoot

String zkRoot

zkEnable

boolean zkEnable

If enable zookeeper

zkConnect

String zkConnect

ZK host string

zkSessionTimeoutMs

int zkSessionTimeoutMs

zookeeper session timeout

zkConnectionTimeoutMs

int zkConnectionTimeoutMs

the max time that the client waits to establish a connection to zookeeper

zkSyncTimeMs

int zkSyncTimeMs

how far a ZK follower can be behind a ZK leader

软件包 com.taobao.metamorphosis.utils.monitor

类 com.taobao.metamorphosis.utils.monitor.Keys 继承 Object 实现 Serializable

serialVersionUID: 1L

序列化字段

keys

List<E> keys

key1

String key1

key2

String key2

key3

String key3

appName

String appName