TableRateLimiter.CreditFunction (samza-api 1.9.0-SNAPSHOT API)
JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev Class
Next Class
Frames
No Frames
All Classes
Summary: 
Nested | 
Field | 
Constr | 
Method
Detail: 
Field | 
Constr | 
Method
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
All Methods Instance Methods Abstract Methods Default Methods 
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
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev Class
Next Class
Frames
No Frames
All Classes
Summary: 
Nested | 
Field | 
Constr | 
Method
Detail: 
Field | 
Constr | 
Method