SideInputsProcessor (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.storage
Interface SideInputsProcessor
All Superinterfaces:
java.io.Serializable
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface
@InterfaceStability.Unstable
public interface SideInputsProcessor
extends java.io.Serializable
The processing logic for store side inputs. Accepts incoming messages from side input streams
and the current store contents, and returns the new key-value entries to be written to the store.
Method Summary
All Methods Instance Methods Abstract Methods 
Modifier and Type
Method and Description
java.util.Collection<Entry<?,?>>
process(IncomingMessageEnvelope message,
KeyValueStore store)
Process the incoming side input message for the store.
Method Detail
process
java.util.Collection<Entry<?,?>> process(IncomingMessageEnvelope message,
KeyValueStore store)
Process the incoming side input message for the store.
Parameters:
message - incoming message envelope
store - the store associated with the incoming message envelope
Returns:
a Collection of Entrys that will be written to the store.
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