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

↓ 95 callersMethodapply

(final R record)

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

↓ 51 callersMethodof

(final String v)

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

↓ 31 callersMethodconfigure

(final Map<String, ?> configs)

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

↓ 25 callersMethodrecord

(final Schema schema, final Object data)

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

↓ 25 callersMethodtransformation

(final String fieldName, final boolean skipMissingOrNull)

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

↓ 23 callersMethodtoString

()

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

↓ 18 callersMethodname

()

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

↓ 16 callersMethodrecord

(final Schema schema, final Object data)

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

↓ 16 callersMethodtransformation

( final String fieldName, final boolean skipMissingOrNull, final String ha

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

↓ 15 callersMethodrecord

(final Schema schema, final Object data)

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

↓ 15 callersMethodtest

(final R record)

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

↓ 15 callersMethodtransformation

()

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

↓ 14 callersMethodconfigure

(final Map<String, ?> configs)

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

↓ 14 callersMethoddataPlace

()

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

↓ 12 callersMethodrecord

(final Schema schema, final Object data)

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

↓ 12 callersMethodtransformation

()

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

↓ 8 callersMethoddataPlace

()

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

↓ 7 callersMethodcreateStruct

Build a test {@link Struct} from a list of field names and values, inferring the schema from the values. @param kvs A list of alternating keys and va

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

↓ 7 callersMethodskipMissingOrNull

()

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

↓ 6 callersMethodassertRecordFieldMatches

( final SchemaAndValue schemaAndValue, final String fieldName, final String expected)

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

↓ 6 callersMethodconverterFor

(final RelationalColumn column, final CustomConverter.ConverterRegistration<Schem

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

↓ 6 callersMethodsetNewTimestamp

(final SinkRecord record, final long newTimestamp)

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

↓ 6 callersMethodsetNewTopic

(final SinkRecord record, final String newTopic)

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

↓ 6 callersMethodsetNewValue

(final SinkRecord record, final Schema newValueSchema,

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

↓ 5 callersMethodapply

(final R record)

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

↓ 5 callersMethodfieldName

()

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

↓ 5 callersMethodhash

(final String function, final String value)

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

↓ 5 callersMethodhashFunction

()

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

↓ 5 callersMethodprepareRecord

( final Supplier<Object> keySupplier, final Supplier<Object> valueSupplier )

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

↓ 5 callersMethodsetNewValue

(final SinkRecord record, final Object newValue)

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

↓ 5 callersMethodstructRecord

(final String state)

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

↓ 4 callersMethodcreateConnector

(final Map<String, String> config)

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

↓ 4 callersMethoddataPlace

()

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

↓ 4 callersMethodencode

Encodes a byte array as a hexadecimal string. @implNote https://stackoverflow.com/a/9855338/1781549

src/main/java/io/aiven/kafka/connect/transforms/utils/Hex.java:26

↓ 4 callersMethodprepareStructRecord

( final Consumer<Struct> keyChanges, final Consumer<Struct> valueChanges )

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

↓ 4 callersMethodrecord

(final Schema keySchema, final Object key, fin

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

↓ 4 callersMethodresolution

()

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

↓ 4 callersMethodtimestampResolution

()

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

↓ 4 callersMethodtransformation

(final Map<String, ?> configs)

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

↓ 4 callersMethodvalueTransform

(final String fieldNames, final String transformCase)

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

↓ 3 callersMethodfieldName

()

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

↓ 3 callersMethodfieldNames

()

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

↓ 3 callersMethodkeyOrValue

()

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

↓ 3 callersMethodnewBehaviorProps

(final String bv)

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

↓ 3 callersMethodoperatingValue

(R record)

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

↓ 3 callersMethodrecord

(final Schema keySchema, final Object key, fin

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

↓ 3 callersMethodwaitForCondition

(final Supplier<Boolean> conditionChecker, final long maxWaitMs,

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

↓ 2 callersMethodapply

(final R record)

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

↓ 2 callersMethodcheckMessageTopics

(final TopicPartition originalTopicPartition, final TopicPartition newTopicPartition)

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

↓ 2 callersMethodclose

()

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

↓ 2 callersMethodconfig

()

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

↓ 2 callersMethodconfig

()

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

↓ 2 callersMethodconfig

()

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

↓ 2 callersMethodconfig

()

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

↓ 2 callersMethodconfig

()

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

↓ 2 callersMethodconfig

()

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

↓ 2 callersMethodconfig

()

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

↓ 2 callersMethodconfig

()

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

↓ 2 callersMethoddataPlace

()

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

↓ 2 callersMethoddataPlace

()

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

↓ 2 callersMethoddelimiter

()

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

↓ 2 callersMethodfieldReplaceMissing

()

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

↓ 2 callersMethodfromString

(final String value)

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

↓ 2 callersMethodgetBehavior

()

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

↓ 2 callersMethodgetNewValue

(final R record, final SchemaAndValue schemaAndValue)

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

↓ 2 callersMethodhashString

(final String string)

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

↓ 2 callersMethodisOptional

()

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

↓ 2 callersMethodkeyTransform

(final String fieldNames, final String transformCase)

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

↓ 2 callersMethodlength

()

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

↓ 2 callersMethodoutputFieldName

()

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

↓ 2 callersMethodpoll

()

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

↓ 2 callersMethodrecord

(final Object value)

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

↓ 2 callersMethodregEx

()

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

↓ 2 callersMethodschemaNameToTopicMap

()

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

↓ 2 callersMethodskipMissingOrNull

()

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

↓ 2 callersMethodtombstoneHandler

(final Behavior b)

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

↓ 1 callersMethodapply

(final R record)

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

↓ 1 callersMethodapplyMap

Apply the case transformation to given map from the map field. @param newValue The mutable map @param fieldName The field name to case transform

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

↓ 1 callersMethodapplySchemaless

(final R record)

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

↓ 1 callersMethodapplyStruct

Apply the case transformation to given new struct from the original struct field. @param newStruct New struct @param fieldName The field name to case

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

↓ 1 callersMethodapplyToMap

(final R record)

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

↓ 1 callersMethodapplyToStruct

Merges the key and value schemas into a new schema, according to the configuration. @param record The incoming record to be transformed. @param ke

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

↓ 1 callersMethodapplyWithSchema

(final R record)

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

↓ 1 callersMethodawaitStop

()

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

↓ 1 callersMethodbehaveOnNull

(final ConnectRecord<R> r)

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

↓ 1 callersMethodcheckMessageTransformInTopic

(final TopicPartition topicPartition, final long expectedNumberOfMessages)

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

↓ 1 callersMethodcompilePattern

(final String pattern)

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

↓ 1 callersMethodconfig

()

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

↓ 1 callersMethodconfig

()

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

↓ 1 callersMethodconfigure

(final Map<String, ?> configs)

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

↓ 1 callersMethodcreateConnectRecord

(final R record, final String newTopicName)

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

↓ 1 callersMethodcreateNewRecord

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

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

↓ 1 callersMethodcreateNewRecord

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

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

↓ 1 callersMethodcreateTransformationObject

()

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

↓ 1 callersMethodcreateTransformationObject

()

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

↓ 1 callersMethodcreateTransformationObject

()

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

↓ 1 callersMethodcreateTransformationObject

()

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

↓ 1 callersMethoddataPlace

()

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

↓ 1 callersMethoddataPlace

()

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

↓ 1 callersMethoddataPlace

()

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

next →1–100 of 448, ranked by callers