LogAppendInfo

Struct to hold various quantities we compute about each message set before appending to the log

firstOffset: The first offset in the message set
lastOffset: The last offset in the message set
sourceCodec: The source codec used in the message set (send by the producer)
targetCodec: The target codec of the message set(after applying the broker compression configuration if any)
shallowCount: The number of shallow messages
validBytes: The number of valid bytes
offsetsMonotonic: Are the offsets in this message set monotonically increasing

Linear Supertypes

Serializable, Serializable, Product, Equals, AnyRef, Any

Instance Constructors

new LogAppendInfo(firstOffset: Long, lastOffset: Long, sourceCodec: CompressionCodec, targetCodec: CompressionCodec, shallowCount: Int, validBytes: Int, offsetsMonotonic: Boolean)

firstOffset
The first offset in the message set
lastOffset
The last offset in the message set
sourceCodec
The source codec used in the message set (send by the producer)
targetCodec
The target codec of the message set(after applying the broker compression configuration if any)
shallowCount
The number of shallow messages
validBytes
The number of valid bytes
offsetsMonotonic
Are the offsets in this message set monotonically increasing

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
var firstOffset: Long

The first offset in the message set
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
var lastOffset: Long

The last offset in the message set
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
val offsetsMonotonic: Boolean

Are the offsets in this message set monotonically increasing
val shallowCount: Int

The number of shallow messages
val sourceCodec: CompressionCodec

The source codec used in the message set (send by the producer)
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
val targetCodec: CompressionCodec

The target codec of the message set(after applying the broker compression configuration if any)
val validBytes: Int

The number of valid bytes
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

Related Docs: object LogAppendInfo | package log

case class LogAppendInfo(firstOffset: Long, lastOffset: Long, sourceCodec: CompressionCodec, targetCodec: CompressionCodec, shallowCount: Int, validBytes: Int, offsetsMonotonic: Boolean) extends Product with Serializable

Instance Constructors

new LogAppendInfo(firstOffset: Long, lastOffset: Long, sourceCodec: CompressionCodec, targetCodec: CompressionCodec, shallowCount: Int, validBytes: Int, offsetsMonotonic: Boolean)

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

final def eq(arg0: AnyRef): Boolean

def finalize(): Unit

var firstOffset: Long

final def getClass(): Class[_]

final def isInstanceOf[T0]: Boolean

var lastOffset: Long

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

val offsetsMonotonic: Boolean

val shallowCount: Int

val sourceCodec: CompressionCodec

final def synchronized[T0](arg0: ⇒ T0): T0

val targetCodec: CompressionCodec

val validBytes: Int

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped