Uses of Class
org.apache.cassandra.streaming.StreamSummary
Packages that use StreamSummary
Package
Description
-
Uses of StreamSummary in org.apache.cassandra.streaming
Fields in org.apache.cassandra.streaming with type parameters of type StreamSummaryModifier and TypeFieldDescriptionfinal Collection<StreamSummary>SessionInfo.receivingSummariesImmutable collection of receiving summariesfinal Collection<StreamSummary>SessionSummary.receivingSummariesImmutable collection of receiving summariesfinal Collection<StreamSummary>SessionInfo.sendingSummariesImmutable collection of sending summariesfinal Collection<StreamSummary>SessionSummary.sendingSummariesImmutable collection of sending summariesstatic final IVersionedSerializer<StreamSummary>StreamSummary.serializerMethods in org.apache.cassandra.streaming that return StreamSummaryModifier and TypeMethodDescriptionStreamSummary.StreamSummarySerializer.deserialize(DataInputPlus in, int version) StreamTask.getSummary()Methods in org.apache.cassandra.streaming with parameters of type StreamSummaryModifier and TypeMethodDescriptionvoidStreamSession.prepareReceiving(StreamSummary summary) voidStreamSummary.StreamSummarySerializer.serialize(StreamSummary summary, DataOutputPlus out, int version) longStreamSummary.StreamSummarySerializer.serializedSize(StreamSummary summary, int version) Method parameters in org.apache.cassandra.streaming with type arguments of type StreamSummaryModifier and TypeMethodDescriptionstatic booleanStreamSession.checkAvailableDiskSpaceAndCompactions(Collection<StreamSummary> summaries, TimeUUID planId, String remoteAddress, boolean isForIncremental) Makes sure that we expect to have enough disk space available for the new streams, taking into consideration the ongoing compactions and streams.Constructor parameters in org.apache.cassandra.streaming with type arguments of type StreamSummaryModifierConstructorDescriptionSessionInfo(InetSocketAddress peer, int sessionIndex, InetSocketAddress connecting, Collection<StreamSummary> receivingSummaries, Collection<StreamSummary> sendingSummaries, StreamSession.State state, String failureReason) SessionSummary(InetSocketAddress coordinator, InetSocketAddress peer, Collection<StreamSummary> receivingSummaries, Collection<StreamSummary> sendingSummaries) -
Uses of StreamSummary in org.apache.cassandra.streaming.management
Methods in org.apache.cassandra.streaming.management that return StreamSummaryModifier and TypeMethodDescriptionstatic StreamSummaryStreamSummaryCompositeData.fromCompositeData(CompositeData cd) Methods in org.apache.cassandra.streaming.management with parameters of type StreamSummaryModifier and TypeMethodDescriptionstatic CompositeDataStreamSummaryCompositeData.toCompositeData(StreamSummary streamSummary) -
Uses of StreamSummary in org.apache.cassandra.streaming.messages
Fields in org.apache.cassandra.streaming.messages with type parameters of type StreamSummaryModifier and TypeFieldDescriptionfinal Collection<StreamSummary>PrepareSynAckMessage.summariesSummaries of streaming outfinal Collection<StreamSummary>PrepareSynMessage.summariesSummaries of streaming out