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

Class ClientDataStreamerStartRequest

java.lang.Object

org.apache.ignite.internal.processors.platform.client.ClientRequest

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

All Implemented Interfaces:

ClientListenerRequest

public class ClientDataStreamerStartRequest
extends ClientRequest

Starts the data streamer.

Field Summary

Fields inherited from interface org.apache.ignite.internal.processors.odbc.ClientListenerRequest

HANDSHAKE

Constructor Summary

Constructors

Constructor	Description
ClientDataStreamerStartRequest(BinaryReaderExImpl reader)	Ctor.

Method Summary

Modifier and Type	Method	Description
protected ClientResponse	getInvalidNodeStateResponse()	Returns invalid node state response.
ClientResponse	process(ClientConnectionContext ctx)	Processes the request.

Methods inherited from class org.apache.ignite.internal.processors.platform.client.ClientRequest

isAsync, processAsync, requestId

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.odbc.ClientListenerRequest

beforeStartupRequest

Constructor Detail

ClientDataStreamerStartRequest

public ClientDataStreamerStartRequest(BinaryReaderExImpl reader)

Ctor.

Parameters:

reader - Data reader.

Method Detail

process

public ClientResponse process(ClientConnectionContext ctx)

Processes the request.

Overrides:

process in class ClientRequest

Returns:

Response.

getInvalidNodeStateResponse

protected ClientResponse getInvalidNodeStateResponse()

Returns invalid node state response.

Returns:

Invalid node state response.