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

MethoddataPlace

()

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

MethoddataPlace

()

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

MethoddataPlace

()

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

MethoddataPlace

()

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

MethoddataPlace

()

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

MethoddataPlace

()

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

MethoddataPlace

()

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

MethoddataPlace

()

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

MethoddataPlace

()

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

MethoddataPlace

()

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

MethoddataPlace

()

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

MethoddefaultValue

()

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

MethoddefaultValue

()

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

Methoddefaults

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicFromSchemaNameConfigTest.java:32

Methoddefaults

()

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

Methoddefaults

()

src/test/java/io/aiven/kafka/connect/transforms/HashConfigTest.java:32

MethoddefinedFieldName

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTimestampConfigTest.java:47

MethoddefinedFieldName

()

src/test/java/io/aiven/kafka/connect/transforms/ConcatFieldsConfigTest.java:52

MethoddefinedFieldName

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicConfigTest.java:54

MethoddefinedFieldName

()

src/test/java/io/aiven/kafka/connect/transforms/HashConfigTest.java:83

MethoddefinedTimestampResolutionInMillis

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTimestampConfigTest.java:75

MethoddefinedTimestampResolutionInSeconds

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTimestampConfigTest.java:63

MethodemptyConfig

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTimestampConfigTest.java:30

MethodemptyConfig

()

src/test/java/io/aiven/kafka/connect/transforms/ConcatFieldsConfigTest.java:35

MethodemptyConfigsValueSchemaNameToTopicTest

()

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

MethodemptyFieldName

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTimestampConfigTest.java:38

MethodemptyFieldName

()

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

MethodemptyFieldName

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicConfigTest.java:46

MethodemptyFieldName

()

src/test/java/io/aiven/kafka/connect/transforms/HashConfigTest.java:74

MethodemptyTimestampResolution

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTimestampConfigTest.java:55

MethodensureValid

(final String name, final Object value)

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

MethodensureValid

(final String name, final Object value)

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

MethoderrorCantAppendToValue

Test trying to copy to a value that can't be appended to.

src/test/java/io/aiven/kafka/connect/transforms/KeyToValueTest.java:242

MethoderrorCantDeduceKeySchema

Test trying to extract a whole schemaless key to a value that requires a schema. This is not allowed.

src/test/java/io/aiven/kafka/connect/transforms/KeyToValueTest.java:218

MethoderrorDuplicateValueMapping

()

src/test/java/io/aiven/kafka/connect/transforms/KeyToValueTest.java:258

MethoderrorMissingFieldKey

()

src/test/java/io/aiven/kafka/connect/transforms/KeyToValueTest.java:188

MethoderrorNonExtractableKeys

Test trying to extract fields from a key when the key value doesn't support fields.

src/test/java/io/aiven/kafka/connect/transforms/KeyToValueTest.java:198

MethodfailOnEmptyBehaviorName

()

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

MethodfailOnUnknownBehaviorName

()

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

MethodfieldName_EmptyStringValue

(final String hashFunction)

src/test/java/io/aiven/kafka/connect/transforms/HashTest.java:230

MethodfieldName_MissingFieldInSchema_NoSkip

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicTest.java:268

MethodfieldName_MissingFieldInSchema_Skip

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicTest.java:277

MethodfieldName_MissingValue_NoSkip

()

src/test/java/io/aiven/kafka/connect/transforms/HashTest.java:142

MethodfieldName_MissingValue_Skip

()

src/test/java/io/aiven/kafka/connect/transforms/HashTest.java:168

MethodfieldName_NonStruct

()

src/test/java/io/aiven/kafka/connect/transforms/HashTest.java:179

MethodfieldName_NormalBooleanValue

(final boolean withSchema)

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicTest.java:303

MethodfieldName_NormalIntValue

(final boolean withSchema)

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicTest.java:285

MethodfieldName_NormalStringValue

(final boolean withSchema)

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicTest.java:321

MethodfieldName_NormalStringValue

(final String hashFunction)

src/test/java/io/aiven/kafka/connect/transforms/HashTest.java:211

MethodfieldName_NullOrEmptyValueOrMissingField_Skip_Schemaless

(final String value)

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicTest.java:254

MethodfieldName_NullOrEmptyValueOrMissingField_Skip_WithSchema

(final String value)

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicTest.java:238

