public class KRaftSnapshotObjectUtils extends Object
Constructor and Description |
---|
KRaftSnapshotObjectUtils() |
Modifier and Type | Method and Description |
---|---|
static TierObjectStoreResponse |
getObject(TierObjectStore objectStore,
TierObjectStore.KRaftSnapshotMetadata objectMetadata) |
static TierObjectStoreResponse |
getObject(TierObjectStore objectStore,
TierObjectStore.KRaftSnapshotMetadata objectMetadata,
VersionInformation versionInformation) |
static Map<KRaftSnapshotObject,List<VersionInformation>> |
listObjects(TierObjectStore objectStore,
boolean versionInfo,
String keyPrefix) |
static Map<KRaftSnapshotObject,List<VersionInformation>> |
listObjectsByNode(TierObjectStore objectStore,
boolean versionInfo,
String keyPrefix,
org.apache.kafka.common.Uuid topicId,
int partition,
String clusterId,
int nodeId) |
static void |
putObject(TierObjectStore objectStore,
TierObjectStore.KRaftSnapshotMetadata objectMetadata,
File file) |
public static void putObject(TierObjectStore objectStore, TierObjectStore.KRaftSnapshotMetadata objectMetadata, File file) throws IOException
IOException
public static TierObjectStoreResponse getObject(TierObjectStore objectStore, TierObjectStore.KRaftSnapshotMetadata objectMetadata) throws IOException
IOException
public static TierObjectStoreResponse getObject(TierObjectStore objectStore, TierObjectStore.KRaftSnapshotMetadata objectMetadata, VersionInformation versionInformation) throws IOException
IOException
public static Map<KRaftSnapshotObject,List<VersionInformation>> listObjects(TierObjectStore objectStore, boolean versionInfo, String keyPrefix)
public static Map<KRaftSnapshotObject,List<VersionInformation>> listObjectsByNode(TierObjectStore objectStore, boolean versionInfo, String keyPrefix, org.apache.kafka.common.Uuid topicId, int partition, String clusterId, int nodeId)