Package org.apache.ignite.stream

## Interface StreamReceiver<K,​V>

- All Superinterfaces:
    `Serializable`
  All Known Implementing Classes:
    `StreamTransformer`, `StreamVisitor`

      public interface StreamReceiver<K,​V>
      extends Serializable

  Updates cache with batch of entries. Usually it is enough to configure `IgniteDataStreamer.allowOverwrite(boolean)` property and appropriate internal cache receiver will be chosen automatically. But in some cases to achieve best performance custom user-defined implementation may help.

  Data streamer can be configured to use custom implementation of the receiver instead of default one using `IgniteDataStreamer.receiver(StreamReceiver)` method.

- - ### Method Summary

    All Methods Instance Methods Abstract Methods
    Modifier and Type | Method | Description
    --- | --- | ---
    `void` | `receive​(IgniteCache<K,​V> cache, Collection<Map.Entry<K,​V>> entries)` | Updates cache with batch of entries.

- - ### Method Detail

    - #### receive

          void receive​(IgniteCache<K,​V> cache,
                       Collection<Map.Entry<K,​V>> entries)
                throws IgniteException

      Updates cache with batch of entries.
      Parameters:
        `cache` - Cache.
        `entries` - Collection of entries.
      Throws:
        `IgniteException` - If failed.