THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
public interface RichInitializer<V, K> { V apply(K key); } public interface RichValueMapper<K, V, VR> { VR apply(final KV keyvalue, final VK valuekey, final RecordContext recordContext); } public interface RichValueJoiner<K, V1, V2, VR> { VR apply(final KV1 keyvalue1, final V1V2 value1value2, final V2K value2key, final RecordContext recordContext); } public interface RichKeyValueMapper<K, V, VR> { VR apply(final K key, final V value, final RecordContext recordContext); } public interface RichReducer<K, V> { V apply(final KV keyvalue1, final V value1value2, final VK value2key, final RecordContext recordContext); } public interface RichAggregator<K, V, VA> { VA apply(final K key, final V value, final VA aggregate, final RecordContext recordContext); } public interface RichForeachAction<K, V> { void apply(final K key, final V value, final RecordContext recordContext); } public interface RichPredicate<K, V> { boolean test(final K key, final V value, final RecordContext recordContext); } public interface RichMerger<K, V> { V apply(final K aggKey, final V aggOne, final V aggTwo, final RecordContext recordContext); } public interface RichValueTransformer<K, V, VR> { void init(final ProcessorContext context); VR transform(final V value); @Deprecated VR punctuate(final K key, final long timestamp); void close(); } public interface RichValueTransformerSupplier<K, V, VR> { RichValueTransformer<K, V, VR> get(); } |
...