Functions — github.com/Aiven-Open/transforms-for-apache-kafka-connect

hub / github.com/Aiven-Open/transforms-for-apache-kafka-connect / functions

Functions448 in github.com/Aiven-Open/transforms-for-apache-kafka-connect

⨍ Functions 448◇ Types & classes 79

↓ 1 callersMethoddataPlace

()

src/main/java/io/aiven/kafka/connect/transforms/ConcatFields.java:39

↓ 1 callersMethodextractFieldValue

(final R record)

src/main/java/io/aiven/kafka/connect/predicates/FieldValueMatches.java:134

↓ 1 callersMethodfieldName

()

src/main/java/io/aiven/kafka/connect/transforms/ExtractTimestampConfig.java:103

↓ 1 callersMethodfromString

(final String value)

src/main/java/io/aiven/kafka/connect/transforms/HashConfig.java:85

↓ 1 callersMethodfromString

Return the case enumeration object resolved from the given parameter. @param string The case enumeration to fetch. @return

src/main/java/io/aiven/kafka/connect/transforms/CaseTransformConfig.java:94

↓ 1 callersMethodgetNewValueForNamedField

(final String recordStr, final Schema schema,

src/main/java/io/aiven/kafka/connect/transforms/Hash.java:94

↓ 1 callersMethodgetNewValueWithoutFieldName

(final String recordStr, final Schema schema,

src/main/java/io/aiven/kafka/connect/transforms/Hash.java:139

↓ 1 callersMethodgetSchemaAndValue

(final R record)

src/main/java/io/aiven/kafka/connect/transforms/Hash.java:168

↓ 1 callersMethodgetSchemaAndValue

(final R record)

src/main/java/io/aiven/kafka/connect/transforms/Hash.java:205

↓ 1 callersMethodgetSchemaAndValue

(final R record)

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopic.java:111

↓ 1 callersMethodgetSchemaAndValue

(final R record)

src/main/java/io/aiven/kafka/connect/transforms/CaseTransform.java:57

↓ 1 callersMethodgetSchemaAndValue

(final R record)

src/main/java/io/aiven/kafka/connect/transforms/ConcatFields.java:41

↓ 1 callersMethodgetSchemaAndValue

(final R record)

src/main/java/io/aiven/kafka/connect/transforms/ExtractTimestamp.java:106

↓ 1 callersMethodgetSchemalessFieldValue

(final Object fieldValue)

src/main/java/io/aiven/kafka/connect/transforms/FilterByFieldValue.java:146

↓ 1 callersMethodgetStructFieldValue

(final Struct struct, final String fieldName)

src/main/java/io/aiven/kafka/connect/transforms/FilterByFieldValue.java:123

↓ 1 callersMethodkeyFields

()

src/main/java/io/aiven/kafka/connect/transforms/KeyToValueConfig.java:62

↓ 1 callersMethodkeyOrValue

()

src/main/java/io/aiven/kafka/connect/transforms/ExtractTimestamp.java:104

↓ 1 callersMethodmapRecord

(final String state)

src/test/java/io/aiven/kafka/connect/predicates/FieldValueMatchesTest.java:285

↓ 1 callersMethodmergeSchema

Merges the key and value schemas into a new schema, according to the configuration of keyFields to copy into the new value schema, and how they are re

src/main/java/io/aiven/kafka/connect/transforms/KeyToValue.java:233

↓ 1 callersMethodoperatingSchema

(R record)

src/main/java/io/aiven/kafka/connect/transforms/FilterByFieldValue.java:100

↓ 1 callersMethodregister

(final SchemaBuilder fieldSchema, final CustomConverter.Converter converter)

src/test/java/io/aiven/kafka/connect/debezium/converters/MoneyConverterTest.java:126

↓ 1 callersMethodschemaName

(R record)

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopicFromSchemaName.java:52

↓ 1 callersMethodstart

()

src/integration-test/java/io/aiven/kafka/connect/transforms/ConnectRunner.java:59

↓ 1 callersMethodstop

()

src/integration-test/java/io/aiven/kafka/connect/transforms/AbstractTestSourceConnector.java:38

↓ 1 callersMethodtopicNameFromNamedFieldSchemaless

(final String recordStr, final Object value,

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopic.java:113

↓ 1 callersMethodtopicNameFromNamedFieldWithSchema

(final String recordStr, final Schema schema,

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopic.java:169

↓ 1 callersMethodtopicNameWithoutFieldNameSchemaless

(final String recordStr, final Object value)

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopic.java:149

↓ 1 callersMethodtopicNameWithoutFieldNameWithSchema

(final String recordStr, final Schema schema,

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopic.java:212

↓ 1 callersMethodtransformCase

()

src/main/java/io/aiven/kafka/connect/transforms/CaseTransformConfig.java:72

↓ 1 callersMethodtypeName

()

src/test/java/io/aiven/kafka/connect/debezium/converters/utils/DummyRelationalColumn.java:35

↓ 1 callersMethodvalidateKeySchemaRequirementsMet

Validation check to fail quickly when the entire key is copied into a structured value with a schema, but has a schemaless class. @param record The i

src/main/java/io/aiven/kafka/connect/transforms/KeyToValue.java:131

↓ 1 callersMethodvalidateNoUnextractableKeyFields

Validation check to ensure that if any named fields exist, they can be extracted from the structured data in the key. @param record The incoming reco

src/main/java/io/aiven/kafka/connect/transforms/KeyToValue.java:109

↓ 1 callersMethodvalidateStructuredValue

Validation check to ensure that the value can receive columns from the key, i.e. as either a Struct or Map.

src/main/java/io/aiven/kafka/connect/transforms/KeyToValue.java:142

↓ 1 callersMethodvalueFields

()

src/main/java/io/aiven/kafka/connect/transforms/KeyToValueConfig.java:66

↓ 1 callersMethodversion

()

src/integration-test/java/io/aiven/kafka/connect/transforms/AbstractTestSourceConnector.java:53

MethodCase

(final String transformCase)

src/main/java/io/aiven/kafka/connect/transforms/CaseTransformConfig.java:85

MethodCaseTransformConfig

(final Map<?, ?> originals)

src/main/java/io/aiven/kafka/connect/transforms/CaseTransformConfig.java:47

MethodConcatFieldsConfig

(final Map<?, ?> originals)

src/main/java/io/aiven/kafka/connect/transforms/ConcatFieldsConfig.java:39

MethodConnectRunner

(final File pluginDir, final String bootstrapServers)

src/integration-test/java/io/aiven/kafka/connect/transforms/ConnectRunner.java:53

MethodExtractTimestampConfig

(final Map<?, ?> originals)

src/main/java/io/aiven/kafka/connect/transforms/ExtractTimestampConfig.java:71

MethodExtractTopicConfig

(final Map<?, ?> originals)

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopicConfig.java:36

MethodExtractTopicFromSchemaNameConfig

(final Map<?, ?> originals)

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopicFromSchemaNameConfig.java:42

MethodHashConfig

(final Map<?, ?> originals)

src/main/java/io/aiven/kafka/connect/transforms/HashConfig.java:38

MethodKeyToValueConfig

(final Map<?, ?> originals)

src/main/java/io/aiven/kafka/connect/transforms/KeyToValueConfig.java:45

MethodTimestampResolution

(final String resolution)

src/main/java/io/aiven/kafka/connect/transforms/ExtractTimestampConfig.java:51

MethodTombstoneHandlerConfig

(final Map<?, ?> originals)

src/main/java/io/aiven/kafka/connect/transforms/TombstoneHandlerConfig.java:33

MethodacceptCorrectBehaviorNames

()

src/test/java/io/aiven/kafka/connect/transforms/TombstoneHandlerConfigTest.java:39

Methodapply

(final R record)

src/main/java/io/aiven/kafka/connect/transforms/KeyToValue.java:149

Methodapply

(final R record)

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopic.java:69

Methodapply

(final R record)

src/main/java/io/aiven/kafka/connect/transforms/ConcatFields.java:55

Methodapply

(final R record)

src/main/java/io/aiven/kafka/connect/transforms/TombstoneHandler.java:45

Methodapply

(final R record)

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopicFromSchemaName.java:54

Methodapply

(final R record)

src/main/java/io/aiven/kafka/connect/transforms/ExtractTimestamp.java:44

Methodapply

(final R record)

src/main/java/io/aiven/kafka/connect/transforms/FilterByFieldValue.java:104

Methodclose

()

src/main/java/io/aiven/kafka/connect/predicates/FieldValueMatches.java:159

Methodclose

()

src/main/java/io/aiven/kafka/connect/transforms/KeyToValue.java:171

Methodclose

()

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopic.java:257

Methodclose

()

src/main/java/io/aiven/kafka/connect/transforms/CaseTransform.java:131

Methodclose

()

src/main/java/io/aiven/kafka/connect/transforms/ConcatFields.java:173

Methodclose

()

src/main/java/io/aiven/kafka/connect/transforms/MakeTombstone.java:46

Methodclose

()

src/main/java/io/aiven/kafka/connect/transforms/TombstoneHandler.java:84

Methodclose

()

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopicFromSchemaName.java:87

Methodclose

()

src/main/java/io/aiven/kafka/connect/transforms/ExtractTimestamp.java:100

Methodclose

()

src/main/java/io/aiven/kafka/connect/transforms/FilterByFieldValue.java:153

Methodconfig

()

src/integration-test/java/io/aiven/kafka/connect/transforms/AbstractTestSourceConnector.java:48

Methodconfig

()

src/main/java/io/aiven/kafka/connect/transforms/KeyToValue.java:70

Methodconfig

()

src/main/java/io/aiven/kafka/connect/transforms/Hash.java:46

Methodconfig

()

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopic.java:59

Methodconfig

()

src/main/java/io/aiven/kafka/connect/transforms/CaseTransform.java:136

Methodconfig

()

src/main/java/io/aiven/kafka/connect/transforms/ConcatFields.java:45

Methodconfig

()

src/main/java/io/aiven/kafka/connect/transforms/MakeTombstone.java:41

Methodconfig

()

src/main/java/io/aiven/kafka/connect/transforms/TombstoneHandler.java:35

Methodconfig

()

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopicFromSchemaName.java:39

Methodconfig

()

src/main/java/io/aiven/kafka/connect/transforms/ExtractTimestamp.java:34

MethodconfigMapValueSchemaNameToTopicTest

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicFromSchemaNameTest.java:43

Methodconfigure

(final Properties props)

src/main/java/io/aiven/kafka/connect/debezium/converters/MoneyConverter.java:34

Methodconfigure

(final Map<String, ?> settings)

src/main/java/io/aiven/kafka/connect/transforms/KeyToValue.java:75

Methodconfigure

(final Map<String, ?> settings)

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopic.java:64

Methodconfigure

(final Map<String, ?> settings)

src/main/java/io/aiven/kafka/connect/transforms/CaseTransform.java:141

Methodconfigure

(final Map<String, ?> configs)

src/main/java/io/aiven/kafka/connect/transforms/ConcatFields.java:50

Methodconfigure

(final Map<String, ?> configs)

src/main/java/io/aiven/kafka/connect/transforms/MakeTombstone.java:51

Methodconfigure

(final Map<String, ?> configs)

src/main/java/io/aiven/kafka/connect/transforms/ExtractTopicFromSchemaName.java:44

Methodconfigure

(final Map<String, ?> configs)

src/main/java/io/aiven/kafka/connect/transforms/ExtractTimestamp.java:39

Methodconfigure

(final Map<String, ?> configs)

src/main/java/io/aiven/kafka/connect/transforms/FilterByFieldValue.java:68

MethodconnectorPartitions

( final String connectorName)

src/integration-test/java/io/aiven/kafka/connect/transforms/ConnectRunner.java:90

MethodcreateNewRecord

(final R record, final Schema newSchema, final Object newValue)

src/main/java/io/aiven/kafka/connect/transforms/CaseTransform.java:167

MethodcreateNewRecord

(final R record, final Schema newSchema, final Object newValue)

src/main/java/io/aiven/kafka/connect/transforms/CaseTransform.java:197

MethodcreateNewRecord

(final R record, final Schema newSchema, final Object newValue)

src/main/java/io/aiven/kafka/connect/transforms/ConcatFields.java:127

MethodcreateNewRecord

(final R record, final Schema newSchema, final Object newValue)

src/main/java/io/aiven/kafka/connect/transforms/ConcatFields.java:153

MethodcreateTransformationObject

()

src/test/java/io/aiven/kafka/connect/transforms/ConcatFieldsValueTest.java:29

MethodcreateTransformationObject

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicValueTest.java:29

MethodcreateTransformationObject

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicKeyTest.java:29

MethodcreateTransformationObject

()

src/test/java/io/aiven/kafka/connect/transforms/ConcatFieldsKeyTest.java:29

MethodcreateTransformationObject

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTimestampValueTest.java:29

MethodcreateTransformationObject

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTimestampKeyTest.java:29

MethodcreateTransformationObject

()

src/test/java/io/aiven/kafka/connect/transforms/HashKeyTest.java:29

MethodcreateTransformationObject

()

src/test/java/io/aiven/kafka/connect/transforms/HashValueTest.java:29

MethoddataCollection

()

src/test/java/io/aiven/kafka/connect/debezium/converters/utils/DummyRelationalColumn.java:75

MethoddataCollection

()

src/test/java/io/aiven/kafka/connect/debezium/converters/utils/MoneyTestRelationalColumn.java:78

MethoddataPlace

()

src/test/java/io/aiven/kafka/connect/transforms/ConcatFieldsValueTest.java:24

← previous next →101–200 of 448, ranked by callers