diff --git a/samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriter.java b/samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriter.java index e501936694..8a162f79ee 100644 --- a/samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriter.java +++ b/samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriter.java @@ -23,7 +23,6 @@ import com.azure.storage.blob.specialized.BlockBlobAsyncClient; import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Preconditions; -import org.apache.samza.system.azureblob.AzureBlobConfig; import org.apache.samza.system.azureblob.compression.Compression; import org.apache.samza.system.azureblob.producer.AzureBlobWriter; import org.apache.samza.system.azureblob.producer.AzureBlobWriterMetrics; @@ -123,18 +122,6 @@ public class AzureBlobAvroWriter implements AzureBlobWriter { private Config blobMetadataGeneratorConfig; private String streamName; - @Deprecated - public AzureBlobAvroWriter(BlobContainerAsyncClient containerAsyncClient, String blobURLPrefix, - Executor blobThreadPool, AzureBlobWriterMetrics metrics, - BlobMetadataGeneratorFactory blobMetadataGeneratorFactory, Config blobMetadataGeneratorConfig, String streamName, - int maxBlockFlushThresholdSize, long flushTimeoutMs, Compression compression, boolean useRandomStringInBlobName, - long maxBlobSize, long maxRecordsPerBlob) { - - this(containerAsyncClient, blobURLPrefix, blobThreadPool, metrics, blobMetadataGeneratorFactory, - blobMetadataGeneratorConfig, streamName, maxBlockFlushThresholdSize, flushTimeoutMs, compression, - useRandomStringInBlobName, maxBlobSize, maxRecordsPerBlob, AzureBlobConfig.SYSTEM_INIT_BUFFER_SIZE_DEFAULT); - } - public AzureBlobAvroWriter(BlobContainerAsyncClient containerAsyncClient, String blobURLPrefix, Executor blobThreadPool, AzureBlobWriterMetrics metrics, BlobMetadataGeneratorFactory blobMetadataGeneratorFactory, Config blobMetadataGeneratorConfig, String streamName,