Help Center> Data Ingestion Service> SDK Reference> Getting Started with SDK> Using the Java SDK> Changing Partition Quantity
View PDF

Changing Partition Quantity

Initialize a DIS SDK client instance named dic. For details, see Initializing a DIS SDK Client Instance.

The value of streamName must be the same as the value of Stream Name in Creating a DIS Stream. For details about endpoints, AKs, SKs, regions, and project IDs, see Obtaining Authentication Information.

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
 
//Specify the number of target partitions.
int targetPartitionCount = 2;
        
UpdatePartitionCountRequest update = new UpdatePartitionCountRequest();
update.setStreamName(streamName);
update.setTargetPartitionCount(targetPartitionCount);
try
{
     UpdatePartitionCountResult updatePartitionCountResult = dic.updatePartitionCount(update);
     LOGGER.info("Success to update partition count, {}", updatePartitionCountResult);
}
catch (Exception e)
{
     LOGGER.error("Failed to update partition count", e);
}

If the number of partitions is changed successfully, information similar to the following is returned:

1
 
Success to update partition count, UpdatePartitionCountResult [currentPartitionCount=2, streamName=mystream, targetPartitionCount=2]
Parent topic: Using the Java SDK