Uses of Interface
org.apache.cassandra.streaming.StreamingChannel.Factory
Packages that use StreamingChannel.Factory
Package
Description
Non-blocking streaming with netty
-
Uses of StreamingChannel.Factory in org.apache.cassandra.io.sstable
Methods in org.apache.cassandra.io.sstable that return StreamingChannel.FactoryModifier and TypeMethodDescriptionSSTableLoader.Client.getConnectionFactory()Provides connection factory. -
Uses of StreamingChannel.Factory in org.apache.cassandra.streaming
Methods in org.apache.cassandra.streaming that return StreamingChannel.FactoryModifier and TypeMethodDescriptionstatic StreamingChannel.FactoryStreamingChannel.Factory.Global.streamingFactory()Methods in org.apache.cassandra.streaming with parameters of type StreamingChannel.FactoryModifier and TypeMethodDescriptionStreamPlan.connectionFactory(StreamingChannel.Factory factory) Set custom StreamConnectionFactory to be used for establishing connectionvoidStreamCoordinator.setConnectionFactory(StreamingChannel.Factory factory) static voidStreamingChannel.Factory.Global.unsafeSet(StreamingChannel.Factory factory) Constructors in org.apache.cassandra.streaming with parameters of type StreamingChannel.FactoryModifierConstructorDescriptionStreamCoordinator(StreamOperation streamOperation, int connectionsPerHost, StreamingChannel.Factory factory, boolean follower, boolean connectSequentially, TimeUUID pendingRepair, PreviewKind previewKind) StreamSession(StreamOperation streamOperation, InetAddressAndPort peer, StreamingChannel.Factory factory, StreamingChannel controlChannel, int messagingVersion, boolean isFollower, int index, TimeUUID pendingRepair, PreviewKind previewKind) Create new streaming session with the peer. -
Uses of StreamingChannel.Factory in org.apache.cassandra.streaming.async
Classes in org.apache.cassandra.streaming.async that implement StreamingChannel.FactoryConstructors in org.apache.cassandra.streaming.async with parameters of type StreamingChannel.FactoryModifierConstructorDescriptionStreamingMultiplexedChannel(StreamSession session, StreamingChannel.Factory factory, InetAddressAndPort to, StreamingChannel controlChannel, int messagingVersion) -
Uses of StreamingChannel.Factory in org.apache.cassandra.tools
Classes in org.apache.cassandra.tools that implement StreamingChannel.Factory