Constant Field Values

Contents

• org.apache.*

org.apache.*

org.apache.heron.kafka.bolt.KafkaBolt<K,V>

Modifier and Type	Constant Field	Value
public static final String	TOPIC	"topic"

org.apache.heron.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper<K,V>

Modifier and Type	Constant Field	Value
public static final String	BOLT_KEY	"key"
public static final String	BOLT_MESSAGE	"message"

org.apache.heron.kafka.spout.KafkaSpout<K,V>

Modifier and Type	Constant Field	Value
public static final long	TIMER_DELAY_MS	500L

org.apache.heron.kafka.spout.KafkaSpoutConfig<K,V>

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_RETRIES	2147483647
public static final int	DEFAULT_MAX_UNCOMMITTED_OFFSETS	10000000
public static final int	DEFAULT_METRICS_TIME_BUCKET_SIZE_SECONDS	60
public static final long	DEFAULT_OFFSET_COMMIT_PERIOD_MS	30000L

org.apache.heron.kafka.spout.internal.CommonKafkaSpoutConfig<K,V>

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_PARTITION_REFRESH_PERIOD_MS	2000L
public static final long	DEFAULT_POLL_TIMEOUT_MS	200L
public static final long	DEFAULT_START_TS	0L