MCPcopy Create free account

hub / github.com/apache/rocketmq-flink / functions

Functions733 in github.com/apache/rocketmq-flink

⨍ Functions 733◇ Types & classes 161
MethodtestRocketMQDynamicTableSinkWithUnknownOption
()
src/test/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactoryTest.java:86
MethodtestRocketMQDynamicTableSinkWithoutRequiredOption
()
src/test/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactoryTest.java:74
MethodtestRocketMQDynamicTableSourceWithLegalOption
()
src/test/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactoryTest.java:59
MethodtestRocketMQDynamicTableSourceWithSql
()
src/test/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactoryTest.java:94
MethodtestRocketMQDynamicTableSourceWithUnknownOption
()
src/test/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactoryTest.java:84
MethodtestRocketMQDynamicTableSourceWithoutRequiredOption
()
src/test/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactoryTest.java:73
MethodtestSelect
()
src/test/java/org/apache/flink/connector/rocketmq/legacy/common/selector/HashMessageQueueSelectorTest.java:32
MethodtestSelect
()
src/test/java/org/apache/flink/connector/rocketmq/legacy/common/selector/RandomMessageQueueSelectorTest.java:32
MethodtestSerializeAndDeserialize
()
src/test/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializerTest.java:40
MethodtestSerializeDeserializeSourceEnumState
()
src/test/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializerTest.java:35
MethodtestSerializePartitionSplit
()
src/test/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializerTest.java:30
MethodtestSetStartupMode
()
src/test/java/org/apache/flink/connector/rocketmq/legacy/sourceFunction/RocketMQSourceFunctionTest.java:46
MethodtestSink
()
src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSinkTest.java:59
MethodtestSource
()
src/test/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceTest.java:73
MethodtestTableExists
()
src/test/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogTest.java:197
Methodtimestamp
Get an {@link OffsetsSelector} which initializes the offsets in each partition so that the initialized offset is the offset of the first record whose
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelector.java:116
MethodtoSplitType
(String splitId, RocketMQSourceSplitState splitState)
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java:153
MethodtoString
()
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGenerator.java:50
MethodtoString
()
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGeneratorPerQueue.java:60
MethodtoString
()
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/TimeLagWatermarkGenerator.java:49
MethodtoString
()
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java:147
MethoduseOption
Set the config option's value to a given builder.
src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfiguration.java:90
Methodvalidate
(Properties rocketmqSourceProperties)
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorByStrategy.java:61
Methodvalidate
(Properties rocketmqSourceProperties)
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorBySpecified.java:82
Methodvalidate
Package private validating for using in {@link RocketMQConfigBuilder}.
src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigValidator.java:58
MethodwakeUp
()
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java:94
MethodwakeUp
()
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java:223
Methodwakeup
()
src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java:196
Methodwakeup
interrupt poll message
src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumer.java:71
MethodwithMessageQueueSelector
(MessageQueueSelector selector)
src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java:198
MethodwithMessageQueueSelectorArg
(String arg)
src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java:203
Methodwrite
(IN element, Context context)
src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java:83
MethodwriteWatermark
(Watermark watermark)
src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java:128
← previous701–733 of 733, ranked by callers