Index

B C E F G H I P R W
All Classes and Interfaces|All Packages

B

BackupConverterHelper - Class in io.confluent.connect.schema.backup.core

Shared helper for backup metadata wrapping in SR converters.

BackupConverterHelper(SchemaRegistryClient, Map<Schema, Schema>) - Constructor for class io.confluent.connect.schema.backup.core.BackupConverterHelper

BackupConverterHelper.SubjectNameComputer - Interface in io.confluent.connect.schema.backup.core

BackupExceptionMapper - Class in io.confluent.connect.schema.backup.core

BackupReferenceResolver - Class in io.confluent.connect.schema.backup.core

Resolves and registers schema references in the target Schema Registry during restore.

BackupReferenceResolver(SchemaRegistryClient) - Constructor for class io.confluent.connect.schema.backup.core.BackupReferenceResolver

BackupReferenceResolver.ParsedSchemaFactory - Interface in io.confluent.connect.schema.backup.core

BackupReferenceResolver.ResolutionResult - Class in io.confluent.connect.schema.backup.core

BackupSchemaFetcher - Class in io.confluent.connect.schema.backup.core

Fetches schema metadata and builds reference trees from Schema Registry for backup.

BackupSchemaFetcher(SchemaRegistryClient) - Constructor for class io.confluent.connect.schema.backup.core.BackupSchemaFetcher

BackupSchemaFetcher.BackupSchemaInfo - Class in io.confluent.connect.schema.backup.core

BackupSchemaFetcher.RefTreeEntry - Class in io.confluent.connect.schema.backup.core

BackupSchemaInfo(String, List<SchemaReference>, Map<String, BackupSchemaFetcher.RefTreeEntry>, String, String, Map<String, Integer>) - Constructor for class io.confluent.connect.schema.backup.core.BackupSchemaFetcher.BackupSchemaInfo

C

classify(String, Throwable) - Static method in class io.confluent.connect.schema.backup.core.BackupExceptionMapper

computeSubjectName(String, boolean, ParsedSchema) - Method in interface io.confluent.connect.schema.backup.core.BackupConverterHelper.SubjectNameComputer

create(String, List<SchemaReference>, Map<String, String>) - Method in interface io.confluent.connect.schema.backup.core.BackupReferenceResolver.ParsedSchemaFactory

E

empty() - Static method in class io.confluent.connect.schema.backup.core.BackupReferenceResolver.ResolutionResult

F

fetchSchemaInfo(int) - Method in class io.confluent.connect.schema.backup.core.BackupSchemaFetcher

fetchSchemaInfoByGuid(String) - Method in class io.confluent.connect.schema.backup.core.BackupSchemaFetcher

G

getDirectReferences() - Method in class io.confluent.connect.schema.backup.core.BackupSchemaFetcher.BackupSchemaInfo

getDirectRefsJson() - Method in class io.confluent.connect.schema.backup.core.BackupSchemaFetcher.BackupSchemaInfo

getGlobalId() - Method in class io.confluent.connect.schema.backup.core.BackupSchemaFetcher.RefTreeEntry

getRawSchema() - Method in class io.confluent.connect.schema.backup.core.BackupSchemaFetcher.BackupSchemaInfo

getReferenceResolver() - Method in class io.confluent.connect.schema.backup.core.BackupConverterHelper

getReferences() - Method in class io.confluent.connect.schema.backup.core.BackupSchemaFetcher.RefTreeEntry

getReferenceTree() - Method in class io.confluent.connect.schema.backup.core.BackupSchemaFetcher.BackupSchemaInfo

getReferenceTreeJson() - Method in class io.confluent.connect.schema.backup.core.BackupSchemaFetcher.BackupSchemaInfo

getResolvedSchemas() - Method in class io.confluent.connect.schema.backup.core.BackupReferenceResolver.ResolutionResult

getSchema() - Method in class io.confluent.connect.schema.backup.core.BackupSchemaFetcher.RefTreeEntry

getSchemaType() - Method in class io.confluent.connect.schema.backup.core.BackupSchemaFetcher.RefTreeEntry

getSubject() - Method in class io.confluent.connect.schema.backup.core.BackupSchemaFetcher.RefTreeEntry

getTargetRefs() - Method in class io.confluent.connect.schema.backup.core.BackupReferenceResolver.ResolutionResult

getVersion() - Method in class io.confluent.connect.schema.backup.core.BackupSchemaFetcher.RefTreeEntry

getVersionForSubject(String) - Method in class io.confluent.connect.schema.backup.core.BackupSchemaFetcher.BackupSchemaInfo

H

hasReferences() - Method in class io.confluent.connect.schema.backup.core.BackupReferenceResolver.ResolutionResult

I

io.confluent.connect.schema.backup.core - package io.confluent.connect.schema.backup.core

isBackupEnabled(Map<String, ?>) - Static method in class io.confluent.connect.schema.backup.core.BackupConverterHelper

P

parseDirectRefs(String) - Static method in class io.confluent.connect.schema.backup.core.BackupReferenceResolver

parseReferenceTree(String) - Static method in class io.confluent.connect.schema.backup.core.BackupReferenceResolver

R

RefTreeEntry(String, int, String, List<SchemaReference>, int, String) - Constructor for class io.confluent.connect.schema.backup.core.BackupSchemaFetcher.RefTreeEntry

registerRefsRecursive(List<SchemaReference>, Map<String, BackupSchemaFetcher.RefTreeEntry>, BackupReferenceResolver.ParsedSchemaFactory, List<SchemaReference>, Map<String, String>) - Method in class io.confluent.connect.schema.backup.core.BackupReferenceResolver

resolveFromWrapper(Schema, Struct, BackupReferenceResolver.ParsedSchemaFactory) - Method in class io.confluent.connect.schema.backup.core.BackupReferenceResolver

W

wrapWithBackupMetadata(SchemaAndValue, String, ParsedSchemaAndValue.SchemaInfo, String, boolean, BackupReferenceResolver.ParsedSchemaFactory, BackupConverterHelper.SubjectNameComputer) - Method in class io.confluent.connect.schema.backup.core.BackupConverterHelper

B C E F G H I P R W
All Classes and Interfaces|All Packages