Uses of Class
org.apache.cassandra.streaming.StreamPlan
Packages that use StreamPlan
-
Uses of StreamPlan in org.apache.cassandra.repair
Methods in org.apache.cassandra.repair with parameters of type StreamPlan -
Uses of StreamPlan in org.apache.cassandra.streaming
Methods in org.apache.cassandra.streaming that return StreamPlanModifier and TypeMethodDescriptionStreamPlan.connectionFactory(StreamingChannel.Factory factory) Set custom StreamConnectionFactory to be used for establishing connectionStreamPlan.flushBeforeTransfer(boolean flushBeforeTransfer) Set flushBeforeTransfer option.StreamPlan.listeners(StreamEventHandler handler, StreamEventHandler... handlers) StreamPlan.requestRanges(InetAddressAndPort from, String keyspace, RangesAtEndpoint fullRanges, RangesAtEndpoint transientRanges) Request data inkeyspaceandrangesfrom specific node.StreamPlan.requestRanges(InetAddressAndPort from, String keyspace, RangesAtEndpoint fullRanges, RangesAtEndpoint transientRanges, String... columnFamilies) Request data incolumnFamiliesunderkeyspaceandrangesfrom specific node.StreamPlan.transferRanges(InetAddressAndPort to, String keyspace, RangesAtEndpoint replicas, String... columnFamilies) Add transfer task to send data of specificcolumnFamiliesunderkeyspaceandranges.StreamPlan.transferStreams(InetAddressAndPort to, Collection<OutgoingStream> streams) Add transfer task to send given streams