Serialized Form (heron-kafka-client 1.0.2 API)

Package org.apache.heron.kafka.bolt
- Class org.apache.heron.kafka.bolt.KafkaBolt extends BaseTickTupleAwareRichBolt implements Serializable
  
  serialVersionUID:
  
  -5205886631877033478L
  - Serialized Fields
    - producer
```
org.apache.kafka.clients.producer.Producer<K,V> producer
```
    - collector
```
org.apache.heron.api.bolt.OutputCollector collector
```
    - mapper
```
TupleToKafkaMapper<K,V> mapper
```
    - topicSelector
```
KafkaTopicSelector topicSelector
```
    - providedCallback
```
PreparableCallback providedCallback
```
    - boltSpecifiedProperties
```
Properties boltSpecifiedProperties
```
    - fireAndForget
```
boolean fireAndForget
```
      KafkaBolt#setFireAndForget(boolean) for more details on this.
    - async
```
boolean async
```
      KafkaBolt#setAsync(boolean) for more details on this.
Package org.apache.heron.kafka.bolt.mapper
- Class org.apache.heron.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper extends Object implements Serializable
  
  serialVersionUID:
  
  -8794262989021702349L
  - Serialized Fields
    - boltKeyField
```
String boltKeyField
```
    - boltMessageField
```
String boltMessageField
```
Package org.apache.heron.kafka.bolt.selector
- Class org.apache.heron.kafka.bolt.selector.DefaultTopicSelector extends Object implements Serializable
  
  serialVersionUID:
  
  4601118062437851265L
  - Serialized Fields
    - topicName
```
String topicName
```
- Class org.apache.heron.kafka.bolt.selector.FieldIndexTopicSelector extends Object implements Serializable
  
  serialVersionUID:
  
  -3830575380208166367L
  - Serialized Fields
    - fieldIndex
```
int fieldIndex
```
    - defaultTopicName
```
String defaultTopicName
```
- Class org.apache.heron.kafka.bolt.selector.FieldNameTopicSelector extends Object implements Serializable
  
  serialVersionUID:
  
  -3903708904533396833L
  - Serialized Fields
    - fieldName
```
String fieldName
```
    - defaultTopicName
```
String defaultTopicName
```
Package org.apache.heron.kafka.spout
- Class org.apache.heron.kafka.spout.ByTopicRecordTranslator extends Object implements Serializable
  
  serialVersionUID:
  
  -121699733778988688L
  - Serialized Fields
    - defaultTranslator
```
RecordTranslator<K,V> defaultTranslator
```
    - topicToTranslator
```
Map<K,V> topicToTranslator
```
    - streamToFields
```
Map<K,V> streamToFields
```
- Class org.apache.heron.kafka.spout.DefaultRecordTranslator extends Object implements Serializable
  
  serialVersionUID:
  
  -5782462870112305750L
- Class org.apache.heron.kafka.spout.EmptyKafkaTupleListener extends Object implements Serializable
- Class org.apache.heron.kafka.spout.KafkaSpout extends org.apache.heron.api.spout.BaseRichSpout implements Serializable
  
  serialVersionUID:
  
  4151921085047987154L
  - Serialized Fields
    - metricsIntervalInSecs
```
int metricsIntervalInSecs
```
    - previousKafkaMetricsUpdatedTimestamp
```
long previousKafkaMetricsUpdatedTimestamp
```
    - collector
```
org.apache.heron.api.spout.SpoutOutputCollector collector
```
    - kafkaSpoutConfig
```
KafkaSpoutConfig<K,V> kafkaSpoutConfig
```
    - kafkaConsumerFactory
```
ConsumerFactory<K,V> kafkaConsumerFactory
```
    - topicAssigner
```
TopicAssigner topicAssigner
```
- Class org.apache.heron.kafka.spout.KafkaSpoutConfig extends CommonKafkaSpoutConfig<K,V> implements Serializable
  
  serialVersionUID:
  
  141902646130682494L
  - Serialized Fields
    - offsetCommitPeriodMs
```
long offsetCommitPeriodMs
```
    - maxUncommittedOffsets
```
int maxUncommittedOffsets
```
    - retryService
```
KafkaSpoutRetryService retryService
```
    - tupleListener
```
KafkaTupleListener tupleListener
```
    - emitNullTuples
```
boolean emitNullTuples
```
    - processingGuarantee
```
KafkaSpoutConfig.ProcessingGuarantee processingGuarantee
```
    - tupleTrackingEnforced
```
boolean tupleTrackingEnforced
```
    - metricsTimeBucketSizeInSecs
```
int metricsTimeBucketSizeInSecs
```
- Class org.apache.heron.kafka.spout.KafkaSpoutMessageId extends Object implements Serializable
  - Serialized Fields
    - topicPart
```
org.apache.kafka.common.TopicPartition topicPart
```
    - offset
```
long offset
```
    - numFails
```
int numFails
```
    - nullTuple
```
boolean nullTuple
```
      false if the record was emitted using a form of collector.emit(...). true when skipping null tuples as configured by the user in KafkaSpoutConfig
- Class org.apache.heron.kafka.spout.KafkaSpoutRetryExponentialBackoff extends Object implements Serializable
  - Serialized Fields
    - initialDelay
```
KafkaSpoutRetryExponentialBackoff.TimeInterval initialDelay
```
    - delayPeriod
```
KafkaSpoutRetryExponentialBackoff.TimeInterval delayPeriod
```
    - maxDelay
```
KafkaSpoutRetryExponentialBackoff.TimeInterval maxDelay
```
    - maxRetries
```
int maxRetries
```
    - retrySchedules
