MCPcopy Create free account

hub / github.com/RealtimeCompute/ververica-connector-demo / functions

Functions33 in github.com/RealtimeCompute/ververica-connector-demo

⨍ Functions 33◇ Types & classes 19
↓ 4 callersMethodcreateConfiguration
()
ververica-connector-hologres-demo/src/main/java/com/alibaba/ververica/connector/demo/HologresDemoUtil.java:8
↓ 2 callersMethodgetRecordEntry
(Long message, String s)
ververica-connector-datahub-demo/src/main/java/com/alibaba/ververica/connector/demo/DatahubSinkDemo.java:63
↓ 1 callersMethodbuildHologresAsyncLookUpFunction
( TableSchema schema, Configuration config, HologresConnectionParam hologr
ververica-connector-hologres-demo/src/main/java/com/alibaba/ververica/connector/demo/HologresDimDemo.java:76
↓ 1 callersMethodcreateRocketMQOutputFormat
(ParameterTool parameters)
ververica-connector-rocketmq-demo/src/main/java/com/alibaba/ververica/connector/demo/RocketMQDataStreamDemo.java:102
↓ 1 callersMethodcreateRocketMQSource
(ParameterTool parameters)
ververica-connector-rocketmq-demo/src/main/java/com/alibaba/ververica/connector/demo/RocketMQDataStreamDemo.java:68
↓ 1 callersMethodcreateSinkMQProperties
(ParameterTool parameters)
ververica-connector-rocketmq-demo/src/main/java/com/alibaba/ververica/connector/demo/RocketMQDataStreamDemo.java:121
↓ 1 callersMethodcreateSourceMQProperties
(ParameterTool parameters)
ververica-connector-rocketmq-demo/src/main/java/com/alibaba/ververica/connector/demo/RocketMQDataStreamDemo.java:110
↓ 1 callersMethodrunExample
()
ververica-connector-datahub-demo/src/main/java/com/alibaba/ververica/connector/demo/DatahubSourceDemo.java:25
↓ 1 callersMethodtestContinuousOdpsSource
()
ververica-connector-maxcompute-demo/src/main/java/com/alibaba/ververica/connector/demo/OdpsSourceDemo.java:41
↓ 1 callersMethodtestOdpsSource
()
ververica-connector-maxcompute-demo/src/main/java/com/alibaba/ververica/connector/demo/OdpsSourceDemo.java:16
↓ 1 callersMethoduseCustomRecordConverter
()
ververica-connector-datahub-demo/src/main/java/com/alibaba/ververica/connector/demo/DatahubSinkDemo.java:44
↓ 1 callersMethoduseDefaultRecordConverter
()
ververica-connector-datahub-demo/src/main/java/com/alibaba/ververica/connector/demo/DatahubSinkDemo.java:27
MethodbuildHologresLookUpFunction
( TableSchema schema, Configuration config, HologresConnectionParam hologr
ververica-connector-hologres-demo/src/main/java/com/alibaba/ververica/connector/demo/HologresDimDemo.java:99
MethodconvertMessages
(List<MessageExt> messages)
ververica-connector-rocketmq-demo/src/main/java/com/alibaba/ververica/connector/demo/RocketMQDataStreamDemo.java:132
MethodgetStringLongTuple2
(RecordEntry recordEntry)
ververica-connector-datahub-demo/src/main/java/com/alibaba/ververica/connector/demo/DatahubSourceDemo.java:49
Methodmain
(String[] args)
ververica-connector-maxcompute-demo/src/main/java/com/alibaba/ververica/connector/demo/OdpsSourceDemo.java:8
Methodmain
(String[] args)
ververica-connector-maxcompute-demo/src/main/java/com/alibaba/ververica/connector/demo/OdpsSinkDemo.java:11
Methodmain
(String[] args)
ververica-connector-rocketmq-demo/src/main/java/com/alibaba/ververica/connector/demo/RocketMQDataStreamDemo.java:52
Methodmain
(String[] args)
ververica-connector-mysql-cdc-demo/src/main/java/com/alibaba/ververica/connector/demo/CdcDemo.java:28
Methodmain
(String[] args)
ververica-connector-datahub-demo/src/main/java/com/alibaba/ververica/connector/demo/DatahubSinkDemo.java:79
Methodmain
(String[] args)
ververica-connector-datahub-demo/src/main/java/com/alibaba/ververica/connector/demo/DatahubSourceDemo.java:57
Methodmain
(String[] args)
ververica-connector-hologres-demo/src/main/java/com/alibaba/ververica/connector/demo/HologresBinlogSourceDemo.java:22
Methodmain
(String[] args)
ververica-connector-hologres-demo/src/main/java/com/alibaba/ververica/connector/demo/HologresDimDemo.java:26
Methodmain
(String[] args)
ververica-connector-hologres-demo/src/main/java/com/alibaba/ververica/connector/demo/HologresSourceDemo.java:18
Methodmain
(String[] args)
ververica-connector-hologres-demo/src/main/java/com/alibaba/ververica/connector/demo/HologresSinkDemo.java:20
Methodmain
(String[] args)
ververica-connector-elasticsearch-demo/src/main/java/com/alibaba/ververica/connector/demo/EsSourceDemo.java:10
Methodmain
(String[] args)
ververica-connector-elasticsearch-demo/src/main/java/com/alibaba/ververica/connector/demo/EsSinkDemo.java:12
Methodmain
(String[] args)
ververica-connector-kafka-demo/src/main/java/com/alibaba/ververica/connector/demo/kafka/KafkaDemoJob.java:42
Methodmain
(String[] args)
ververica-connector-mongodb-demo/src/main/java/MongoDBSourceDemo.java:25
Methodmain
(String[] args)
ververica-connector-mongodb-demo/src/main/java/MongoDBSinkDemo.java:31
Methodmain
(String[] args)
ververica-connector-starrocks-demo/src/main/java/com/alibaba/ververica/connectors/demo/StarRocksSourceDemo.java:9
Methodmain
(String[] args)
ververica-connector-starrocks-demo/src/main/java/com/alibaba/ververica/connectors/demo/StarRocksSinkDemo.java:13
Methodserialize
(Document element, MongoSinkContext sinkContext)
ververica-connector-mongodb-demo/src/main/java/MongoDBSinkDemo.java:51