Package org.apache.cassandra.io.sstable

Class SSTableLoader.Client

java.lang.Object

org.apache.cassandra.io.sstable.SSTableLoader.Client

Direct Known Subclasses:

NativeSSTableLoaderClient

Enclosing class:

SSTableLoader

public abstract static class SSTableLoader.Client
extends Object

Constructor Summary

Constructors

Constructor	Description
Client()

Method Summary

Modifier and Type	Method	Description
protected void	addRangeForEndpoint(Range<Token> range, InetAddressAndPort endpoint)
StreamingChannel.Factory	getConnectionFactory()	Provides connection factory.
Map<InetAddressAndPort,Collection<Range<Token>>>	getEndpointToRangesMap()
abstract TableMetadataRef	getTableMetadata(String tableName)	Validate that keyspace is an existing keyspace and cfName one of its existing column family.
abstract void	init(String keyspace)	Initialize the client.
void	setTableMetadata(TableMetadataRef cfm)
void	stop()	Stop the client.

Methods inherited from class java.lang.Object

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

Constructor Details

Client

public Client()

Method Details

init

public abstract void init(String keyspace)

Initialize the client. Perform any step necessary so that after the call to the this method: * partitioner is initialized * getEndpointToRangesMap() returns a correct map This method is guaranteed to be called before any other method of a client.

stop

public void stop()

Stop the client.

getConnectionFactory

public StreamingChannel.Factory getConnectionFactory()

Provides connection factory. By default, it uses DefaultConnectionFactory.

Returns:

StreamConnectionFactory to use

getTableMetadata

public abstract TableMetadataRef getTableMetadata(String tableName)

Validate that keyspace is an existing keyspace and cfName one of its existing column family.

setTableMetadata

public void setTableMetadata(TableMetadataRef cfm)

getEndpointToRangesMap

public Map<InetAddressAndPort,Collection<Range<Token>>> getEndpointToRangesMap()

addRangeForEndpoint

protected void addRangeForEndpoint(Range<Token> range,
 InetAddressAndPort endpoint)