Package org.apache.ignite.internal.processors.platform.client.streamer

Class ClientDataStreamerHandle

java.lang.Object

org.apache.ignite.internal.processors.platform.client.streamer.ClientDataStreamerHandle

All Implemented Interfaces:

ClientCloseableResource

public class ClientDataStreamerHandle
extends Object
implements ClientCloseableResource

Streamer handle.

Constructor Summary

Constructors

Constructor	Description
ClientDataStreamerHandle(IgniteDataStreamer<KeyCacheObject,CacheObject> streamer)	Ctor.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the resource.
IgniteDataStreamer<KeyCacheObject,CacheObject>	getStreamer()	Gets the wrapped streamer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClientDataStreamerHandle

public ClientDataStreamerHandle(IgniteDataStreamer<KeyCacheObject,CacheObject> streamer)

Ctor.

Parameters:

streamer - Streamer instance.

Method Detail

close

public void close()

Closes the resource.

Specified by:

close in interface ClientCloseableResource

getStreamer

public IgniteDataStreamer<KeyCacheObject,CacheObject> getStreamer()

Gets the wrapped streamer.

Returns:

Wrapped streamer.