Package org.apache.cassandra.streaming

Class StreamDeserializingTask

java.lang.Object

org.apache.cassandra.streaming.StreamDeserializingTask

All Implemented Interfaces:

Runnable

public class StreamDeserializingTask
extends Object
implements Runnable

The task that performs the actual deserialization.

Field Summary

Fields

Modifier and Type	Field	Description
protected StreamSession	session

Constructor Summary

Constructors

Constructor	Description
StreamDeserializingTask(StreamSession session, StreamingChannel channel, int messagingVersion)

Method Summary

Modifier and Type	Method	Description
StreamSession	deriveSession(StreamMessage message)
void	run()

Methods inherited from class java.lang.Object

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

Field Details

session

protected StreamSession session

Constructor Details

StreamDeserializingTask

public StreamDeserializingTask(StreamSession session,
 StreamingChannel channel,
 int messagingVersion)

Method Details

run

public void run()

Specified by:

run in interface Runnable

deriveSession

public StreamSession deriveSession(StreamMessage message)