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

MethodnativeType

()

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

MethodnoFieldName_EmptyStringValue

(final String hashFunction)

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

MethodnoFieldName_NormalBooleanValue

(final boolean withSchema)

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

MethodnoFieldName_NormalInt64Value

(final boolean withSchema)

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

MethodnoFieldName_NormalStringValue

(final boolean withSchema)

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

MethodnoFieldName_NormalStringValue

(final String hashFunction)

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

MethodnoFieldName_NullOrEmptyValue_NoSkip_Schemaless

(final String value)

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

MethodnoFieldName_NullOrEmptyValue_NoSkip_WithSchema

(final String value)

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

MethodnoFieldName_NullOrEmptyValue_Skip_Schemaless

(final String value)

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

MethodnoFieldName_NullOrEmptyValue_Skip_WithSchema

(final String value)

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

MethodnoFieldName_NullValue_NoSkip

()

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

MethodnoFieldName_NullValue_Skip

()

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

MethodnoFieldName_UnsupportedSchemaType

(final boolean skipMissingOrNull)

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

MethodnoFieldName_UnsupportedType

()

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

MethodnoFieldName_UnsupportedValueType

(final boolean skipMissingOrNull)

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

MethodnullSchema

(final boolean skipMissingOrNull)

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

MethodnullSchema

()

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

MethodonCompletion

(final Throwable error, final Herder.Created<ConnectorInfo> info)

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

MethodoperatingSchema

(final R record)

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

MethodoperatingSchema

(final R record)

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

MethodoperatingValue

(final R record)

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

MethodoperatingValue

(final R record)

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

Methodpoll

()

src/integration-test/java/io/aiven/kafka/connect/transforms/TestCaseTransformConnector.java:56

Methodpoll

()

src/integration-test/java/io/aiven/kafka/connect/transforms/TestKeyToValueConnector.java:58

Methodpoll

()

src/integration-test/java/io/aiven/kafka/connect/transforms/TopicFromValueSchemaConnector.java:67

Methodrecord

(final Schema schema, final Object data)

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

Methodrecord

(final Schema schema, final Object data)

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

Methodrecord

(final Schema schema, final Object data)

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

Methodrecord

(final Schema schema, final Object data)

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

Methodrecord

(final Schema schema, final Object data)

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

Methodrecord

(final Schema schema, final Object data)

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

Methodrecord

(final Schema schema, final Object data)

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

Methodrecord

(final Schema schema, final Object data)

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

MethodrecordMapNull

()

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

MethodrecordMapNull

()

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

MethodrecordNotStructOrMap

()

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

MethodrecordNotStructOrMap

()

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

MethodrecordProvider

()

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

MethodrecordStructNull

()

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

MethodrecordStructNull

()

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

MethodregexConfigValueAfterLastDotToTopicTest

()

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

MethodregexNoMatchToTopicTest

()

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

MethodsameValueSameHash

(final String hashFunction)

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

Methodscale

()

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

Methodscale

()

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

MethodschemaIntToSchemaStructWholeKey

()

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

MethodschemaIntToSchemaStructWholeKeyWithRenaming

()

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

MethodschemaName

(final R record)

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

MethodschemaStructToSchemaStruct

()

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

MethodschemaStructToSchemaStructWholeKey

()

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

MethodschemaStructToSchemaStructWithRenaming

()

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

MethodschemalessIntToSchemaStructWholeKey

()

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

MethodschemalessMapToSchemalessMap

()

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

MethodsetNewValue

(final SinkRecord record, final Schema newValueSchema, final Object newValue)

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

MethodsetNewValue

(final SinkRecord record, final Schema newValueSchema, final Object newValue)

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

MethodsetNewValue

(final SinkRecord record, final Object newValue)

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

MethodsetNewValue

(final SinkRecord record, final Object newValue)

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

MethodsetUp

()

src/integration-test/java/io/aiven/kafka/connect/transforms/IntegrationTest.java:127

MethodsetUpAll

()