MethodfieldName_NullOrEmptyValue_NoSkip_Schemaless

(final String value)

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicTest.java:223

MethodfieldName_NullOrEmptyValue_NoSkip_WithSchema

(final String value)

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicTest.java:206

MethodfieldName_NullStruct

()

src/test/java/io/aiven/kafka/connect/transforms/HashTest.java:187

MethodfieldName_NullValue_NoSkip

()

src/test/java/io/aiven/kafka/connect/transforms/HashTest.java:131

MethodfieldName_NullValue_Skip

()

src/test/java/io/aiven/kafka/connect/transforms/HashTest.java:152

MethodfieldName_Schemaless_NonMap

(final boolean skipMissingOrNull)

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicTest.java:147

MethodfieldName_Schemaless_NullStruct

(final boolean skipMissingOrNull)

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicTest.java:168

MethodfieldName_Schemaless_UnsupportedSchemaTypeInField

(final boolean skipMissingOrNull)

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicTest.java:192

MethodfieldName_UnsupportedTypeInField

()

src/test/java/io/aiven/kafka/connect/transforms/HashTest.java:198

MethodfieldName_WithSchema_NonStruct

(final boolean skipMissingOrNull)

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicTest.java:138

MethodfieldName_WithSchema_NullStruct

(final boolean skipMissingOrNull)

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicTest.java:156

MethodfieldName_WithSchema_UnsupportedSchemaTypeInField

(final boolean skipMissingOrNull)

src/test/java/io/aiven/kafka/connect/transforms/ExtractTopicTest.java:177

MethodfieldNames

()

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

MethodgetConfig

()

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

MethodgetSchemaAndValue

(final R record)

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

MethodgetSchemaAndValue

(final R record)

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

MethodgetSchemaAndValue

(final R record)

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

MethodgetSchemaAndValue

(final R record)

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

MethodgetSchemaAndValue

(final R record)

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

MethodgetSchemaAndValue

(final R record)

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

MethodgetSchemaAndValue

(final R record)

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

MethodgetSchemaAndValue

(final R record)

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

MethodgetSchemaAndValue

(final R record)

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

MethodhasDefaultValue

()

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

MethodhasDefaultValue

()

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

MethodhashFunctionMd5

()

src/test/java/io/aiven/kafka/connect/transforms/HashConfigTest.java:50

MethodhashFunctionSha1

()

src/test/java/io/aiven/kafka/connect/transforms/HashConfigTest.java:58

MethodhashFunctionSha256

()

src/test/java/io/aiven/kafka/connect/transforms/HashConfigTest.java:66

Methodinit

()

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

MethodisOptional

()

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

MethodjdbcType

()

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

MethodjdbcType

()

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

MethodkeyOrValue

()

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

MethodkeyOrValue

()

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

MethodkeyOrValue

()

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

MethodkeyOrValue

()

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

Methodlength

()

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

MethodmapWithFieldOfIncorrectType

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTimestampTest.java:120

MethodmapWithIntField

(final ExtractTimestampConfig.TimestampResolution tsResolution)

src/test/java/io/aiven/kafka/connect/transforms/ExtractTimestampTest.java:190

MethodmapWithMissingField

()

src/test/java/io/aiven/kafka/connect/transforms/ConcatFieldsTest.java:119

MethodmapWithMissingField

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTimestampTest.java:80

MethodmapWithNullField

()

src/test/java/io/aiven/kafka/connect/transforms/ExtractTimestampTest.java:99

MethodmapWithSchema

()

src/test/java/io/aiven/kafka/connect/transforms/ConcatFieldsTest.java:165

MethodmapWithSchemaMissingField

()

src/test/java/io/aiven/kafka/connect/transforms/ConcatFieldsTest.java:185

MethodmapWithTimestampField

(final ExtractTimestampConfig.TimestampResolution tsResolution)

src/test/java/io/aiven/kafka/connect/transforms/ExtractTimestampTest.java:229

MethodmapWithoutSchema

()

src/test/java/io/aiven/kafka/connect/transforms/ConcatFieldsTest.java:127

MethodmapWithoutSchemaMissingField

()

src/test/java/io/aiven/kafka/connect/transforms/ConcatFieldsTest.java:147

Methodname

()

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

MethodnativeType

()

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

← previous next →201–300 of 448, ranked by callers