MCPcopy Create free account

hub / github.com/LioRoger/subscribe_example / functions

Functions648 in github.com/LioRoger/subscribe_example

⨍ Functions 648◇ Types & classes 82
↓ 59 callersMethodput
(int field$, java.lang.Object value$)
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Float.java:89
↓ 13 callersMethodgetMillis
Gets the value of the 'millis' field. @return The value of the 'millis' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:219
↓ 13 callersMethodsetValue
(byte[] bytes)
javaimpl/src/main/java/recordprocessor/FieldValue.java:21
↓ 12 callersMethodget
(int field$)
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Float.java:79
↓ 12 callersMethodsetEncoding
(String encoding)
javaimpl/src/main/java/recordprocessor/FieldValue.java:18
↓ 11 callersMethodgetValue
()
javaimpl/src/main/java/recordprocessor/FieldValue.java:14
↓ 10 callersMethodgetBytes
(ByteBuffer origin)
javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:369
↓ 10 callersMethodgetHour
Gets the value of the 'hour' field. @return The value of the 'hour' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:171
↓ 10 callersMethodgetOffset
()
javaimpl/src/main/java/common/Checkpoint.java:20
↓ 9 callersMethodgetTimeStamp
()
javaimpl/src/main/java/common/Checkpoint.java:24
↓ 8 callersMethoddeserializeFrom
(TopicPartition topicPartition, String groupID)
javaimpl/src/main/java/metastore/LocalFileMetaStore.java:94
↓ 8 callersMethodrequire
(boolean predict, String errMessage)
javaimpl/src/main/java/common/Util.java:56
↓ 8 callersMethodswallowErrorClose
(Closeable target)
javaimpl/src/main/java/common/Util.java:16
↓ 6 callersMethodtoString
()
javaimpl/src/main/java/common/Checkpoint.java:36
↓ 5 callersMethodgetYear
Gets the value of the 'year' field. @return The value of the 'year' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:123
↓ 5 callersMethodseek
(String storeName, TopicPartition tp, String group)
javaimpl/src/main/java/metastore/MetaStoreCenter.java:29
↓ 4 callersMethoddeleteFile
(String fileName)
javaimpl/src/main/java/common/Util.java:72
↓ 4 callersMethodgetMinute
Gets the value of the 'minute' field. @return The value of the 'minute' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:187
↓ 4 callersMethodgetSecond
Gets the value of the 'second' field. @return The value of the 'second' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:203
↓ 4 callersMethodpoll
()
javaimpl/src/main/java/recordgenerator/ConsumerWrap.java:35
↓ 4 callersMethodserializeTo
(TopicPartition topicPartition, String groupID, Checkpoint value)
javaimpl/src/main/java/metastore/LocalFileMetaStore.java:75
↓ 4 callersMethodsleepMS
(long value)
javaimpl/src/main/java/common/Util.java:25
↓ 4 callersMethodtoString
()
javaimpl/src/main/java/recordprocessor/FieldValue.java:24
↓ 3 callersMethodgetOperation
Gets the value of the 'operation' field. @return The value of the 'operation' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:292
↓ 3 callersMethodgetSourceTimestamp
Gets the value of the 'sourceTimestamp' field. @return record log timestamp
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:207
↓ 3 callersMethodgetTopicPartition
()
javaimpl/src/main/java/common/Checkpoint.java:32
↓ 3 callersMethodhasNext
()
javaimpl/src/main/java/common/FieldEntryHolder.java:22
↓ 3 callersMethodnewBuilder
Creates a new Record RecordBuilder. @return A new Record RecordBuilder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:423
↓ 3 callersMethodnewBuilder
Creates a new TimestampWithTimeZone RecordBuilder. @return A new TimestampWithTimeZone RecordBuilder
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TimestampWithTimeZone.java:130
↓ 2 callersMethodappendRecordGeneralInfo
(Record record, StringBuilder stringBuilder)
javaimpl/src/main/java/boot/MysqlRecordPrinter.java:81
↓ 2 callersMethodcheckFileExists
(String fileName)
javaimpl/src/main/java/common/Util.java:67
↓ 2 callersMethodcommit
(TopicPartition tp, Record record, long offset, String metadata)
javaimpl/src/main/java/common/UserCommitCallBack.java:7
↓ 2 callersMethodconvert
(Field field, Object o)
javaimpl/src/main/java/recordprocessor/FieldConverter.java:8
↓ 2 callersMethodencodeDate
(com.alibaba.dts.formats.avro.DateTime dateTime, byte[] out, int position)
javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:142
↓ 2 callersMethodencodeTime
(com.alibaba.dts.formats.avro.DateTime dateTime, byte[] out, int position)
javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:157
↓ 2 callersMethodencodeTimeMillis
(com.alibaba.dts.formats.avro.DateTime dateTime, byte[] out, int position)
javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:170
↓ 2 callersMethodgetAfterImages
Gets the value of the 'afterImages' field. @return The value of the 'afterImages' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:390
↓ 2 callersMethodgetDay
Gets the value of the 'day' field. @return The value of the 'day' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:155
↓ 2 callersMethodgetInfo
()
javaimpl/src/main/java/common/Checkpoint.java:28
↓ 2 callersMethodgetMonth
Gets the value of the 'month' field. @return The value of the 'month' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:139
↓ 2 callersMethodgetName
Gets the value of the 'name' field. @return The value of the 'name' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Field.java:98
↓ 2 callersMethodgetRecord
()
javaimpl/src/main/java/common/UserRecord.java:23
↓ 2 callersMethodsetFetchOffsetByTimestamp
(TopicPartition topicPartition, Checkpoint checkpoint)
javaimpl/src/main/java/recordgenerator/ConsumerWrap.java:58
↓ 2 callersMethodsetHour
Sets the value of the 'hour' field. @param value the value to set.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:179
↓ 2 callersMethodsetSourceBuilder
Sets the Builder instance for the 'source' field source dataource @param value The builder instance that must be set. @return This builder.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:932
↓ 2 callersMethodsetValueBuilder
Sets the Builder instance for the 'value' field @param value The builder instance that must be set. @return This builder.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TimestampWithTimeZone.java:252
↓ 2 callersMethodstart
()
javaimpl/src/main/java/common/WorkThread.java:16
↓ 2 callersMethodstop
()
javaimpl/src/main/java/common/WorkThread.java:20
↓ 2 callersMethodtake
()
javaimpl/src/main/java/common/FieldEntryHolder.java:35
↓ 1 callersMethodappendField
(Field field, Object beforeImage, Object afterImage, StringBuilder stringBuilder)
javaimpl/src/main/java/boot/MysqlRecordPrinter.java:70
↓ 1 callersMethodappendFields
(List<Field> fields, FieldEntryHolder before, FieldEntryHolder after, StringBuilder stringBuilder)
javaimpl/src/main/java/boot/MysqlRecordPrinter.java:56
↓ 1 callersMethodassignTopic
(TopicPartition topicPartition, Checkpoint checkpoint)
javaimpl/src/main/java/recordgenerator/ConsumerWrap.java:28
↓ 1 callersMethodboot
(String configFile, Map<String, RecordListener> recordListeners)
javaimpl/src/main/java/boot/Boot.java:35
↓ 1 callersMethodbuildJaasConfig
(String sid, String user, String password)
javaimpl/src/main/java/common/Util.java:62
↓ 1 callersMethodbuildRecordListener
()
javaimpl/src/main/java/NotifyDemo.java:17
↓ 1 callersMethodcheckConfig
(Properties properties)
javaimpl/src/main/java/recordgenerator/ConsumerWrap.java:117
↓ 1 callersMethodcheckConfig
(Properties properties)
javaimpl/src/main/java/boot/Boot.java:130
↓ 1 callersMethodclearSource
Clears the value of the 'source' field. source dataource @return This builder.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:952
↓ 1 callersMethodclearValue
Clears the value of the 'value' field. @return This builder.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TimestampWithTimeZone.java:270
↓ 1 callersMethodclose
()
javaimpl/src/main/java/recordgenerator/RecordGenerator.java:186
↓ 1 callersMethodcommit
(TopicPartition tp, Record commitRecord, long offset, String metadata)
javaimpl/src/main/java/recordprocessor/EtlRecordProcessor.java:84
↓ 1 callersMethodcommit
(TopicPartition tp, long timestamp, long offset, String metadata)
javaimpl/src/main/java/recordgenerator/OffsetCommitCallBack.java:7
↓ 1 callersMethodcommitCheckpoint
(TopicPartition topicPartition, Checkpoint checkpoint)
javaimpl/src/main/java/recordgenerator/RecordGenerator.java:172
↓ 1 callersMethodconfigure
(Map<String, ?> configs)
javaimpl/src/main/java/recordgenerator/ClusterSwitchListener.java:53
↓ 1 callersMethodconsume
(UserRecord record)
javaimpl/src/main/java/common/RecordListener.java:8
↓ 1 callersMethoddeserialize
(byte[] data)
javaimpl/src/main/java/recordprocessor/AvroDeserializer.java:19
↓ 1 callersMethoddeserializeFrom
(TopicPartition topicPartition, String group)
javaimpl/src/main/java/metastore/MetaStore.java:9
↓ 1 callersMethoddeserializeFrom
(TopicPartition topicPartition, String group)
javaimpl/src/main/java/metastore/KafkaMetaStore.java:59
↓ 1 callersMethodfromString
(String jsonString)
javaimpl/src/main/java/metastore/LocalFileMetaStore.java:57
↓ 1 callersMethodgetBeforeImages
Gets the value of the 'beforeImages' field. @return The value of the 'beforeImages' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:374
↓ 1 callersMethodgetCharset
Gets the value of the 'charset' field. @return The value of the 'charset' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Character.java:98
↓ 1 callersMethodgetCheckpoint
()
javaimpl/src/main/java/recordgenerator/RecordGenerator.java:162
↓ 1 callersMethodgetCommitThread
()
javaimpl/src/main/java/recordprocessor/EtlRecordProcessor.java:119
↓ 1 callersMethodgetConfigs
This demo use hard coded config. User can modify variable value for test The detailed describe for var in resources/demoConfig
javaimpl/src/main/java/NotifyDemo.java:36
↓ 1 callersMethodgetConsumerWrap
(Properties properties)
javaimpl/src/main/java/recordgenerator/ConsumerWrapFactory.java:6
↓ 1 callersMethodgetConsumerWrap
()
javaimpl/src/main/java/recordgenerator/RecordGenerator.java:60
↓ 1 callersMethodgetContent
()
javaimpl/src/main/java/common/AtomicFileStore.java:16
↓ 1 callersMethodgetConverter
(String sourceName, String sourceVersion)
javaimpl/src/main/java/recordprocessor/FieldConverter.java:9
↓ 1 callersMethodgetDataTypeNumber
Gets the value of the 'dataTypeNumber' field. @return The value of the 'dataTypeNumber' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Field.java:114
↓ 1 callersMethodgetDecoder
Return the BinaryMessageDecoder instance used by this class.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Float.java:31
↓ 1 callersMethodgetDecoder
Return the BinaryMessageDecoder instance used by this class.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Decimal.java:31
↓ 1 callersMethodgetDecoder
Return the BinaryMessageDecoder instance used by this class.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:31
↓ 1 callersMethodgetDecoder
Return the BinaryMessageDecoder instance used by this class.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Source.java:31
↓ 1 callersMethodgetDecoder
Return the BinaryMessageDecoder instance used by this class.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Character.java:31
↓ 1 callersMethodgetDecoder
Return the BinaryMessageDecoder instance used by this class.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Timestamp.java:31
↓ 1 callersMethodgetDecoder
Return the BinaryMessageDecoder instance used by this class.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TextObject.java:31
↓ 1 callersMethodgetDecoder
Return the BinaryMessageDecoder instance used by this class.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TextGeometry.java:31
↓ 1 callersMethodgetDecoder
Return the BinaryMessageDecoder instance used by this class.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/TimestampWithTimeZone.java:31
↓ 1 callersMethodgetDecoder
Return the BinaryMessageDecoder instance used by this class.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/BinaryGeometry.java:31
↓ 1 callersMethodgetDecoder
Return the BinaryMessageDecoder instance used by this class.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/BinaryObject.java:31
↓ 1 callersMethodgetDecoder
Return the BinaryMessageDecoder instance used by this class.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Integer.java:31
↓ 1 callersMethodgetDecoder
Return the BinaryMessageDecoder instance used by this class.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Field.java:31
↓ 1 callersMethodgetDecoder
Return the BinaryMessageDecoder instance used by this class.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:31
↓ 1 callersMethodgetEtlRecordProcessor
(Context context, Properties properties, RecordGenerator recordGenerator)
javaimpl/src/main/java/boot/Boot.java:116
↓ 1 callersMethodgetFieldEntryHolder
(Record record)
javaimpl/src/main/java/boot/MysqlRecordPrinter.java:46
↓ 1 callersMethodgetFieldValue
(Object data)
javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:62
↓ 1 callersMethodgetFields
Gets the value of the 'fields' field. @return The value of the 'fields' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:358
↓ 1 callersMethodgetId
Gets the value of the 'id' field. @return unique id of this record in the whole stream
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:190
↓ 1 callersMethodgetJDKEncoding
(String mysqlEncoding)
javaimpl/src/main/java/recordprocessor/mysql/JDKEncodingMapper.java:50
↓ 1 callersMethodgetObjectName
Gets the value of the 'objectName' field. @return The value of the 'objectName' field.
javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:308
next →1–100 of 648, ranked by callers