Functions — github.com/DarioBalinzo/kafka-connect-elasticsearch-source

hub / github.com/DarioBalinzo/kafka-connect-elasticsearch-source / functions

Functions149 in github.com/DarioBalinzo/kafka-connect-elasticsearch-source

⨍ Functions 149◇ Types & classes 37

↓ 66 callersMethodinsertMockData

(int tsStart)

src/test/java/com/github/dariobalinzo/TestContainersContext.java:90

↓ 41 callersMethodtoString

()

src/main/java/com/github/dariobalinzo/elastic/response/Cursor.java:29

↓ 22 callersMethodpoll

()

src/main/java/com/github/dariobalinzo/task/ElasticSourceTask.java:195

↓ 21 callersMethodbuild

()

src/main/java/com/github/dariobalinzo/elastic/ElasticConnectionBuilder.java:76

↓ 18 callersMethodfrom

(String elasticName)

src/main/java/com/github/dariobalinzo/schema/FieldNameConverter.java:21

↓ 16 callersMethodconvert

(Map<String, Object> elasticDocument, String schemaName)

src/main/java/com/github/dariobalinzo/schema/SchemaConverter.java:39

↓ 16 callersMethodrefreshIndex

()

src/test/java/com/github/dariobalinzo/TestContainersContext.java:86

↓ 15 callersMethoddeleteTestIndex

()

src/test/java/com/github/dariobalinzo/TestContainersContext.java:78

↓ 12 callersMethodgetConf

()

src/test/java/com/github/dariobalinzo/TestContainersContext.java:116

↓ 12 callersMethodstart

(Map<String, String> properties)

src/main/java/com/github/dariobalinzo/task/ElasticSourceTask.java:79

↓ 10 callersMethodstop

()

src/main/java/com/github/dariobalinzo/task/ElasticSourceTask.java:278

↓ 9 callersMethodgetDocuments

()

src/main/java/com/github/dariobalinzo/elastic/response/PageResult.java:33

↓ 9 callersMethodgetLastCursor

()

src/main/java/com/github/dariobalinzo/elastic/response/PageResult.java:37

↓ 7 callersMethodempty

()

src/test/java/com/github/dariobalinzo/task/MockOffsetFactory.java:27

↓ 6 callersMethodempty

()

src/main/java/com/github/dariobalinzo/elastic/response/Cursor.java:25

↓ 5 callersMethodcatIndices

(String prefix)

src/main/java/com/github/dariobalinzo/elastic/ElasticRepository.java:185

↓ 5 callersMethodgetClient

()

src/main/java/com/github/dariobalinzo/elastic/ElasticConnection.java:138

↓ 5 callersMethodgetPrimaryCursor

()

src/main/java/com/github/dariobalinzo/elastic/response/Cursor.java:17

↓ 5 callersMethodsearchAfter

(String index, Cursor cursor)

src/main/java/com/github/dariobalinzo/elastic/ElasticRepository.java:77

↓ 5 callersMethodsearchAfterWithSecondarySort

(String index, Cursor cursor)

src/main/java/com/github/dariobalinzo/elastic/ElasticRepository.java:114

↓ 4 callersMethodbuildGreaterThen

(String cursorField, String cursorValue)

src/main/java/com/github/dariobalinzo/elastic/ElasticRepository.java:149

↓ 4 callersMethodremoveKeywordSuffix

(String fieldName)

src/main/java/com/github/dariobalinzo/elastic/ElasticJsonNaming.java:4

↓ 3 callersMethodconvertDocumentSchema

(String prefixName, Map<String, Object> doc, SchemaBuilder schemaBuilder)

src/main/java/com/github/dariobalinzo/schema/SchemaConverter.java:46

↓ 3 callersMethodconvertDocumentStruct

(String prefixName, Map<String, Object> doc, Struct struct, Schema schema)

src/main/java/com/github/dariobalinzo/schema/StructConverter.java:41

↓ 3 callersMethodfilter

(Map<String, Object> document)

src/main/java/com/github/dariobalinzo/filter/DocumentFilter.java:23

↓ 3 callersMethodfrom

(String initialCursor)

