object BufferConfig
Duplicates the static factory methods inside the Java interface org.apache.kafka.streams.kstream.Suppressed.BufferConfig.
- Alphabetic
- By Inheritance
- BufferConfig
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def maxBytes(byteLimit: Long): EagerBufferConfig
Create a size-constrained buffer in terms of the maximum number of bytes it will use.
Create a size-constrained buffer in terms of the maximum number of bytes it will use.
- byteLimit
maximum number of bytes to buffer.
- returns
size-constrained buffer in terms of the maximum number of bytes it will use.
- See also
org.apache.kafka.streams.kstream.Suppressed.BufferConfig.maxBytes
- def maxRecords(recordLimit: Long): EagerBufferConfig
Create a size-constrained buffer in terms of the maximum number of keys it will store.
Create a size-constrained buffer in terms of the maximum number of keys it will store.
- recordLimit
maximum number of keys to buffer.
- returns
size-constrained buffer in terms of the maximum number of keys it will store.
- See also
org.apache.kafka.streams.kstream.Suppressed.BufferConfig.maxRecords
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def unbounded(): StrictBufferConfig
Create a buffer unconstrained by size (either keys or bytes).
Create a buffer unconstrained by size (either keys or bytes).
As a result, the buffer will consume as much memory as it needs, dictated by the time bound.
If there isn't enough heap available to meet the demand, the application will encounter an OutOfMemoryError and shut down (not guaranteed to be a graceful exit). Also, note that JVM processes under extreme memory pressure may exhibit poor GC behavior.
This is a convenient option if you doubt that your buffer will be that large, but also don't wish to pick particular constraints, such as in testing.
This buffer is "strict" in the sense that it will enforce the time bound or crash. It will never emit early.
- returns
a buffer unconstrained by size (either keys or bytes).
- See also
org.apache.kafka.streams.kstream.Suppressed.BufferConfig.unbounded
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()