Package org.apache.cassandra.io.sstable

Class SSTableLoader

java.lang.Object

org.apache.cassandra.io.sstable.SSTableLoader

All Implemented Interfaces:

com.google.common.util.concurrent.FutureCallback<StreamState>, StreamEventHandler

public class SSTableLoader
extends Object
implements StreamEventHandler

Cassandra SSTable bulk loader. Load an externally created sstable into a cluster.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SSTableLoader.Client

Constructor Summary

Constructors

Constructor	Description
SSTableLoader(File directory, SSTableLoader.Client client, OutputHandler outputHandler)
SSTableLoader(File directory, SSTableLoader.Client client, OutputHandler outputHandler, int connectionsPerHost, String targetKeyspace)
SSTableLoader(File directory, SSTableLoader.Client client, OutputHandler outputHandler, int connectionsPerHost, String targetKeyspace, String targetTable)

Method Summary

Modifier and Type	Method	Description
Set<InetAddressAndPort>	getFailedHosts()
void	handleStreamEvent(StreamEvent event)	Callback for various streaming events.
void	onFailure(Throwable t)
void	onSuccess(StreamState finalState)
StreamResultFuture	stream()
StreamResultFuture	stream(Set<InetAddressAndPort> toIgnore, StreamEventHandler... listeners)

Methods inherited from class java.lang.Object

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

Constructor Details

SSTableLoader

public SSTableLoader(File directory,
 SSTableLoader.Client client,
 OutputHandler outputHandler)

SSTableLoader

public SSTableLoader(File directory,
 SSTableLoader.Client client,
 OutputHandler outputHandler,
 int connectionsPerHost,
 String targetKeyspace)

SSTableLoader

public SSTableLoader(File directory,
 SSTableLoader.Client client,
 OutputHandler outputHandler,
 int connectionsPerHost,
 String targetKeyspace,
 String targetTable)

Method Details

stream

public StreamResultFuture stream()

stream

public StreamResultFuture stream(Set<InetAddressAndPort> toIgnore,
 StreamEventHandler... listeners)

onSuccess

public void onSuccess(StreamState finalState)

Specified by:

onSuccess in interface com.google.common.util.concurrent.FutureCallback<StreamState>

onFailure

public void onFailure(Throwable t)

Specified by:

onFailure in interface com.google.common.util.concurrent.FutureCallback<StreamState>

handleStreamEvent

public void handleStreamEvent(StreamEvent event)

Description copied from interface: StreamEventHandler

Callback for various streaming events.

Specified by:

handleStreamEvent in interface StreamEventHandler

Parameters:

event - Stream event.

See Also:

• StreamEvent.Type

getFailedHosts

public Set<InetAddressAndPort> getFailedHosts()