src/test/java/com/github/dariobalinzo/task/MockOffsetFactory.java:31

↓ 3 callersMethodfrom

(String elasticName)

src/main/java/com/github/dariobalinzo/schema/AvroName.java:21

↓ 3 callersMethodindexes

()

src/main/java/com/github/dariobalinzo/elastic/ElasticIndexMonitorThread.java:64

↓ 3 callersMethodsetPageSize

(int pageSize)

src/main/java/com/github/dariobalinzo/elastic/ElasticRepository.java:225

↓ 3 callersMethodvisit

(Map<String, Object> document)

src/main/java/com/github/dariobalinzo/filter/JsonFilterVisitor.java:29

↓ 3 callersMethodwithBackoff

(long connectionRetryBackoff)

src/main/java/com/github/dariobalinzo/elastic/ElasticConnectionBuilder.java:59

↓ 3 callersMethodwithMaxAttempts

(int maxConnectionAttempts)

src/main/java/com/github/dariobalinzo/elastic/ElasticConnectionBuilder.java:54

↓ 2 callersMethodbaseConfigDef

()

src/main/java/com/github/dariobalinzo/ElasticSourceConnectorConfig.java:155

↓ 2 callersMethodcloseQuietly

()

src/main/java/com/github/dariobalinzo/elastic/ElasticConnection.java:150

↓ 2 callersMethodexecuteSearch

(SearchRequest searchRequest)

src/main/java/com/github/dariobalinzo/elastic/ElasticRepository.java:167

↓ 2 callersMethodextractDocuments

(SearchResponse response)

src/main/java/com/github/dariobalinzo/elastic/ElasticRepository.java:104

↓ 2 callersMethodfilter

(Map<String, Object> document)

src/main/java/com/github/dariobalinzo/filter/WhitelistFilter.java:40

↓ 2 callersMethodfilter

(Map<String, Object> document)

src/main/java/com/github/dariobalinzo/filter/BlacklistFilter.java:40

↓ 2 callersMethodfilterInvalidCharacters

(String elasticName)

src/main/java/com/github/dariobalinzo/schema/AvroName.java:29

↓ 2 callersMethodgetIndex

()

src/main/java/com/github/dariobalinzo/elastic/response/PageResult.java:41

↓ 2 callersMethodgetSecondaryCursor

()

src/main/java/com/github/dariobalinzo/elastic/response/Cursor.java:21

↓ 2 callersMethodgroupIndicesToTasksConfig

(int maxTasks, List<String> currentIndexes)

src/main/java/com/github/dariobalinzo/ElasticSourceConnector.java:135

↓ 2 callersMethodisScalar

(Object value)

src/main/java/com/github/dariobalinzo/schema/StructConverter.java:61

↓ 2 callersMethodshutdown

()

src/main/java/com/github/dariobalinzo/elastic/ElasticIndexMonitorThread.java:82

↓ 2 callersMethodstart

(Map<String, String> props)

src/main/java/com/github/dariobalinzo/ElasticSourceConnector.java:50

↓ 2 callersMethodstop

()

src/main/java/com/github/dariobalinzo/ElasticSourceConnector.java:148

↓ 2 callersMethodtaskConfigs

(int maxTasks)

src/main/java/com/github/dariobalinzo/ElasticSourceConnector.java:114

↓ 2 callersMethodvisitJsonDocument

(String prefixPathName, Map<String, Object> document)

src/main/java/com/github/dariobalinzo/filter/JsonFilterVisitor.java:33

↓ 2 callersMethodwithKeyStore

(String path, String password)

src/main/java/com/github/dariobalinzo/elastic/ElasticConnectionBuilder.java:70

↓ 2 callersMethodwithPassword

(String password)

src/main/java/com/github/dariobalinzo/elastic/ElasticConnectionBuilder.java:49

↓ 2 callersMethodwithProtocol

(String protocol)

src/main/java/com/github/dariobalinzo/elastic/ElasticConnectionBuilder.java:39

↓ 2 callersMethodwithTrustStore

(String path, String password)

src/main/java/com/github/dariobalinzo/elastic/ElasticConnectionBuilder.java:64

