MCPcopy Create free account

hub / github.com/decodableco/examples / functions

Functions200 in github.com/decodableco/examples

⨍ Functions 200◇ Types & classes 66↳ Endpoints 1
Method__init__
(self)
pyflink-intro/apps/embeddings/main.py:51
Methodaccumulate
(ArrayAccumulator<T> acc, T o)
array-agg-postgres/src/main/java/co/decodable/demos/arrayagg/ArrayAggr.java:45
MethodaddReview
(Review review)
pyflink-vector-embeddings/reviews-app/src/main/java/co/decodable/examples/ReviewResource.java:24
MethodclearTestSink
()
testing-cupi/src/test/java/co/decodable/examples/FruitEnricherJobTest.java:61
MethodcreateAccumulator
()
array-agg-postgres/src/main/java/co/decodable/demos/arrayagg/ArrayAggr.java:28
MethodcreateTypeInfo
(Type t, Map<String, TypeInformation<?>> genericParameters)
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/typeinfo/TxDataCollectionTypeInfoFactory.java:15
MethodcreateTypeInfo
(Type t, Map<String, TypeInformation<?>> genericParameters)
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/typeinfo/TxBufferTypeInfoFactory.java:14
MethodcreateWriter
(InitContext context)
testing-cupi/src/test/java/co/decodable/examples/FruitEnricherJobTest.java:106
Methoddeserialize
(ConsumerRecord<byte[], byte[]> record, Collector<CdcEvent> out)
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/serde/DeserializationSchemaCdcEvents.java:22
Methoddeserialize
(JsonParser p, DeserializationContext ctxt)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/common/deserialization/MessageDeserializer.java:41
Methodencode
(String text)
pyflink-vector-embeddings/model-serving-app/src/main/java/co/decodable/examples/HuggingFaceEmbeddingResource.java:21
Methodenrich
(FruitIntake intake)
testing-cupi/src/test/java/co/decodable/examples/FruitEnricherJobTest.java:68
Methodequals
(Object obj)
sql-cupi-hybrid/cupi/src/main/java/co/decodable/model/Nutritions.java:46
Methodequals
(Object obj)
sql-cupi-hybrid/cupi/src/main/java/co/decodable/model/FruitEnriched.java:30
Methodequals
(Object obj)
sql-cupi-hybrid/cupi/src/main/java/co/decodable/model/FruitIntake.java:30
Methodequals
(Object obj)
testing-cupi/src/main/java/co/decodable/model/FruitEnriched.java:32
Methodequals
(Object obj)
testing-cupi/src/main/java/co/decodable/model/FruitIntake.java:32
Methodequals
(Object obj)
array-agg-postgres/src/main/java/co/decodable/demos/arrayagg/ArrayAccumulator.java:23
Methodeval
(self, text)
pyflink-vector-embeddings/pyflink-app/main.py:19
Methodeval
(self, text)
pyflink-vector-embeddings/pyflink-app/main.py:35
Methodeval
(self,url)
pyflink-intro/apps/embeddings/main.py:18
Methodeval
(self, text)
pyflink-intro/apps/embeddings/main.py:39
Methodeval
(self, text)
pyflink-intro/apps/embeddings/main.py:60
MethodgetAfter
()
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/common/model/ChangeEvent.java:73
MethodgetAuditData
()
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/common/model/ChangeEvent.java:97
MethodgetBefore
()
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/common/model/ChangeEvent.java:65
MethodgetBeginMarker
()
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/CdcTxBuffer.java:31
MethodgetBuffer
()
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/CdcTxBuffer.java:23
MethodgetEndMarker
()
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/CdcTxBuffer.java:40
MethodgetKey
(CdcEvent event)
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/TxIdKeySelector.java:13
MethodgetProducedType
()
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/serde/DeserializationSchemaCdcEvents.java:17
MethodgetTransaction
()
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/common/model/ChangeEvent.java:89
MethodgetTs_ms
()
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/common/model/ChangeEvent.java:49
MethodgetTypeInference
(DataTypeFactory typeFactory)
array-agg-postgres/src/main/java/co/decodable/demos/arrayagg/ArrayAggr.java:61
Functionget_user_name
(id)
pyflink-decodable/main.py:32
Functionhandle_dict
(key:str=None, value=None, parent=None)
util/schemas/helper.py:3
Functionhandle_field
(key:str=None, value=None, parent=None)
util/schemas/helper.py:8
Functionhandle_list
(key:str=None, value=None, parent=None)
util/schemas/helper.py:6
MethodhashCode
()
sql-cupi-hybrid/cupi/src/main/java/co/decodable/model/Nutritions.java:28
MethodhashCode
()
sql-cupi-hybrid/cupi/src/main/java/co/decodable/model/FruitEnriched.java:21
MethodhashCode
()
sql-cupi-hybrid/cupi/src/main/java/co/decodable/model/FruitIntake.java:21
MethodhashCode
()
testing-cupi/src/main/java/co/decodable/model/Nutritions.java:30
MethodhashCode
()
testing-cupi/src/main/java/co/decodable/model/FruitEnriched.java:23
MethodhashCode
()
testing-cupi/src/main/java/co/decodable/model/FruitIntake.java:23
MethodhashCode
()
array-agg-postgres/src/main/java/co/decodable/demos/arrayagg/ArrayAccumulator.java:18
Methodinitialize
()
testing-cupi/src/test/java/co/decodable/examples/HttpNutritionEnricherTest.java:18
MethodinitializeState
(FunctionInitializationContext functionInitializationContext)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/auditing/AuditMain.java:133
Functionlambda_handler
(event, context)
s3events/lambda.py:13
Functionlambda_handler
(event, context)
influxdb/lambda_function.py:9
MethodlistReviews
()
pyflink-vector-embeddings/reviews-app/src/main/java/co/decodable/examples/ReviewResource.java:19
Methodmain
(String[] args)
github-webhooks/NameGen.java:20
Methodmain
(String[] args)
flink-on-kubernetes/hello-world-job/src/main/java/co/decodable/demos/flinkhelloworld/DataStreamJob.java:44
Methodmain
(String[] args)
pulsar/java/app/src/main/java/pulsar/App.java:18
Methodmain
(String[] args)
sql-cupi-hybrid/cupi/src/main/java/co/decodable/examples/FruitEnricherJob.java:22
Methodmain
(String[] args)
testing-cupi/src/main/java/co/decodable/examples/FruitEnricherJob.java:55
Methodmain
(String[] args)
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/CdcTxBufferingJob.java:30
Methodmain
(String[] args)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/auditing/AuditMain.java:46
Methodmain
(String[] args)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/outbox/OutboxMain.java:44
Methodmain
(String[] args)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/advanceslot/AdvanceSlotMain.java:28
MethodonTimer
(long timestamp, OnTimerContext ctx, Collector<TxBuffer> out)
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/CdcTxBufferingLogic.java:161
Methodopen
(self, function_context: FunctionContext)
pyflink-vector-embeddings/pyflink-app/main.py:32
Methodopen
(self, function_context: FunctionContext)
pyflink-intro/apps/embeddings/main.py:30
Methodopen
(self, function_context: FunctionContext)
pyflink-intro/apps/embeddings/main.py:54
Methodopen
(Configuration parameters)
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/CdcTxBufferingLogic.java:62
Methodopen
(Configuration parameters)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/auditing/AuditMain.java:115
Methodopen
(InitializationContext context, KafkaSinkContext sinkContext)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/outbox/OutboxMain.java:104
Methodopen
(Configuration parameters)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/outbox/OutboxMain.java:127
MethodprocessBroadcastElement
(String rawTxMetaEvent, KeyedBroadcastProcessFunction<String, CdcEvent, String, TxBuffer>.Context
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/CdcTxBufferingLogic.java:99
MethodprocessElement
(CdcEvent rawEvent, KeyedBroadcastProcessFunction<String, CdcEvent, String, TxBuffer>.ReadOnlyCont
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/CdcTxBufferingLogic.java:70
MethodresetAccumulator
(ArrayAccumulator<T> acc)
array-agg-postgres/src/main/java/co/decodable/demos/arrayagg/ArrayAggr.java:57
Methodretract
(ArrayAccumulator<T> acc, T o)
array-agg-postgres/src/main/java/co/decodable/demos/arrayagg/ArrayAggr.java:51
Methodserialize
( TxBuffer record, KafkaSinkContext context, Long timestamp)
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/serde/SerializationSchemaTxBuffer.java:22
Methodserialize
(ChangeEvent element, KafkaSinkContext context, Long timestamp)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/outbox/OutboxMain.java:86
MethodsetAfter
(JsonNode after)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/common/model/ChangeEvent.java:77
MethodsetBefore
(JsonNode before)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/common/model/ChangeEvent.java:69
MethodsetBuffer
(Map<String,Map<Integer,CdcEvent>> buffer)
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/CdcTxBuffer.java:27
MethodsetCompleted
(boolean completed)
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/CdcTxBuffer.java:64
MethodsetKey
(String key)
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/model/CdcEvent.java:20
MethodsetMessage
(Message message)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/common/model/ChangeEvent.java:85
MethodsetOp
(String op)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/common/model/ChangeEvent.java:45
MethodsetSource
(JsonNode source)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/common/model/ChangeEvent.java:61
MethodsetState
(JsonNode state)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/auditing/model/AuditState.java:42
MethodsetTs_ms
(long ts_ms)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/common/model/ChangeEvent.java:53
MethodsetTxId
(String txId)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/auditing/model/AuditState.java:34
MethodsetValue
(String value)
tx-aware-cdc-buffering/flink-datastream-poc/src/main/java/co/decodable/examples/cdc/txbuffering/model/CdcEvent.java:28
MethodshouldEnrichFruitIntakeEvents
()
testing-cupi/src/test/java/co/decodable/examples/FruitEnricherJobTest.java:29
MethodshouldEnrichFruitIntakeEvents
()
testing-cupi/src/test/java/co/decodable/examples/FruitEnricherJobIntegrationTest.java:32
Functionshow
(si)
oracle_cdc/kinesis.py:23
MethodsnapshotState
(FunctionSnapshotContext functionSnapshotContext)
postgres-logical-decoding/src/main/java/co/decodable/examples/logicaldecoding/auditing/AuditMain.java:123
MethodtestAnyFruitWithNonExistantApiEndpoint
(String anyFruitName)
testing-cupi/src/test/java/co/decodable/examples/HttpNutritionEnricherTest.java:48
MethodtestInvalidFruitWithExternalApi
(String invalidFruitName)
testing-cupi/src/test/java/co/decodable/examples/HttpNutritionEnricherTest.java:36
MethodtestInvalidFruitWithMockedApi
(String invalidFruitName)
testing-cupi/src/test/java/co/decodable/examples/MockNutritionEnricherTest.java:45
MethodtestValidFruitWithExternalApi
(String validFruitName)
testing-cupi/src/test/java/co/decodable/examples/HttpNutritionEnricherTest.java:24
MethodtestValidFruitWithMockedApi
(String validFruitName)
testing-cupi/src/test/java/co/decodable/examples/MockNutritionEnricherTest.java:25
MethodtoString
()
sql-cupi-hybrid/cupi/src/main/java/co/decodable/model/Nutritions.java:22
MethodtoString
()
sql-cupi-hybrid/cupi/src/main/java/co/decodable/model/FruitEnriched.java:16
MethodtoString
()
sql-cupi-hybrid/cupi/src/main/java/co/decodable/model/FruitIntake.java:16
MethodtoString
()
testing-cupi/src/main/java/co/decodable/model/Nutritions.java:24
MethodtoString
()
testing-cupi/src/main/java/co/decodable/model/FruitEnriched.java:18
MethodtoString
()
testing-cupi/src/main/java/co/decodable/model/FruitIntake.java:18
← previous101–200 of 200, ranked by callers