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 java.lang.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(java.io.File directory, SSTableLoader.Client client, OutputHandler outputHandler)
SSTableLoader(java.io.File directory, SSTableLoader.Client client, OutputHandler outputHandler, int connectionsPerHost, java.lang.String targetKeyspace)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Set<InetAddressAndPort>
getFailedHosts()
void
handleStreamEvent(StreamEvent event)
Callback for various streaming events.void
onFailure(java.lang.Throwable t)
void
onSuccess(StreamState finalState)
protected java.util.Collection<SSTableReader>
openSSTables(java.util.Map<InetAddressAndPort,java.util.Collection<Range<Token>>> ranges)
StreamResultFuture
stream()
StreamResultFuture
stream(java.util.Set<InetAddressAndPort> toIgnore, StreamEventHandler... listeners)
-
-
-
Constructor Detail
-
SSTableLoader
public SSTableLoader(java.io.File directory, SSTableLoader.Client client, OutputHandler outputHandler)
-
SSTableLoader
public SSTableLoader(java.io.File directory, SSTableLoader.Client client, OutputHandler outputHandler, int connectionsPerHost, java.lang.String targetKeyspace)
-
-
Method Detail
-
openSSTables
protected java.util.Collection<SSTableReader> openSSTables(java.util.Map<InetAddressAndPort,java.util.Collection<Range<Token>>> ranges)
-
stream
public StreamResultFuture stream()
-
stream
public StreamResultFuture stream(java.util.Set<InetAddressAndPort> toIgnore, StreamEventHandler... listeners)
-
onSuccess
public void onSuccess(StreamState finalState)
- Specified by:
onSuccess
in interfacecom.google.common.util.concurrent.FutureCallback<StreamState>
-
onFailure
public void onFailure(java.lang.Throwable t)
- Specified by:
onFailure
in interfacecom.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 interfaceStreamEventHandler
- Parameters:
event
- Stream event.- See Also:
StreamEvent.Type
-
getFailedHosts
public java.util.Set<InetAddressAndPort> getFailedHosts()
-
-