↓ 2 callersMethodwithUser

(String user)

src/main/java/com/github/dariobalinzo/elastic/ElasticConnectionBuilder.java:44

↓ 1 callersMethodaddConnectorOptions

(ConfigDef config)

src/main/java/com/github/dariobalinzo/ElasticSourceConnectorConfig.java:373

↓ 1 callersMethodaddDatabaseOptions

(ConfigDef config)

src/main/java/com/github/dariobalinzo/ElasticSourceConnectorConfig.java:163

↓ 1 callersMethodaddModeOptions

(ConfigDef config)

src/main/java/com/github/dariobalinzo/ElasticSourceConnectorConfig.java:328

↓ 1 callersMethodcastToJson

(Object value)

src/main/java/com/github/dariobalinzo/filter/JsonCastFilter.java:47

↓ 1 callersMethodconvertListOfObject

(String prefixName, SchemaBuilder schemaBuilder, String k, List<Map<String, Object>> list)

src/main/java/com/github/dariobalinzo/schema/SchemaConverter.java:132

↓ 1 callersMethodconvertListOfObject

(String prefixName, Schema schema, String key, Map<String, Object> doc)

src/main/java/com/github/dariobalinzo/schema/StructConverter.java:120

↓ 1 callersMethodconvertListSchema

(String prefixName, SchemaBuilder schemaBuilder, String k, Object item)

src/main/java/com/github/dariobalinzo/schema/SchemaConverter.java:93

↓ 1 callersMethodconvertListToAvroArray

(String prefixName, Struct struct, Schema schema, Map.Entry<String, Object> entry)

src/main/java/com/github/dariobalinzo/schema/StructConverter.java:79

↓ 1 callersMethodconvertMapSchema

(String prefixName, SchemaBuilder schemaBuilder, Map.Entry<String, Object> entry)

src/main/java/com/github/dariobalinzo/schema/SchemaConverter.java:83

↓ 1 callersMethodcovertMapToAvroStruct

(String prefixName, Struct struct, Schema schema, Map.Entry<String, Object> entry)

src/main/java/com/github/dariobalinzo/schema/StructConverter.java:106

↓ 1 callersMethodcreateConnection

()

src/main/java/com/github/dariobalinzo/elastic/ElasticConnection.java:82

↓ 1 callersMethodfetchLastOffset

(String index)

src/main/java/com/github/dariobalinzo/task/ElasticSourceTask.java:222

↓ 1 callersMethodfilter

(Map<String, Object> document)

src/main/java/com/github/dariobalinzo/filter/JsonCastFilter.java:34

↓ 1 callersMethodfilterElement

(String fieldPath, Object value)

src/main/java/com/github/dariobalinzo/filter/JsonElementFilter.java:20

↓ 1 callersMethodfindTaskFromIndexPrefix

(int maxTasks)

src/main/java/com/github/dariobalinzo/ElasticSourceConnector.java:130

↓ 1 callersMethodgenerateTaskFromFixedList

(List<String> indicesList, int maxTasks)

src/main/java/com/github/dariobalinzo/ElasticSourceConnector.java:125

↓ 1 callersMethodgetConnectionRetryBackoff

()

src/main/java/com/github/dariobalinzo/elastic/ElasticConnection.java:142

↓ 1 callersMethodgetMaxConnectionAttempts

()

src/main/java/com/github/dariobalinzo/elastic/ElasticConnection.java:146

↓ 1 callersMethodgetSecondarySortFieldQuery

(String primaryCursor, String secondaryCursor)

src/main/java/com/github/dariobalinzo/elastic/ElasticRepository.java:153

↓ 1 callersMethodgetSslContext

