MCPcopy Create free account

hub / github.com/LioRoger/subscribe_example / functions

Functions648 in github.com/LioRoger/subscribe_example

⨍ Functions 648◇ Types & classes 82
↓ 1 callersMethodgetRecordGenerator
(Context context, Properties properties)
javaimpl/src/main/java/boot/Boot.java:107
↓ 1 callersMethodgetRecordProcessor
()
javaimpl/src/main/java/common/Context.java:16
↓ 1 callersMethodgetSource
Gets the value of the 'source' field. @return source dataource
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:275
↓ 1 callersMethodgetSourceBuilder
Gets the Builder instance for the 'source' field and creates one if it doesn't exist yet. source dataource @return This builder.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:915
↓ 1 callersMethodgetStreamContext
(Properties properties)
javaimpl/src/main/java/boot/Boot.java:88
↓ 1 callersMethodgetTags
Gets the value of the 'tags' field. @return tags to identify properties of this record
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:341
↓ 1 callersMethodgetTestKafkaConsumer
(String groupID)
javaimpl/src/test/java/store/KafkaMetaStoreTest.java:16
↓ 1 callersMethodgetTimestamp
Gets the value of the 'timestamp' field. @return The value of the 'timestamp' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Timestamp.java:98
↓ 1 callersMethodgetValueBuilder
Gets the Builder instance for the 'value' field and creates one if it doesn't exist yet. @return This builder.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TimestampWithTimeZone.java:236
↓ 1 callersMethodhandle
(Signal signal)
javaimpl/src/main/java/boot/Boot.java:77
↓ 1 callersMethodhasSource
Checks whether the 'source' field has been set. source dataource @return True if the 'source' field has been set, false otherwise.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:906
↓ 1 callersMethodhasSourceBuilder
Checks whether the 'source' field has an active Builder instance source dataource @return True if the 'source' field has an active Builder instance
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:943
↓ 1 callersMethodhasValue
Checks whether the 'value' field has been set. @return True if the 'value' field has been set, false otherwise.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TimestampWithTimeZone.java:228
↓ 1 callersMethodhasValueBuilder
Checks whether the 'value' field has an active Builder instance @return True if the 'value' field has an active Builder instance
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TimestampWithTimeZone.java:262
↓ 1 callersMethodinitLog4j
()
javaimpl/src/main/java/boot/Boot.java:138
↓ 1 callersMethodisErrorRecoverable
(Throwable e)
javaimpl/src/main/java/recordgenerator/RecordGenerator.java:178
↓ 1 callersMethodloadConfig
(String filePath)
javaimpl/src/main/java/boot/Boot.java:152
↓ 1 callersMethodmayCommitCheckpoint
()
javaimpl/src/main/java/recordgenerator/RecordGenerator.java:110
↓ 1 callersMethodmergeSourceKafkaProperties
(Properties originProperties, Properties mergeToProperties)
javaimpl/src/main/java/common/Util.java:32
↓ 1 callersMethodoffer
(long timeOut, TimeUnit timeUnit, ConsumerRecord record)
javaimpl/src/main/java/recordprocessor/EtlRecordProcessor.java:31
↓ 1 callersMethodparseCheckpoint
(String checkpoint)
javaimpl/src/main/java/boot/Boot.java:95
↓ 1 callersMethodparseConsumerSubscribeMode
(String value)
javaimpl/src/main/java/recordgenerator/RecordGenerator.java:195
↓ 1 callersMethodrecordToString
(Record record)
javaimpl/src/main/java/boot/MysqlRecordPrinter.java:24
↓ 1 callersMethodregisterRecordListener
(String name, RecordListener recordListener)
javaimpl/src/main/java/recordprocessor/EtlRecordProcessor.java:109
↓ 1 callersMethodregisterSignalHandler
(Context context)
javaimpl/src/main/java/boot/Boot.java:75
↓ 1 callersMethodregisterStore
(String name, MetaStore metaStore)
javaimpl/src/main/java/metastore/MetaStoreCenter.java:18
↓ 1 callersMethodremove
()
javaimpl/src/main/java/common/AtomicFileStore.java:68
↓ 1 callersMethodserializeTo
(TopicPartition topicPartition, String group, V value)
javaimpl/src/main/java/metastore/MetaStore.java:8
↓ 1 callersMethodserializeTo
(TopicPartition topicPartition, String group, Checkpoint value)
javaimpl/src/main/java/metastore/KafkaMetaStore.java:31
↓ 1 callersMethodsetMillis
Sets the value of the 'millis' field. @param value the value to set.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:227
↓ 1 callersMethodsetMinute
Sets the value of the 'minute' field. @param value the value to set.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:195
↓ 1 callersMethodsetRecordProcessor
(EtlRecordProcessor recordProcessor)
javaimpl/src/main/java/common/Context.java:20
↓ 1 callersMethodsetSecond
Sets the value of the 'second' field. @param value the value to set.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:211
↓ 1 callersMethodsetStreamSource
(RecordGenerator streamSource)
javaimpl/src/main/java/common/Context.java:12
↓ 1 callersMethodsetToCommitCheckpoint
(Checkpoint committedCheckpoint)
javaimpl/src/main/java/recordgenerator/RecordGenerator.java:117
↓ 1 callersMethodstartWorker
(EtlRecordProcessor etlRecordProcessor, RecordGenerator recordGenerator)
javaimpl/src/main/java/boot/Boot.java:65
↓ 1 callersMethodstore
(TopicPartition topicPartition, String group, Checkpoint value)
javaimpl/src/main/java/metastore/MetaStoreCenter.java:23
↓ 1 callersMethodsubscribeTopic
(TopicPartition topicPartition, Supplier<Checkpoint> streamCheckpoint)
javaimpl/src/main/java/recordgenerator/ConsumerWrap.java:32
↓ 1 callersMethodtoJson
(StoreElement storeElement)
javaimpl/src/main/java/metastore/LocalFileMetaStore.java:39
↓ 1 callersMethoduncompressionObjectName
(String compressionName)
javaimpl/src/main/java/common/Util.java:96
↓ 1 callersMethodunescapeName
(String name)
javaimpl/src/main/java/common/Util.java:111
↓ 1 callersMethodupdateContent
(List<String> newContent)
javaimpl/src/main/java/common/AtomicFileStore.java:39
MethodAtomicFileStore
(String fileName)
javaimpl/src/main/java/common/AtomicFileStore.java:12
MethodAvroDeserializer
()
javaimpl/src/main/java/recordprocessor/AvroDeserializer.java:16
MethodBinaryGeometry
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
javaimpl/src/main/java/com/alibaba/dts/formats/avro/BinaryGeometry.java:62
MethodBinaryObject
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
javaimpl/src/main/java/com/alibaba/dts/formats/avro/BinaryObject.java:62
MethodBuilder
Creates a new Builder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Float.java:184
MethodBuilder
Creates a new Builder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Decimal.java:184
MethodBuilder
Creates a new Builder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:479
MethodBuilder
Creates a new Builder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Source.java:165
MethodBuilder
Creates a new Builder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Character.java:162
MethodBuilder
Creates a new Builder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Timestamp.java:162
MethodBuilder
Creates a new Builder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TextObject.java:162
MethodBuilder
Creates a new Builder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TextGeometry.java:162
MethodBuilder
Creates a new Builder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TimestampWithTimeZone.java:163
MethodBuilder
Creates a new Builder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/BinaryGeometry.java:162
MethodBuilder
Creates a new Builder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/BinaryObject.java:162
MethodBuilder
Creates a new Builder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Integer.java:162
MethodBuilder
Creates a new Builder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Field.java:162
MethodBuilder
Creates a new Builder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:272
MethodCharacter
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Character.java:62
MethodCheckpoint
(TopicPartition topicPartition, long timeStamp, long offset, String info)
javaimpl/src/main/java/common/Checkpoint.java:13
MethodClusterSwitchException
(String message, Throwable cause)
javaimpl/src/main/java/recordgenerator/ClusterSwitchListener.java:57
MethodDateTime
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:67
MethodDecimal
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Decimal.java:63
MethodDefaultConsumerWrap
(Properties properties)
javaimpl/src/main/java/recordgenerator/ConsumerWrap.java:44
MethodEtlRecordProcessor
(OffsetCommitCallBack offsetCommitCallBack, Context context)
javaimpl/src/main/java/recordprocessor/EtlRecordProcessor.java:46
MethodField
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Field.java:62
MethodFieldEntryHolder
(List<Object> originFields)
javaimpl/src/main/java/common/FieldEntryHolder.java:11
MethodFloat
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Float.java:63
MethodInteger
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Integer.java:62
MethodKafkaMetaStore
(KafkaConsumer kafkaConsumer)
javaimpl/src/main/java/metastore/KafkaMetaStore.java:23
MethodLocalFileMetaStore
(String fileName)
javaimpl/src/main/java/metastore/LocalFileMetaStore.java:35
MethodMetaStoreCenter
()
javaimpl/src/main/java/metastore/MetaStoreCenter.java:14
MethodRecord
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:85
MethodRecordGenerator
(Properties properties, Context context, Checkpoint initialCheckpoint, ConsumerWrapFactory consumerWrapFactory
javaimpl/src/main/java/recordgenerator/RecordGenerator.java:43
MethodSource
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Source.java:63
MethodStoreElement
(String groupName, Map<TopicPartition, Checkpoint> streamCheckpoint)
javaimpl/src/main/java/metastore/LocalFileMetaStore.java:27
MethodTextGeometry
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TextGeometry.java:62
MethodTextObject
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TextObject.java:62
MethodTimestamp
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Timestamp.java:62
MethodTimestampWithTimeZone
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TimestampWithTimeZone.java:62
MethodUniqueKeyGenerator
()
javaimpl/src/main/java/common/UniqueKeyGenerator.java:10
MethodUserRecord
(TopicPartition tp, long offset, Record record, UserCommitCallBack userCommitCallBack)
javaimpl/src/main/java/common/UserRecord.java:12
MethodWorkThread
(T r)
javaimpl/src/main/java/common/WorkThread.java:11
MethodassignTopic
(TopicPartition topicPartition, Checkpoint checkpoint)
javaimpl/src/main/java/recordgenerator/ConsumerWrap.java:69
Methodbuild
()
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Float.java:342
Methodbuild
()
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Decimal.java:343
Methodbuild
()
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:1282
Methodbuild
()
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Source.java:283
Methodbuild
()
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Character.java:276
Methodbuild
()
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Timestamp.java:274
Methodbuild
()
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TextObject.java:276
Methodbuild
()
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TextGeometry.java:276
Methodbuild
()
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TimestampWithTimeZone.java:316
Methodbuild
()
javaimpl/src/main/java/com/alibaba/dts/formats/avro/BinaryGeometry.java:276
Methodbuild
()
javaimpl/src/main/java/com/alibaba/dts/formats/avro/BinaryObject.java:276
Methodbuild
()
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Integer.java:275
Methodbuild
()
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Field.java:275
Methodbuild
()
javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:621
← previousnext →101–200 of 648, ranked by callers