Package org.apache.cassandra.streaming

Class StreamingState

java.lang.Object
org.apache.cassandra.streaming.StreamingState
All Implemented Interfaces:
com.google.common.util.concurrent.FutureCallback<StreamState>, IMeasurableMemory, StreamEventHandler
public class StreamingState extends Object implements StreamEventHandler, IMeasurableMemory

  • Field Details

  • Constructor Details

  • Method Details

    • unsharedHeapSize

      public long unsharedHeapSize()
      Specified by:
      unsharedHeapSize in interface IMeasurableMemory
      Returns:
      the amount of on-heap memory retained by the object that might be reclaimed if the object were reclaimed, i.e. it should try to exclude globally cached data where possible, or counting portions of arrays that are referenced by the object but used by other objects only (e.g. slabbed byte-buffers), etc.

    • id

      public TimeUUID id()

    • follower

      public boolean follower()

    • operation

      public StreamOperation operation()

    • peers

      public Set<InetSocketAddress> peers()

    • completeMessage

      public String completeMessage()

    • status

      public StreamingState.Status status()

    • sessions

      public StreamingState.Sessions sessions()

    • isComplete

      public boolean isComplete()

    • future

      public StreamResultFuture future()

    • progress

      public float progress()

    • stateTimesMillis

      public EnumMap<StreamingState.Status,Long> stateTimesMillis()

    • durationMillis

      public long durationMillis()

    • lastUpdatedAtMillis

      public long lastUpdatedAtMillis()

    • lastUpdatedAtNanos

      public long lastUpdatedAtNanos()

    • failureCause

      public String failureCause()

    • successMessage

      public String successMessage()

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • 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:

    • onSuccess

      public void onSuccess(@Nullable StreamState state)
      Specified by:
      onSuccess in interface com.google.common.util.concurrent.FutureCallback<StreamState>

    • onFailure

      public void onFailure(Throwable throwable)
      Specified by:
      onFailure in interface com.google.common.util.concurrent.FutureCallback<StreamState>