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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()Closes the resource.IgniteDataStreamer<KeyCacheObject,CacheObject>getStreamer()Gets the wrapped streamer.
-
-
-
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:
closein interfaceClientCloseableResource
-
getStreamer
public IgniteDataStreamer<KeyCacheObject,CacheObject> getStreamer()
Gets the wrapped streamer.- Returns:
- Wrapped streamer.
-
-