```
Set<E> retrySchedules
```
    - toRetryMsgs
```
Set<E> toRetryMsgs
```
- Class org.apache.heron.kafka.spout.KafkaSpoutRetryExponentialBackoff.TimeInterval extends Object implements Serializable
  - Serialized Fields
    - lengthNanos
```
long lengthNanos
```
    - timeUnit
```
TimeUnit timeUnit
```
    - length
```
long length
```
- Class org.apache.heron.kafka.spout.KafkaTuple extends org.apache.heron.api.tuple.Values implements Serializable
  
  serialVersionUID:
  
  4803794470450587992L
  - Serialized Fields
    - stream
```
String stream
```
- Class org.apache.heron.kafka.spout.SimpleRecordTranslator extends Object implements Serializable
  
  serialVersionUID:
  
  4678369144122009596L
  - Serialized Fields
    - fields
```
org.apache.heron.api.tuple.Fields fields
```
    - func
```
Func<V,R> func
```
    - stream
```
String stream
```
Package org.apache.heron.kafka.spout.internal
- Class org.apache.heron.kafka.spout.internal.CommonKafkaSpoutConfig extends Object implements Serializable
  - Serialized Fields
    - kafkaProps
```
Map<K,V> kafkaProps
```
    - topicFilter
```
TopicFilter topicFilter
```
    - topicPartitioner
```
ManualPartitioner topicPartitioner
```
    - pollTimeoutMs
```
long pollTimeoutMs
```
    - translator
```
RecordTranslator<K,V> translator
```
    - firstPollOffsetStrategy
```
FirstPollOffsetStrategy firstPollOffsetStrategy
```
    - partitionRefreshPeriodMs
```
long partitionRefreshPeriodMs
```
    - startTimeStamp
```
long startTimeStamp
```
- Class org.apache.heron.kafka.spout.internal.ConsumerFactoryDefault extends Object implements Serializable
Package org.apache.heron.kafka.spout.subscription
- Class org.apache.heron.kafka.spout.subscription.NamedTopicFilter extends Object implements Serializable
  - Serialized Fields
    - topics
```
Set<E> topics
```
- Class org.apache.heron.kafka.spout.subscription.PatternTopicFilter extends Object implements Serializable
  - Serialized Fields
    - pattern
```
Pattern pattern
```
    - topics
```
Set<E> topics
```
- Class org.apache.heron.kafka.spout.subscription.RoundRobinManualPartitioner extends Object implements Serializable
- Class org.apache.heron.kafka.spout.subscription.TopicAssigner extends Object implements Serializable
  
  serialVersionUID:
  
  5423018073527583826L

Serialized Form

Package org.apache.heron.kafka.bolt

Class org.apache.heron.kafka.bolt.KafkaBolt extends BaseTickTupleAwareRichBolt implements Serializable

Serialized Fields

producer

collector

mapper

topicSelector

providedCallback

boltSpecifiedProperties

fireAndForget

async

Package org.apache.heron.kafka.bolt.mapper

Class org.apache.heron.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper extends Object implements Serializable

Serialized Fields

boltKeyField

boltMessageField

Package org.apache.heron.kafka.bolt.selector

Class org.apache.heron.kafka.bolt.selector.DefaultTopicSelector extends Object implements Serializable

Serialized Fields

topicName

Class org.apache.heron.kafka.bolt.selector.FieldIndexTopicSelector extends Object implements Serializable

Serialized Fields

fieldIndex

defaultTopicName

Class org.apache.heron.kafka.bolt.selector.FieldNameTopicSelector extends Object implements Serializable

Serialized Fields

fieldName

defaultTopicName

Package org.apache.heron.kafka.spout

Class org.apache.heron.kafka.spout.ByTopicRecordTranslator extends Object implements Serializable

Serialized Fields

defaultTranslator

topicToTranslator

streamToFields

Class org.apache.heron.kafka.spout.DefaultRecordTranslator extends Object implements Serializable

Class org.apache.heron.kafka.spout.EmptyKafkaTupleListener extends Object implements Serializable

Class org.apache.heron.kafka.spout.KafkaSpout extends org.apache.heron.api.spout.BaseRichSpout implements Serializable

Serialized Fields

metricsIntervalInSecs

previousKafkaMetricsUpdatedTimestamp

collector

kafkaSpoutConfig

kafkaConsumerFactory

topicAssigner

Class org.apache.heron.kafka.spout.KafkaSpoutConfig extends CommonKafkaSpoutConfig<K,V> implements Serializable

Serialized Fields

offsetCommitPeriodMs

maxUncommittedOffsets

retryService

tupleListener

emitNullTuples

processingGuarantee

tupleTrackingEnforced

metricsTimeBucketSizeInSecs

Class org.apache.heron.kafka.spout.KafkaSpoutMessageId extends Object implements Serializable

Serialized Fields

topicPart

offset

numFails

nullTuple

Class org.apache.heron.kafka.spout.KafkaSpoutRetryExponentialBackoff extends Object implements Serializable

Serialized Fields

initialDelay

delayPeriod

maxDelay

maxRetries

retrySchedules

toRetryMsgs

Class org.apache.heron.kafka.spout.KafkaSpoutRetryExponentialBackoff.TimeInterval extends Object implements Serializable

Serialized Fields

lengthNanos

timeUnit

length

Class org.apache.heron.kafka.spout.KafkaTuple extends org.apache.heron.api.tuple.Values implements Serializable

Serialized Fields

stream

Class org.apache.heron.kafka.spout.SimpleRecordTranslator extends Object implements Serializable

Serialized Fields

fields