org.apache.samza.table.remote

Interface TableRateLimiter.CreditFunction<K,V>

Type Parameters:

K - the type of the key

V - the type of the value

All Superinterfaces:

java.io.Serializable

Enclosing class:

TableRateLimiter<K,V>

@InterfaceStability.Unstable
public static interface TableRateLimiter.CreditFunction<K,V>
extends java.io.Serializable

Function interface for providing rate limiting credits for each table record. This interface allows callers to pass in lambda expressions which are otherwise non-serializable as-is.

Method Summary

Modifier and Type	Method and Description
int	getCredits(K key, V value) Get the number of credits required for the key and value pair.

Method Detail

getCredits

int getCredits(K key,
               V value)

Get the number of credits required for the key and value pair.

Parameters:

key - table key

value - table record

Returns:

number of credits