public class DiskTierFactory extends Object implements TierFactory
TierFactory
for disk tier.Constructor and Description |
---|
DiskTierFactory(int numBytesPerSegment,
int bufferSizeBytes,
float minReservedDiskSpaceFraction,
int regionGroupSizeInBytes,
int maxCachedBytesBeforeFlush,
long numRetainedInMemoryRegionsMax) |
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 DiskTierFactory(int numBytesPerSegment, int bufferSizeBytes, float minReservedDiskSpaceFraction, int regionGroupSizeInBytes, int maxCachedBytesBeforeFlush, long numRetainedInMemoryRegionsMax)
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.