Class and Description |
---|
StreamOperation |
TableStreamManager
The main streaming hook for a storage implementation.
|
Class and Description |
---|
IncomingStream
The counterpart of
OutgoingStream on the receiving side. |
OutgoingStream
Some subset of data to be streamed.
|
PreviewKind |
StreamManager.StreamRateLimiter |
StreamOperation |
StreamReceiver
StreamReceiver acts as a staging area for incoming data.
|
StreamSession
Handles the streaming a one or more streams to and from a specific remote node.
|
TableStreamManager
The main streaming hook for a storage implementation.
|
Class and Description |
---|
StreamEvent |
StreamEventHandler |
StreamOperation |
StreamResultFuture
A future on the result (
StreamState ) of a streaming plan. |
StreamState
Current snapshot of streaming progress.
|
Class and Description |
---|
PreviewKind |
Class and Description |
---|
StreamConnectionFactory |
StreamEvent |
StreamEventHandler |
StreamResultFuture
A future on the result (
StreamState ) of a streaming plan. |
StreamState
Current snapshot of streaming progress.
|
Class and Description |
---|
StreamManager.StreamRateLimiter |
Class and Description |
---|
PreviewKind |
SessionSummary |
StreamEvent |
StreamEventHandler |
StreamState
Current snapshot of streaming progress.
|
Class and Description |
---|
PreviewKind |
SessionSummary |
Class and Description |
---|
PreviewKind |
StreamState
Current snapshot of streaming progress.
|
Class and Description |
---|
IncomingStream
The counterpart of
OutgoingStream on the receiving side. |
OutgoingStream
Some subset of data to be streamed.
|
PreviewKind |
ProgressInfo
ProgressInfo contains stream transfer progress.
|
ProgressInfo.Direction
Direction of the stream.
|
ReplicationDoneVerbHandler |
SessionInfo
Stream session info.
|
SessionSummary |
StreamConnectionFactory |
StreamCoordinator
StreamCoordinator is a helper class that abstracts away maintaining multiple
StreamSession and ProgressInfo instances per peer. |
StreamEvent |
StreamEvent.Type |
StreamEventHandler |
StreamHook |
StreamManager
StreamManager manages currently running
StreamResultFuture s and provides status of all operation invoked. |
StreamManager.StreamRateLimiter |
StreamManagerMBean |
StreamOperation |
StreamPlan
StreamPlan is a helper class that builds StreamOperation of given configuration. |
StreamReceiver
StreamReceiver acts as a staging area for incoming data.
|
StreamReceiveTask
Task that manages receiving files for the session for certain ColumnFamily.
|
StreamRequest |
StreamResultFuture
A future on the result (
StreamState ) of a streaming plan. |
StreamSession
Handles the streaming a one or more streams to and from a specific remote node.
|
StreamSession.MessageStateSink |
StreamSession.State
State Transition:
|
StreamState
Current snapshot of streaming progress.
|
StreamSummary
Summary of streaming.
|
StreamTask
StreamTask is an abstraction of the streaming task performed over specific ColumnFamily.
|
StreamTransferTask
StreamTransferTask sends streams for a given table
|
Class and Description |
---|
StreamConnectionFactory |
StreamingMessageSender |
StreamSession
Handles the streaming a one or more streams to and from a specific remote node.
|
Class and Description |
---|
ProgressInfo
ProgressInfo contains stream transfer progress.
|
SessionInfo
Stream session info.
|
StreamEvent |
StreamEvent.SessionCompleteEvent |
StreamEventHandler |
StreamState
Current snapshot of streaming progress.
|
StreamSummary
Summary of streaming.
|
Class and Description |
---|
IncomingStream
The counterpart of
OutgoingStream on the receiving side. |
OutgoingStream
Some subset of data to be streamed.
|
PreviewKind |
StreamOperation |
StreamRequest |
StreamSession
Handles the streaming a one or more streams to and from a specific remote node.
|
StreamSummary
Summary of streaming.
|
Class and Description |
---|
DefaultConnectionFactory |
StreamConnectionFactory |
StreamManagerMBean |
StreamState
Current snapshot of streaming progress.
|
Copyright © 2009-2020 The Apache Software Foundation