public class RemoteTierFactory extends Object implements TierFactory
TierFactory
for remote tier.Constructor and Description |
---|
RemoteTierFactory(int numBytesPerSegment,
int bufferSizeBytes,
String remoteStorageBasePath) |
Modifier and Type | Method and Description |
---|---|
TierConsumerAgent |
createConsumerAgent(List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs,
TieredStorageNettyService nettyService)
Creates the consumer-side agent of a Tier.
|
TierMasterAgent |
createMasterAgent(TieredStorageResourceRegistry resourceRegistry)
Creates the master-side agent of a Tier.
|
TierProducerAgent |
createProducerAgent(int numSubpartitions,
TieredStoragePartitionId partitionID,
String dataFileBasePath,
boolean isBroadcastOnly,
TieredStorageMemoryManager storageMemoryManager,
TieredStorageNettyService nettyService,
TieredStorageResourceRegistry resourceRegistry,
BatchShuffleReadBufferPool bufferPool,
ScheduledExecutorService ioExecutor,
int maxRequestedBuffers,
java.time.Duration bufferRequestTimeout)
Creates the producer-side agent of a Tier.
|
public RemoteTierFactory(int numBytesPerSegment, int bufferSizeBytes, String remoteStorageBasePath)
public TierMasterAgent createMasterAgent(TieredStorageResourceRegistry resourceRegistry)
TierFactory
createMasterAgent
in interface TierFactory
public TierProducerAgent createProducerAgent(int numSubpartitions, TieredStoragePartitionId partitionID, String dataFileBasePath, boolean isBroadcastOnly, TieredStorageMemoryManager storageMemoryManager, TieredStorageNettyService nettyService, TieredStorageResourceRegistry resourceRegistry, BatchShuffleReadBufferPool bufferPool, ScheduledExecutorService ioExecutor, int maxRequestedBuffers, java.time.Duration bufferRequestTimeout)
TierFactory
createProducerAgent
in interface TierFactory
public TierConsumerAgent createConsumerAgent(List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs, TieredStorageNettyService nettyService)
TierFactory
createConsumerAgent
in interface TierFactory
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.