THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
For the low level api once user runs the job, users can assert data from any streams the job uses. Whereas Samza fluent api does job chaining hence only the final expected output can be compared in this case. StreamAssert spins up a consumer for the system under test, gets the messages in the stream and compares this result with the expected value. Various assertion functions provided are:
| StreamAssert | StateAssert |
|---|---|
| contains | contains |
| containsInAnyOrder | satisfies |
| inWindowPane | |
| satifies |
...
| Code Block | ||||||
|---|---|---|---|---|---|---|
| ||||||
/**
* CollectionStream provides utilities to build an in memory input stream of collections(list, map). It also supports initialization of
* multiple partitions for an input stream
*/
public class CollectionStream<T> {
// Create an empty stream that a Samza task can produce to
public static <T> CollectionStream<T> empty(String steamId) {...}
// Create a stream of messages from input list with single partition
public static <T> CollectionStream<T> of(String steamId, Iterable<T> collection){...}
// Create a stream of messages from input list with multiple partition, key of partitions map is partitionId
public static <T> CollectionStream<T> of(String steamId, Map<Integer,Iterable>Iterable<T>> partitions){...}
}
|
| Code Block | ||||||
|---|---|---|---|---|---|---|
| ||||||
/**
* EventStream provides utilities to build an in memory input stream of events. It helps mimic run time environment of your job,
* advancing time for windowing functions
*/
public class EventStream<T> {
public static abstract class Builder<T> {
public abstract Builder addElement();
public abstract Builder addException();
public abstract Builder advanceTimeTo(long time);
public abstract EventStream<T> build();
}
public static <T> Builder<T> builder() {...}
} |
...