Samza 核心类图

StreamSpec

SystemAdmin

SystemStream

- system:String- stream:String

OutgoingMessageEnvelope

- systemStream:SystemStream- keySerializerName:String- messageSerializerName:String- partitionKey:Object- key:Object- message:Object

SystemStreamMetadata

Partition

- partition: int

SystemConsumer

SystemProducer

SystemFactory

+ getProducer():SystemProcuder+ getConsumer():SystemConcumser+ getAdmin():SystemAdmin

SystemStreamPartition

- system : String- stream : String- partition : Partition

Startpoint

- creationTimestamp:long