(String trustStoreConf, String trustStorePass, String keyStoreConf, String keySto

src/main/java/com/github/dariobalinzo/elastic/ElasticConnection.java:101

↓ 1 callersMethodgroupPartitions

(List<String> currentIndices, int numGroups)

src/main/java/com/github/dariobalinzo/ElasticSourceConnector.java:166

↓ 1 callersMethodhandleNumericPrecision

(Object value)

src/main/java/com/github/dariobalinzo/schema/StructConverter.java:70

↓ 1 callersMethodinitConnectorFieldConverter

()

src/main/java/com/github/dariobalinzo/task/ElasticSourceTask.java:130

↓ 1 callersMethodinitConnectorFilters

()

src/main/java/com/github/dariobalinzo/task/ElasticSourceTask.java:107

↓ 1 callersMethodinitEsConnection

()

src/main/java/com/github/dariobalinzo/task/ElasticSourceTask.java:147

↓ 1 callersMethodoffset

(Map<String, T> map)

src/test/java/com/github/dariobalinzo/task/MockOffsetFactory.java:43

↓ 1 callersMethodparseHosts

(String hosts, String protocol, int port)

src/main/java/com/github/dariobalinzo/elastic/ElasticConnection.java:132

↓ 1 callersMethodparseResult

(PageResult pageResult, List<SourceRecord> results)

src/main/java/com/github/dariobalinzo/task/ElasticSourceTask.java:239

↓ 1 callersMethodtoMapOffset

(String primaryCursor, String secondaryCursor, Map<String, Object> document)

src/main/java/com/github/dariobalinzo/task/OffsetSerializer.java:11

↓ 1 callersMethodtoStringOffset

(String cursor, String secondaryCursor, String index, Map<String, Object> document)

src/main/java/com/github/dariobalinzo/task/OffsetSerializer.java:20

↓ 1 callersMethodupdateIndexes

()

src/main/java/com/github/dariobalinzo/elastic/ElasticIndexMonitorThread.java:86

↓ 1 callersMethodversion

()

src/main/java/com/github/dariobalinzo/ElasticSourceConnector.java:45

↓ 1 callersMethodvisitNestedList

(String prefixPathName, List<Object> nestedList)

src/main/java/com/github/dariobalinzo/filter/JsonFilterVisitor.java:56

↓ 1 callersMethodvisitNestedMap

(String prefixPathName, Object item)

src/main/java/com/github/dariobalinzo/filter/JsonFilterVisitor.java:60

MethodBlacklistFilter

(Set<String> fieldsToRemove)

src/main/java/com/github/dariobalinzo/filter/BlacklistFilter.java:26

MethodCursor

(String primaryCursor, String secondaryCursor)

src/main/java/com/github/dariobalinzo/elastic/response/Cursor.java:7

MethodElasticConnection

(ElasticConnectionBuilder builder)

src/main/java/com/github/dariobalinzo/elastic/ElasticConnection.java:53

MethodElasticConnectionBuilder

(String hosts, int port)

src/main/java/com/github/dariobalinzo/elastic/ElasticConnectionBuilder.java:34

MethodElasticIndexMonitorThread

(ConnectorContext context, long pollMs, ElasticRepository elasticRepository, String prefix)

src/main/java/com/github/dariobalinzo/elastic/ElasticIndexMonitorThread.java:28

MethodElasticRepository

(ElasticConnection elasticConnection)

src/main/java/com/github/dariobalinzo/elastic/ElasticRepository.java:53

MethodElasticSourceConnectorConfig

(Map<String, String> properties)

src/main/java/com/github/dariobalinzo/ElasticSourceConnectorConfig.java:417

MethodElasticSourceTaskConfig

(Map<String, String> props)

src/main/java/com/github/dariobalinzo/task/ElasticSourceTaskConfig.java:36

MethodJsonCastFilter

(Set<String> fieldsToCast)

src/main/java/com/github/dariobalinzo/filter/JsonCastFilter.java:29

MethodJsonFilterVisitor

(JsonElementFilter businessLogic)

src/main/java/com/github/dariobalinzo/filter/JsonFilterVisitor.java:25

MethodPageResult

(String index, List<Map<String, Object>> documents, Cursor cursor)

src/main/java/com/github/dariobalinzo/elastic/response/PageResult.java:27

MethodSchemaConverter

(FieldNameConverter converter)

src/main/java/com/github/dariobalinzo/schema/SchemaConverter.java:35

MethodSslContextException

(Exception e)

src/main/java/com/github/dariobalinzo/elastic/SslContextException.java:4

next →1–100 of 149, ranked by callers