org.apache.samza.table.batching

Class BatchProvider<K,V>

java.lang.Object

org.apache.samza.table.batching.BatchProvider<K,V>

All Implemented Interfaces:

java.io.Serializable, TablePart

public abstract class BatchProvider<K,V>
extends java.lang.Object
implements TablePart, java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BatchProvider()

Method Summary

Modifier and Type	Method and Description
abstract Batch<K,V>	getBatch()
java.time.Duration	getMaxBatchDelay()
int	getMaxBatchSize()
BatchProvider<K,V>	withMaxBatchDelay(java.time.Duration maxBatchDelay)
BatchProvider<K,V>	withMaxBatchSize(int maxBatchSize)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.samza.table.remote.TablePart

toConfig

Constructor Detail

BatchProvider

public BatchProvider()

Method Detail

getBatch

public abstract Batch<K,V> getBatch()

withMaxBatchSize

public BatchProvider<K,V> withMaxBatchSize(int maxBatchSize)

withMaxBatchDelay

public BatchProvider<K,V> withMaxBatchDelay(java.time.Duration maxBatchDelay)

getMaxBatchSize

public int getMaxBatchSize()

getMaxBatchDelay

public java.time.Duration getMaxBatchDelay()