src/integration-test/java/io/aiven/kafka/connect/transforms/IntegrationTest.java:81

MethodshouldDoNothingIfColumnIsNotMoney

()

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

MethodshouldDoNothingIfColumnIsOptional

()

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

MethodshouldDropTombstoneRecord

()

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

MethodshouldFailIfDataIsMissing

()

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

MethodshouldFailIfDataIsNotBigDecimal

()

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

MethodshouldFailWhenBothValueAndPatternAreSet

()

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

MethodshouldFailWhenNeitherValueNorPatternIsSet

()

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

MethodshouldFailWithConfigExceptionOnInvalidRegex

()

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

MethodshouldFilterOutKeyRecordsEqualsToId

()

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

MethodshouldFilterOutKeyRecordsNotEqualsToId

()

src/test/java/io/aiven/kafka/connect/transforms/FilterByFieldValueTest.java:114

MethodshouldFilterOutMapKeyRecordsWithRegex

()

src/test/java/io/aiven/kafka/connect/transforms/FilterByFieldValueTest.java:159

MethodshouldFilterOutMapValueRecordsWithRegex

()

src/test/java/io/aiven/kafka/connect/transforms/FilterByFieldValueTest.java:141

MethodshouldFilterOutRawKeyRecords

()

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

MethodshouldFilterOutRawNumericValueRecords

()

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

MethodshouldFilterOutRawValueRecords

()

src/test/java/io/aiven/kafka/connect/transforms/FilterByFieldValueTest.java:194

MethodshouldFilterOutValueRecordsEqualsToReadEvents

()

src/test/java/io/aiven/kafka/connect/transforms/FilterByFieldValueTest.java:36

MethodshouldFilterOutValueRecordsNotEqualsReadEvents

()

src/test/java/io/aiven/kafka/connect/transforms/FilterByFieldValueTest.java:87

MethodshouldFormatDataToMoneyFormat

()

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

MethodshouldMakeTombstone

()

src/test/java/io/aiven/kafka/connect/transforms/MakeTombstoneTest.java:28

MethodshouldMatchEmptyStringValue

()

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

MethodshouldMatchNestedFieldContainingDotUsingBacktick

()

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

MethodshouldMatchNumericFieldValue

()

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

MethodshouldMatchWhenNestedFieldEqualsValue

()

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

MethodshouldMatchWholeValueWhenFieldIsEmpty

()

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

MethodshouldMatchWithRegex

()

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

MethodshouldNotMatchTombstoneValue

()

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

MethodshouldNotMatchWhenFieldConfiguredButValueIsNotStructOrMap

()

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

MethodshouldNotMatchWhenNestedFieldIsMissing

()

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

MethodshouldRegisterCorrectSchema

()

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

MethodshouldRequireFullMatchForRegex

()

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

MethodshouldSupportSchemalessValues

()

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

MethodshouldThrowDataAccessExceptionOnTombstoneRecords

()

src/test/java/io/aiven/kafka/connect/transforms/TombstoneHandlerTest.java:41

MethodskipMissingOrNull

(final boolean skipMissingOrNull)

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

MethodskipMissingOrNull

(final boolean skipMissingOrNull)

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

Methodstart

(final Map<String, String> props)

src/integration-test/java/io/aiven/kafka/connect/transforms/TestSourceConnector.java:56

Methodstart

(final Map<String, String> props)

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

Methodstart

(final Map<String, String> props)

src/integration-test/java/io/aiven/kafka/connect/transforms/TestCaseTransformConnector.java:52

Methodstart

(final Map<String, String> props)

src/integration-test/java/io/aiven/kafka/connect/transforms/TestKeyToValueConnector.java:54

Methodstart

(final Map<String, String> props)

src/integration-test/java/io/aiven/kafka/connect/transforms/TopicFromValueSchemaConnector.java:62

Methodstop

()

src/integration-test/java/io/aiven/kafka/connect/transforms/TestSourceConnector.java:80

Methodstop

()

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

← previous next →301–400 of 448, ranked by callers