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

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.