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, TablePart

Enclosing class:

TableRateLimiter<K,V>

@InterfaceStability.Unstable
public static interface TableRateLimiter.CreditFunction<K,V>
extends TablePart, 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
default int	getCredits(int opId, java.lang.Object... args) Get the number of credits required for the opId and associated args.
int	getCredits(K key, V value, java.lang.Object... args) Get the number of credits required for the key and value pair.

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

toConfig

Method Detail

getCredits

int getCredits(K key,
               V value,
               java.lang.Object... args)

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

Parameters:

key - table key

value - table record

args - additional arguments

Returns:

number of credits

getCredits

default int getCredits(int opId,
                       java.lang.Object... args)

Get the number of credits required for the opId and associated args.

Parameters:

opId - operation Id

args - additional arguments

Returns:

number of credits