A B C D E F G H I J K L M N O P Q R S T U V W Z

A

activateOptions() - Method in class com.github.hackerwin7.jlib.utils.drivers.log.DailyRollingFileAppenderCustom

add(byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.data.HData

add family

add(byte[], byte[], byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.data.HData

add a columnByteArrayWrapper(qualifier)

addFamily(String, String[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

add family columng

admin - Static variable in class com.github.hackerwin7.jlib.utils.executors.HBaseClientScanIns

asHex(byte[]) - Static method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Turns array of bytes into string representing each byte as unsigned hex number.

asHex() - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Returns 32-character hex representation of this objects hash

B

Base64Cus - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

Base64Cus() - Constructor for class com.github.hackerwin7.jlib.utils.executors.Base64Cus

Base64Decode(String) - Method in class com.github.hackerwin7.jlib.utils.executors.Base64Cus

Base64Encode(byte[]) - Method in class com.github.hackerwin7.jlib.utils.executors.Base64Cus

BATCH_SIZE - Static variable in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo

BDP_URL - Static variable in class com.github.hackerwin7.jlib.utils.executors.TrainBdpConfig

BlockingDataQueue<E> - Class in com.github.hackerwin7.jlib.utils.drivers.queue.blocking

Created by IntelliJ IDEA.

BlockingDataQueue(int) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.queue.blocking.BlockingDataQueue

make queue by size

brokers(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaInfo.KafkaInfoBuilder

brokers(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo.KafkaInfoBuilder

build() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaInfo.KafkaInfoBuilder

build() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg.KafkaMsgBuilder

build() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo.KafkaInfoBuilder

build() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column.Builder

ByteArrayWrapper - Class in com.github.hackerwin7.jlib.utils.commons.wrap

Created by IntelliJ IDEA.

ByteArrayWrapper(byte[]) - Constructor for class com.github.hackerwin7.jlib.utils.commons.wrap.ByteArrayWrapper

constructor with byte[]

bytes2String(byte[]) - Static method in class com.github.hackerwin7.jlib.utils.commons.convert.Convert

bytes to string

C

CHECKPOINT_PATH - Static variable in class com.github.hackerwin7.jlib.utils.executors.ZkCheckpointMagpieJob

clear() - Method in class com.github.hackerwin7.jlib.utils.drivers.queue.blocking.BlockingDataQueue

clear the queue

close() - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.io.NullOutputStream

close() - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

close the connection

close() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

close thread pool

close() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.producer.KafkaProducer

close producer client

close() - Method in class com.github.hackerwin7.jlib.utils.drivers.zk.ZkClient

close the zk driver

close() - Static method in class com.github.hackerwin7.jlib.utils.executors.HBaseClientScanIns

close() - Method in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo

close

close() - Method in interface com.github.hackerwin7.jlib.utils.frameworks.magpie.MagpieExecutor

close

com.github.hackerwin7.jlib.utils.commons - package com.github.hackerwin7.jlib.utils.commons

com.github.hackerwin7.jlib.utils.commons.convert - package com.github.hackerwin7.jlib.utils.commons.convert

com.github.hackerwin7.jlib.utils.commons.wrap - package com.github.hackerwin7.jlib.utils.commons.wrap

com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.io - package com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.io

com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util - package com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util

com.github.hackerwin7.jlib.utils.drivers.file - package com.github.hackerwin7.jlib.utils.drivers.file

com.github.hackerwin7.jlib.utils.drivers.hbase.client - package com.github.hackerwin7.jlib.utils.drivers.hbase.client

com.github.hackerwin7.jlib.utils.drivers.hbase.conf - package com.github.hackerwin7.jlib.utils.drivers.hbase.conf

com.github.hackerwin7.jlib.utils.drivers.hbase.data - package com.github.hackerwin7.jlib.utils.drivers.hbase.data

com.github.hackerwin7.jlib.utils.drivers.io - package com.github.hackerwin7.jlib.utils.drivers.io

com.github.hackerwin7.jlib.utils.drivers.kafka.conf - package com.github.hackerwin7.jlib.utils.drivers.kafka.conf

com.github.hackerwin7.jlib.utils.drivers.kafka.consumer - package com.github.hackerwin7.jlib.utils.drivers.kafka.consumer

com.github.hackerwin7.jlib.utils.drivers.kafka.data - package com.github.hackerwin7.jlib.utils.drivers.kafka.data

com.github.hackerwin7.jlib.utils.drivers.kafka.producer - package com.github.hackerwin7.jlib.utils.drivers.kafka.producer

com.github.hackerwin7.jlib.utils.drivers.kafka.utils - package com.github.hackerwin7.jlib.utils.drivers.kafka.utils

com.github.hackerwin7.jlib.utils.drivers.log - package com.github.hackerwin7.jlib.utils.drivers.log

com.github.hackerwin7.jlib.utils.drivers.mysql.client - package com.github.hackerwin7.jlib.utils.drivers.mysql.client

com.github.hackerwin7.jlib.utils.drivers.mysql.conf - package com.github.hackerwin7.jlib.utils.drivers.mysql.conf

com.github.hackerwin7.jlib.utils.drivers.mysql.data - package com.github.hackerwin7.jlib.utils.drivers.mysql.data

com.github.hackerwin7.jlib.utils.drivers.queue.blocking - package com.github.hackerwin7.jlib.utils.drivers.queue.blocking

com.github.hackerwin7.jlib.utils.drivers.shell - package com.github.hackerwin7.jlib.utils.drivers.shell

com.github.hackerwin7.jlib.utils.drivers.url - package com.github.hackerwin7.jlib.utils.drivers.url

com.github.hackerwin7.jlib.utils.drivers.zk - package com.github.hackerwin7.jlib.utils.drivers.zk

com.github.hackerwin7.jlib.utils.executors - package com.github.hackerwin7.jlib.utils.executors

com.github.hackerwin7.jlib.utils.frameworks.magpie - package com.github.hackerwin7.jlib.utils.frameworks.magpie

CommonUtils - Class in com.github.hackerwin7.jlib.utils.commons

common utils for jdk Created by fff on 10/28/15.

CommonUtils() - Constructor for class com.github.hackerwin7.jlib.utils.commons.CommonUtils

compressToByte(String) - Static method in class com.github.hackerwin7.jlib.utils.executors.GZIPer

compressToByte(String, String) - Static method in class com.github.hackerwin7.jlib.utils.executors.GZIPer

CONF_SPLIT - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

configuration - Static variable in class com.github.hackerwin7.jlib.utils.executors.HBaseClientScanIns

CONN_TIME_OUT - Static variable in class com.github.hackerwin7.jlib.utils.drivers.url.URLClient

connect() - Method in class com.github.hackerwin7.jlib.utils.drivers.url.HttpClient

connect

connection - Static variable in class com.github.hackerwin7.jlib.utils.executors.HBaseClientScanIns

consume() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaHighConsumer

consume a msg

consume(int, long) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaHighConsumer

batch consume kafka

consume() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

consume message

CONSUME_BUFFER_SIZE - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

CONSUME_TIME_OUT - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

ConsumerTh(KafkaStream<byte[], byte[]>, int) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaHighConsumer.ConsumerTh

ConsumeThread(Map<String, Integer>, int, long, long) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer.ConsumeThread

constructor with broker and partition, offset

Convert - Class in com.github.hackerwin7.jlib.utils.commons.convert

Created by IntelliJ IDEA.

Convert() - Constructor for class com.github.hackerwin7.jlib.utils.commons.convert.Convert

create(String, String) - Method in class com.github.hackerwin7.jlib.utils.drivers.zk.ZkClient

create the path and data

create(String, String, CreateMode) - Method in class com.github.hackerwin7.jlib.utils.drivers.zk.ZkClient

reload func

createBuilder() - Static method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaInfo

createBuilder() - Static method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg

create builder

createBuilder() - Static method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

createBuilder() - Static method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column

createNamespace(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

create namespace

createR(String, String) - Method in class com.github.hackerwin7.jlib.utils.drivers.zk.ZkClient

recursively create

createTable(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

create htable

createTable(String, String[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

create the hbase table with hbase descriptor

D

DailyRollingFileAppenderCustom - Class in com.github.hackerwin7.jlib.utils.drivers.log

Created by IntelliJ IDEA.

DailyRollingFileAppenderCustom() - Constructor for class com.github.hackerwin7.jlib.utils.drivers.log.DailyRollingFileAppenderCustom

The default constructor does nothing.

DailyRollingFileAppenderCustom(Layout, String, String) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.log.DailyRollingFileAppenderCustom

Instantiate a DailyRollingFileAppenderCustom and open the file designated by filename.

DBAIpCompare - Class in com.github.hackerwin7.jlib.utils.executors

Created by fff on 12/21/15.

DBAIpCompare() - Constructor for class com.github.hackerwin7.jlib.utils.executors.DBAIpCompare

DEFAULT_CHARSET - Static variable in class com.github.hackerwin7.jlib.utils.drivers.url.HttpClient

DEFAULT_SCAN_CACHING - Static variable in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

delete(String, byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

delete by rowkey

delete(String, List<byte[]>) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

delete(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.zk.ZkClient

delete the zk node

deleteAsync(String, List<byte[]>) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

deleteAsyncHData(String, List<HData>) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

deleteAsyncOrigin(String, List<Delete>) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

original delete async

deleteFamily(String, String) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

delete family column

deleteHData(String, HData) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

delete hdata

deleteHData(String, List<HData>) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

deleteNamespace(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

delete namespace

deleteOrigin(String, Delete) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

delete the delte

deleteOrigin(String, List<Delete>) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

deleteTable(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

delete htable

desc(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.client.MysqlClient

desc table structure

DescMeta() - Constructor for class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo.DescMeta

disconnect() - Method in class com.github.hackerwin7.jlib.utils.drivers.url.HttpClient

close the http client

distinct() - Method in class com.github.hackerwin7.jlib.utils.executors.DBAIpCompare

E

equals(Object) - Method in class com.github.hackerwin7.jlib.utils.commons.wrap.ByteArrayWrapper

override the equal method

equals(Object) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.data.HData.HValue

ERR_COUNT_RECONN - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

execute(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.client.MysqlClient

execute update delete or insert

execute(String) - Static method in class com.github.hackerwin7.jlib.utils.drivers.shell.ShellClient

execute the command

execute(ZkClient, String, String, String) - Static method in class com.github.hackerwin7.jlib.utils.executors.ZkCheckpointMagpieJob

executeBatch(List<String>) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.client.MysqlClient

execute batch

exist(byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.data.HData

exist family

exist(byte[], byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.data.HData

exist family, qualifier

exists(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.zk.ZkClient

the string path is exists

existsR(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.zk.ZkClient

recursively check

existsRow(String, Get) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

exists getOrigin

existsRow(String, byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

overloading with rowkey

existsTable(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

htable is exists

F

FETCH_SIZE - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

file2in(String, String) - Static method in class com.github.hackerwin7.jlib.utils.commons.CommonUtils

file2in(String, String) - Static method in class com.github.hackerwin7.jlib.utils.commons.convert.Convert

file convert to input stream

file2List(String) - Static method in class com.github.hackerwin7.jlib.utils.drivers.file.FileUtils

load resource or classpath file name and convert into list

file2List(String, ClassLoader) - Static method in class com.github.hackerwin7.jlib.utils.drivers.file.FileUtils

load the specified class loader

file2List(String, InputStream) - Static method in class com.github.hackerwin7.jlib.utils.drivers.file.FileUtils

load the specified class loader

FILE_NAME - Static variable in class com.github.hackerwin7.jlib.utils.executors.TrainBdpConfig

FileUtils - Class in com.github.hackerwin7.jlib.utils.drivers.file

Created by IntelliJ IDEA.

FileUtils() - Constructor for class com.github.hackerwin7.jlib.utils.drivers.file.FileUtils

Final() - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Returns array of bytes (16 bytes) representing hash as of the current state of this object.

findMaxOffset(int) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

find max offset

findMinOffset(int) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

find min offset

findTopicInfo(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.utils.KafkaUtils

getOrigin topic information by using topic and zkconn

flush() - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.io.NullOutputStream

FlushTask() - Constructor for class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient.FlushTask

FlushTask(BufferedMutator) - Constructor for class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo.FlushTask

G

generateDecoder() - Method in class com.github.hackerwin7.jlib.utils.executors.Base64Cus

get(String, byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

overloading

get(String, List<byte[]>) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

get(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.url.HttpClient

http getOrigin

get() - Method in class com.github.hackerwin7.jlib.utils.drivers.url.URLClient

getOrigin string data from url

get(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.zk.ZkClient

getOrigin the zookeeper node

getBeginOffsetsMap() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

getBrokerMap() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

getBrokers() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaInfo

getBrokers() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

getBrokers(int) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

getChildren(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.zk.ZkClient

getOrigin children node

getColumn(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData

getColumnFamilies(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

getOrigin column families

getColumnFamiliesName(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

getOrigin all column families name

getColumnList() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData

getColumns(byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.data.HData

getOrigin multiple columns

getData() - Method in class com.github.hackerwin7.jlib.utils.commons.wrap.ByteArrayWrapper

getOrigin data

getDatePattern() - Method in class com.github.hackerwin7.jlib.utils.drivers.log.DailyRollingFileAppenderCustom

Returns the value of the DatePattern option.

getDbname() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData

getEncode() - Method in class com.github.hackerwin7.jlib.utils.executors.GZIPer

getEndOffsets(int) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

getEndOffsetsMap() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

getFamilyList() - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.data.HData

getOrigin list of family

getFromUrl(String) - Static method in class com.github.hackerwin7.jlib.utils.drivers.url.URLClient

getOrigin string data from specified url

getHash(File) - Static method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Calculates and returns the hash of the contents of the given file.

getHdata(String, HData) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

hdata parameter

getHdata(String, List<HData>) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

getIp() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData

getJavaType() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column

getJtype() - Method in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo.DescMeta

getKey() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg

getLength() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column

getLogFileName() - Method in class com.github.hackerwin7.jlib.utils.drivers.shell.ShellGetMysqlOffset.MysqlSimpleOffset

getLogFileOffset() - Method in class com.github.hackerwin7.jlib.utils.drivers.shell.ShellGetMysqlOffset.MysqlSimpleOffset

getLogicName(String) - Static method in class com.github.hackerwin7.jlib.utils.executors.SwitchTpConfig

getMaxBackupIndex() - Method in class com.github.hackerwin7.jlib.utils.drivers.log.DailyRollingFileAppenderCustom

getMaxOffset(SimpleConsumer, String, int) - Static method in class com.github.hackerwin7.jlib.utils.drivers.kafka.utils.KafkaUtils

getMD5() - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5InputStream

getMD5() - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5OutputStream

getMd5Row(String) - Static method in class com.github.hackerwin7.jlib.utils.executors.HBaseReadDemo

getMinOffset(SimpleConsumer, String, int) - Static method in class com.github.hackerwin7.jlib.utils.drivers.kafka.utils.KafkaUtils

getMtype() - Method in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo.DescMeta

getMyData() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.client.MysqlClient

getName() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column

getName() - Method in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo.DescMeta

getNextOffset() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg

getOffset() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg

getoffset(int) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

getOrigin(String, Get) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

origonal getOrigin

getOrigin(String, List<Get>) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

batch

getParititon() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg

getPartitionNum() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

getPort() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData

getProp(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.conf.HBaseConf

getOrigin key value property

getProp(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

getOrigin properties value

getProp(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.conf.MysqlConf

getOrigin property value

getProps() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

getOrigin config properties

getQualifier() - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.data.HData.HValue

getQueueSize() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

getOrigin queue size

getRowkey() - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.data.HData

getOrigin rowkey

gets(String, byte[], byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

scan data by start rowkey and stop rowkey

gets(String, byte[], byte[], byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

gets(String, byte[], byte[], byte[], byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

gets(String, byte[], int, HBaseClient.NextRowkeyHandler) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

set start and load count hdatas to list

gets(String, byte[], int, HBaseClient.NextRowkeyHandler, byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

gets(String, byte[], int, HBaseClient.NextRowkeyHandler, byte[], byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

getSize() - Method in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo.DescMeta

getsOrigin(String, Scan) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

original scanner

getSqlType() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column

getTableNameList() - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

getOrigin table name list

getTbname() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData

getTopic() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

getOrigin topic in this consumer

getTopic() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaInfo

getTopic() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg

getTopic() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

getVal() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg

getValue() - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.data.HData.HValue

getValue() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column

getZks() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaInfo

getZks() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

GZIPer - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

GZIPer() - Constructor for class com.github.hackerwin7.jlib.utils.executors.GZIPer

H

hash() - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5InputStream

Returns array of bytes representing hash of the stream as finalized for the current state.

hash() - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5OutputStream

Returns array of bytes representing hash of the stream as finalized for the current state.

hashCode() - Method in class com.github.hackerwin7.jlib.utils.commons.wrap.ByteArrayWrapper

override the hashcode for something else use, such as HashMap key

hashCode() - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.data.HData.HValue

hashesEqual(byte[], byte[]) - Static method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

HBASE_ZK_NODE_ROOT - Static variable in class com.github.hackerwin7.jlib.utils.drivers.hbase.conf.HBaseConf

HBASE_ZK_PORT - Static variable in class com.github.hackerwin7.jlib.utils.drivers.hbase.conf.HBaseConf

HBASE_ZK_QUORUM - Static variable in class com.github.hackerwin7.jlib.utils.drivers.hbase.conf.HBaseConf

HBaseClient - Class in com.github.hackerwin7.jlib.utils.drivers.hbase.client

Created by IntelliJ IDEA.

HBaseClient(HBaseConf) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

init hbase conn and admin and table

HBaseClient.FlushTask - Class in com.github.hackerwin7.jlib.utils.drivers.hbase.client

HBaseClient.NextRowkeyHandler - Interface in com.github.hackerwin7.jlib.utils.drivers.hbase.client

HBaseClientScanIns - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

HBaseClientScanIns() - Constructor for class com.github.hackerwin7.jlib.utils.executors.HBaseClientScanIns

HBaseConf - Class in com.github.hackerwin7.jlib.utils.drivers.hbase.conf

Created by IntelliJ IDEA.

HBaseConf() - Constructor for class com.github.hackerwin7.jlib.utils.drivers.hbase.conf.HBaseConf

constructor default

HBaseReadDemo - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

HBaseReadDemo() - Constructor for class com.github.hackerwin7.jlib.utils.executors.HBaseReadDemo

HData - Class in com.github.hackerwin7.jlib.utils.drivers.hbase.data

Created by IntelliJ IDEA.

HData(byte[]) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.hbase.data.HData

default constructor

HData.HValue - Class in com.github.hackerwin7.jlib.utils.drivers.hbase.data

hdata2put(HData) - Static method in class com.github.hackerwin7.jlib.utils.commons.convert.Convert

convert hdata to put

HdfsWriteData - Class in com.github.hackerwin7.jlib.utils.executors

Created by fff on 11/6/15.

HdfsWriteData() - Constructor for class com.github.hackerwin7.jlib.utils.executors.HdfsWriteData

HIGH_AUTO_COMMIT_INTERVAL - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

HIGH_GROUP_ID - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

HIGH_TOPIC - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

HIGH_ZOOKEEPER_CONN - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

HIGH_ZOOKEEPER_SESSION_TIMEOUT - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

HIGH_ZOOKEEPER_SYNC_TIME - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

HttpClient - Class in com.github.hackerwin7.jlib.utils.drivers.url

Created by IntelliJ IDEA.

HttpClient() - Constructor for class com.github.hackerwin7.jlib.utils.drivers.url.HttpClient

constructor

HValue(byte[], byte[]) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.hbase.data.HData.HValue

I

Init() - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Initialize MD5 internal state (object can be reused just by calling Init() after every Final()

init() - Static method in class com.github.hackerwin7.jlib.utils.executors.HBaseClientScanIns

initNativeLibrary() - Static method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Convenience method for initNativeLibrary(false).

initNativeLibrary(boolean) - Static method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Attempts to initialize native library support.

isAuto(boolean) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column.Builder

isAuto() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column

isConsumeEmpty() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

is queue empty

isDataQueueEmpty() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.client.MysqlClient

isEmpty() - Method in class com.github.hackerwin7.jlib.utils.drivers.queue.blocking.BlockingDataQueue

is empty or not

isKey(boolean) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column.Builder

isKey() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column

isNull(boolean) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column.Builder

isNull() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column

isTracker(String) - Static method in class com.github.hackerwin7.jlib.utils.executors.ZkCheckpointMagpieJob

isWrite(boolean) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column.Builder

isWrite() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column

J

javaType(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column.Builder

JDQ_COMPRESSION - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

JDQ_IS_CONTROL_SPEED - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

JDQ_IS_SYNC - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

JDQ_REPLICA_LEVEL - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

JDQ_ZK_INFO - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

JOB_LIST - Static variable in class com.github.hackerwin7.jlib.utils.executors.ZkCheckpointMagpieJob

JSample - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

JSample() - Constructor for class com.github.hackerwin7.jlib.utils.executors.JSample

json2Map(JSONObject) - Static method in class com.github.hackerwin7.jlib.utils.commons.convert.Convert

json convert to map using ObjectMapper

K

KafkaConf - Class in com.github.hackerwin7.jlib.utils.drivers.kafka.conf

Created by IntelliJ IDEA.

KafkaConf() - Constructor for class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

default props

KafkaDefaultPartitionKeyExecutor - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

KafkaDefaultPartitionKeyExecutor() - Constructor for class com.github.hackerwin7.jlib.utils.executors.KafkaDefaultPartitionKeyExecutor

KafkaHighConsumer - Class in com.github.hackerwin7.jlib.utils.drivers.kafka.consumer

Created by IntelliJ IDEA.

KafkaHighConsumer(KafkaConf) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaHighConsumer

constructor with kafka conf

KafkaHighConsumer.ConsumerTh - Class in com.github.hackerwin7.jlib.utils.drivers.kafka.consumer

consumer thread running consume

KafkaInfo - Class in com.github.hackerwin7.jlib.utils.drivers.kafka.data

Created by IntelliJ IDEA.

KafkaInfo.KafkaInfoBuilder - Class in com.github.hackerwin7.jlib.utils.drivers.kafka.data

KafkaMsg - Class in com.github.hackerwin7.jlib.utils.drivers.kafka.data

Created by IntelliJ IDEA.

KafkaMsg.KafkaMsgBuilder - Class in com.github.hackerwin7.jlib.utils.drivers.kafka.data

builder class

KafkaProducer - Class in com.github.hackerwin7.jlib.utils.drivers.kafka.producer

Created by IntelliJ IDEA.

KafkaProducer(KafkaConf) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.kafka.producer.KafkaProducer

constructor kafka producer client by kafka conf

KafkaSimpleConsumer - Class in com.github.hackerwin7.jlib.utils.drivers.kafka.consumer

Created by IntelliJ IDEA.

KafkaSimpleConsumer(KafkaConf) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

constructor by kafka config

KafkaSimpleConsumer.ConsumeThread - Class in com.github.hackerwin7.jlib.utils.drivers.kafka.consumer

start the thread to run the consumer

KafkaUtils - Class in com.github.hackerwin7.jlib.utils.drivers.kafka.utils

Created by IntelliJ IDEA.

KafkaUtils(String) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.kafka.utils.KafkaUtils

build zk client and load global broker id mapping

key(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg.KafkaMsgBuilder

KEY_FORMAT - Static variable in class com.github.hackerwin7.jlib.utils.executors.SwitchTpConfig

KEY_FORMAT_TEST - Static variable in class com.github.hackerwin7.jlib.utils.executors.SwitchTpConfig

L

length(int) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column.Builder

logger - Static variable in class com.github.hackerwin7.jlib.utils.executors.HBaseClientScanIns

LOOKAHEAD_SCAN_SEEK - Static variable in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

M

MagpieExecutor - Interface in com.github.hackerwin7.jlib.utils.frameworks.magpie

Created by IntelliJ IDEA.

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5InputStream

This method is here for testing purposes only - do not rely on it being here.

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5OutputStream

This method is here for testing purposes only - do not rely on it being here.

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.drivers.shell.ShellClient

test for the method

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.drivers.shell.ShellGetMysqlOffset

test static class

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.Base64Cus

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.DBAIpCompare

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.GZIPer

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.HBaseClientScanIns

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.HBaseReadDemo

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.HdfsWriteData

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.JSample

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.KafkaDefaultPartitionKeyExecutor

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo

args have 2 parameters

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.MysqlInsertMySec

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.RandomInsertMysql

parameter is a string = host:port:user:password:database:table:count

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.RowStringProcess

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.StringGenerator

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.SwitchTpConfig

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.TrainBdpConfig

getOrigin the ip config info

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.TrainIpUserMapExecutor

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.ValueTest

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.ZkCheckpointMagpieJob

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.ZkUtilCommand

main(String[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.ZkUtilsExecutors

command for zk client

mainProc() - Method in class com.github.hackerwin7.jlib.utils.executors.DBAIpCompare

mainProc(long) - Method in class com.github.hackerwin7.jlib.utils.executors.MysqlInsertMySec

mainProc() - Method in class com.github.hackerwin7.jlib.utils.executors.RowStringProcess

map2Json(Map) - Static method in class com.github.hackerwin7.jlib.utils.commons.convert.Convert

map convert to json

maxBackupIndex - Variable in class com.github.hackerwin7.jlib.utils.drivers.log.DailyRollingFileAppenderCustom

MD5 - Class in com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util

Fast implementation of RSA's MD5 hash generator in Java JDK Beta-2 or higher.

MD5() - Constructor for class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Class constructor

MD5(Object) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Initialize class, and update hash with ob.toString()

md5Hex(String) - Static method in class com.github.hackerwin7.jlib.utils.commons.CommonUtils

get md5 hex string

md5Hex(FileInputStream) - Static method in class com.github.hackerwin7.jlib.utils.commons.CommonUtils

by input stream

md5HexFast(String) - Static method in class com.github.hackerwin7.jlib.utils.commons.CommonUtils

fast md5 lib, but may not faster than the jdk (7, 8)

MD5InputStream - Class in com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util

MD5InputStream, a subclass of FilterInputStream implementing MD5 functionality on a stream.

MD5InputStream(InputStream) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5InputStream

Creates a MD5InputStream

MD5OutputStream - Class in com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util

MD5OutputStream is a subclass of FilterOutputStream adding MD5 hashing of the output.

MD5OutputStream(OutputStream) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5OutputStream

Creates MD5OutputStream

MyData - Class in com.github.hackerwin7.jlib.utils.drivers.mysql.data

Created by IntelliJ IDEA.

MyData() - Constructor for class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData

MyData.Column - Class in com.github.hackerwin7.jlib.utils.drivers.mysql.data

MyData.Column.Builder - Class in com.github.hackerwin7.jlib.utils.drivers.mysql.data

Mysql2HBaseDemo - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

Mysql2HBaseDemo(String, String) - Constructor for class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo

construct with string

Mysql2HBaseDemo.DescMeta - Class in com.github.hackerwin7.jlib.utils.executors

Mysql2HBaseDemo.FlushTask - Class in com.github.hackerwin7.jlib.utils.executors

MYSQL_DATABASE - Static variable in class com.github.hackerwin7.jlib.utils.drivers.mysql.conf.MysqlConf

MYSQL_HOST - Static variable in class com.github.hackerwin7.jlib.utils.drivers.mysql.conf.MysqlConf

MYSQL_PASSWORD - Static variable in class com.github.hackerwin7.jlib.utils.drivers.mysql.conf.MysqlConf

MYSQL_PORT - Static variable in class com.github.hackerwin7.jlib.utils.drivers.mysql.conf.MysqlConf

MYSQL_USER - Static variable in class com.github.hackerwin7.jlib.utils.drivers.mysql.conf.MysqlConf

MysqlClient - Class in com.github.hackerwin7.jlib.utils.drivers.mysql.client

Created by IntelliJ IDEA.

MysqlClient(MysqlConf) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.mysql.client.MysqlClient

connect the mysql server using jdbc

MysqlConf - Class in com.github.hackerwin7.jlib.utils.drivers.mysql.conf

Created by IntelliJ IDEA.

MysqlConf() - Constructor for class com.github.hackerwin7.jlib.utils.drivers.mysql.conf.MysqlConf

default config

MysqlInsertMySec - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

MysqlInsertMySec() - Constructor for class com.github.hackerwin7.jlib.utils.executors.MysqlInsertMySec

MysqlSimpleOffset() - Constructor for class com.github.hackerwin7.jlib.utils.drivers.shell.ShellGetMysqlOffset.MysqlSimpleOffset

N

name(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column.Builder

next(byte[]) - Method in interface com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient.NextRowkeyHandler

getOrigin next rowkey

nextOffset(long) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg.KafkaMsgBuilder

NullOutputStream - Class in com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.io

Copyright (c) 2001, 2002 by Pensamos Digital, Inc., All Rights Reserved.

NullOutputStream() - Constructor for class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.io.NullOutputStream

O

offset(long) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg.KafkaMsgBuilder

P

partition(int) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg.KafkaMsgBuilder

partition(String, int) - Static method in class com.github.hackerwin7.jlib.utils.executors.KafkaDefaultPartitionKeyExecutor

partitionNum(int) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo.KafkaInfoBuilder

PORT_SPLIT - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

post(String, Map<String, String>) - Method in class com.github.hackerwin7.jlib.utils.drivers.url.HttpClient

http post

prepare() - Method in interface com.github.hackerwin7.jlib.utils.frameworks.magpie.MagpieExecutor

prepare load conf, start thread etc...

PRIMARY_INPUT_CONN - Static variable in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo

PRIMARY_ROWKEY_CONN - Static variable in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo

proc1() - Static method in class com.github.hackerwin7.jlib.utils.executors.StringGenerator

proc2() - Static method in class com.github.hackerwin7.jlib.utils.executors.StringGenerator

proc3() - Static method in class com.github.hackerwin7.jlib.utils.executors.StringGenerator

proc4() - Static method in class com.github.hackerwin7.jlib.utils.executors.StringGenerator

PRODUCER_ACKS - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

PRODUCER_BROKER_LIST - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

PRODUCER_COMPRESSION_CODEC - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

PRODUCER_KEY_SERIALIZER_CLASS - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

PRODUCER_PARTITION_CLASS - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

PRODUCER_REQUEST_TIMEOUT - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

PRODUCER_TYPE - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

PRODUCER_VALUE_SERIALIZER_CLASS - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

put(String, HData) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

put single data

put(String, List<HData>) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

put list datas

put(E) - Method in class com.github.hackerwin7.jlib.utils.drivers.queue.blocking.BlockingDataQueue

put in this data, data is not null

putAsync(String, HData) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

async put HData

putAsync(String, List<HData>) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

async put bulk data, but no flush per minute or same interval flush the mutator

putAsyncOrigin(String, Put) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

async mutate

putAsyncOrigin(String, List<Put>) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

async batch mutate

putBeginoffsetsAll(Map<Integer, Long>) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

putBrokersAll(Map<Integer, String>) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

putEndOffset(int, long) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

putEndOffsetsAll(Map<Integer, Long>) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

putOffset(int, long) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

putOrigin(String, Put) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

origin put

putOrigin(String, List<Put>) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

origin puts

putPartitionBroker(int, String) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

Q

query(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.client.MysqlClient

query from sql , receive list MyData

queryAsync(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.client.MysqlClient

query sql retrieve data into queue

QUEUE_DEFAULT_SIZE - Static variable in class com.github.hackerwin7.jlib.utils.drivers.mysql.client.MysqlClient

QUEUE_LENGTH - Static variable in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo

QUEUE_SIZE - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaHighConsumer

QUEUE_SIZE - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

R

RANDOM_INT_RANGE - Static variable in class com.github.hackerwin7.jlib.utils.drivers.mysql.client.MysqlClient

RANDOM_LONG_RANGE - Static variable in class com.github.hackerwin7.jlib.utils.drivers.mysql.client.MysqlClient

RandomInsertMysql - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

RandomInsertMysql() - Constructor for class com.github.hackerwin7.jlib.utils.executors.RandomInsertMysql

randomString(int) - Static method in class com.github.hackerwin7.jlib.utils.commons.CommonUtils

random generate string

randomString() - Static method in class com.github.hackerwin7.jlib.utils.commons.CommonUtils

default random string

rdInsert(String, int) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.client.MysqlClient

random insert with table name

read() - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5InputStream

Read a byte of data.

read(byte[], int, int) - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5InputStream

Reads into an array of bytes.

readYaml(String, String) - Static method in class com.github.hackerwin7.jlib.utils.drivers.file.FileUtils

read yaml file and return the value

reload() - Method in interface com.github.hackerwin7.jlib.utils.frameworks.magpie.MagpieExecutor

reload

result2hdata(Result) - Static method in class com.github.hackerwin7.jlib.utils.commons.convert.Convert

convert a result into a hdata Single row result of a Get or Scan query.

ResumeTrans - Class in com.github.hackerwin7.jlib.utils.drivers.io

Created by IntelliJ IDEA.

ResumeTrans() - Constructor for class com.github.hackerwin7.jlib.utils.drivers.io.ResumeTrans

RowStringProcess - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

RowStringProcess() - Constructor for class com.github.hackerwin7.jlib.utils.executors.RowStringProcess

run() - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient.FlushTask

flush mutators

run() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaHighConsumer.ConsumerTh

run() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer.ConsumeThread

run consumer to consume the kafka message

run() - Method in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo.FlushTask

run() - Method in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo

check the thread and driver's status

run(String) - Method in class com.github.hackerwin7.jlib.utils.executors.RandomInsertMysql

run(String, String, String, String) - Method in class com.github.hackerwin7.jlib.utils.executors.ZkUtilCommand

run() - Method in interface com.github.hackerwin7.jlib.utils.frameworks.magpie.MagpieExecutor

main process while run

run() - Method in class com.github.hackerwin7.jlib.utils.frameworks.magpie.Topology

main process while run executor's run

S

scanData(String, String, String) - Static method in class com.github.hackerwin7.jlib.utils.executors.HBaseClientScanIns

scanData(String) - Static method in class com.github.hackerwin7.jlib.utils.executors.HBaseClientScanIns

send(KeyedMessage<String, byte[]>) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.producer.KafkaProducer

send(List<KeyedMessage<String, byte[]>>) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.producer.KafkaProducer

SEND_INTERVAL - Static variable in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo

sendKafkaMsg(KafkaMsg) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.producer.KafkaProducer

sendKafkaMsg single

sendKafkaMsg(List<KafkaMsg>) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.producer.KafkaProducer

sendKafkaMsg batch

set(String, String) - Method in class com.github.hackerwin7.jlib.utils.drivers.zk.ZkClient

set the zookeeper node

set(ZkClient, String, String) - Static method in class com.github.hackerwin7.jlib.utils.executors.ZkCheckpointMagpieJob

SET_CMD - Static variable in class com.github.hackerwin7.jlib.utils.executors.ZkCheckpointMagpieJob

setBatchSize(int) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.client.MysqlClient

set batch size

setColumn(MyData.Column) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData

setDatePattern(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.log.DailyRollingFileAppenderCustom

The DatePattern takes a string in the same format as expected by SimpleDateFormat.

setDbname(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData

setEncode(String) - Method in class com.github.hackerwin7.jlib.utils.executors.GZIPer

setIp(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData

setJtype(String) - Method in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo.DescMeta

setLogFileName(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.shell.ShellGetMysqlOffset.MysqlSimpleOffset

setLogFileOffset(long) - Method in class com.github.hackerwin7.jlib.utils.drivers.shell.ShellGetMysqlOffset.MysqlSimpleOffset

setMaxBackupIndex(int) - Method in class com.github.hackerwin7.jlib.utils.drivers.log.DailyRollingFileAppenderCustom

setMtype(String) - Method in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo.DescMeta

setName(String) - Method in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo.DescMeta

setPort(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData

setProp(String, String) - Method in class com.github.hackerwin7.jlib.utils.drivers.hbase.conf.HBaseConf

set key, value properties

setProp(String, String) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

set customer kafka config

setProp(String, String) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.conf.MysqlConf

set properties key value

setR(String, String) - Method in class com.github.hackerwin7.jlib.utils.drivers.zk.ZkClient

set recursively the process same as createR

setSize(int) - Method in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo.DescMeta

setTbname(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData

sha256Hex(String) - Static method in class com.github.hackerwin7.jlib.utils.commons.CommonUtils

sha256 interface to call

SHELL_CONF - Static variable in class com.github.hackerwin7.jlib.utils.executors.ZkCheckpointMagpieJob

ShellClient - Class in com.github.hackerwin7.jlib.utils.drivers.shell

Created by IntelliJ IDEA.

ShellClient() - Constructor for class com.github.hackerwin7.jlib.utils.drivers.shell.ShellClient

ShellGetMysqlOffset - Class in com.github.hackerwin7.jlib.utils.drivers.shell

Created by IntelliJ IDEA.

ShellGetMysqlOffset() - Constructor for class com.github.hackerwin7.jlib.utils.drivers.shell.ShellGetMysqlOffset

ShellGetMysqlOffset.MysqlSimpleOffset - Class in com.github.hackerwin7.jlib.utils.drivers.shell

showBytes(byte[]) - Static method in class com.github.hackerwin7.jlib.utils.commons.CommonUtils

showCell(Result) - Static method in class com.github.hackerwin7.jlib.utils.executors.HBaseClientScanIns

showMasterStatus(String) - Static method in class com.github.hackerwin7.jlib.utils.drivers.shell.ShellGetMysqlOffset

execute a shell command "show master status" on the specific mysql source

SIMPLE_BROKER_LIST - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

SIMPLE_END_OFFSETS - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

SIMPLE_OFFSETS - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

SIMPLE_PARTITIONS - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

SIMPLE_TOPIC - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

size() - Method in class com.github.hackerwin7.jlib.utils.drivers.queue.blocking.BlockingDataQueue

the size of queue

SLEEP_INTERVAL - Static variable in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo

SLEEP_INTERVAL - Static variable in class com.github.hackerwin7.jlib.utils.frameworks.magpie.Topology

SLEEP_SHORT_INTERVAL - Static variable in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo

SLEEPING_INTERVAL - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaHighConsumer

SLEEPING_TIME - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

SLEEPING_TIME - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.utils.KafkaUtils

sqlType(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column.Builder

start() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaHighConsumer

start the consumer client, start the thread pool to consume topic

start() - Method in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo

start main process

stop() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaHighConsumer

StringGenerator - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

StringGenerator() - Constructor for class com.github.hackerwin7.jlib.utils.executors.StringGenerator

subAppend(LoggingEvent) - Method in class com.github.hackerwin7.jlib.utils.drivers.log.DailyRollingFileAppenderCustom

This method differentiates DailyRollingFileAppenderCustom from its super class.

switchJob(String) - Method in class com.github.hackerwin7.jlib.utils.executors.SwitchTpConfig

SwitchTpConfig - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

SwitchTpConfig() - Constructor for class com.github.hackerwin7.jlib.utils.executors.SwitchTpConfig

T

take() - Method in class com.github.hackerwin7.jlib.utils.drivers.queue.blocking.BlockingDataQueue

consume a data5959

THREAD_COUNT - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaHighConsumer

THREAD_POOL_SIZE - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaSimpleConsumer

TIMEOUT - Static variable in class com.github.hackerwin7.jlib.utils.executors.SwitchTpConfig

TIMER_DELAY - Static variable in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo

TIMER_DELAY_SCHEDULE - Static variable in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

TIMER_PERIOD - Static variable in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo

TIMER_PERIOD_SCHEDULE - Static variable in class com.github.hackerwin7.jlib.utils.drivers.hbase.client.HBaseClient

toKeyedMessage(KafkaMsg) - Static method in class com.github.hackerwin7.jlib.utils.drivers.kafka.producer.KafkaProducer

convert to keyedmessage

toKeyedMessage(List<KafkaMsg>) - Static method in class com.github.hackerwin7.jlib.utils.drivers.kafka.producer.KafkaProducer

convert to batch keyedmessages

topic(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaInfo.KafkaInfoBuilder

topic(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg.KafkaMsgBuilder

topic(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo.KafkaInfoBuilder

TopicInfo - Class in com.github.hackerwin7.jlib.utils.drivers.kafka.data

Created by IntelliJ IDEA.

TopicInfo.KafkaInfoBuilder - Class in com.github.hackerwin7.jlib.utils.drivers.kafka.data

topicSum - Static variable in class com.github.hackerwin7.jlib.utils.executors.TrainBdpConfig

Topology - Class in com.github.hackerwin7.jlib.utils.frameworks.magpie

Created by IntelliJ IDEA.

Topology(MagpieExecutor) - Constructor for class com.github.hackerwin7.jlib.utils.frameworks.magpie.Topology

construct

toString() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.conf.KafkaConf

return config string show

toString() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaInfo

toString() - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

toString() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column

toString() - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData

toString() - Method in class com.github.hackerwin7.jlib.utils.drivers.shell.ShellGetMysqlOffset.MysqlSimpleOffset

toString() - Method in class com.github.hackerwin7.jlib.utils.executors.Mysql2HBaseDemo.DescMeta

TrainBdpConfig - Class in com.github.hackerwin7.jlib.utils.executors

getOrigin source host in train.bdp.com......

TrainBdpConfig() - Constructor for class com.github.hackerwin7.jlib.utils.executors.TrainBdpConfig

TrainIpUserMapExecutor - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

TrainIpUserMapExecutor() - Constructor for class com.github.hackerwin7.jlib.utils.executors.TrainIpUserMapExecutor

U

uncompressToString(byte[]) - Static method in class com.github.hackerwin7.jlib.utils.executors.GZIPer

uncompressToString(byte[], String) - Static method in class com.github.hackerwin7.jlib.utils.executors.GZIPer

Update(MD5State, byte[], int, int) - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Updates hash with the bytebuffer given (using at maximum length bytes from that buffer)

Update(byte[], int, int) - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Plain update, updates this object

Update(byte[], int) - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Update(byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Updates hash with given array of bytes

Update(byte) - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Updates hash with a single byte

Update(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Update buffer with given string.

Update(String, String) - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Update buffer with given string using the given encoding.

Update(int) - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5

Update buffer with a single integer (only & 0xff part is used, as a byte)

URLClient - Class in com.github.hackerwin7.jlib.utils.drivers.url

according to the url, read the string Created by fff on 10/28/15.

URLClient(String) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.url.URLClient

construct with url

V

val(byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg.KafkaMsgBuilder

value(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.mysql.data.MyData.Column.Builder

ValueTest - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

ValueTest() - Constructor for class com.github.hackerwin7.jlib.utils.executors.ValueTest

verify(ZkClient, String) - Static method in class com.github.hackerwin7.jlib.utils.executors.ZkCheckpointMagpieJob

W

write(byte[]) - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.io.NullOutputStream

write(byte[], int, int) - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.io.NullOutputStream

write(int) - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.io.NullOutputStream

write(int) - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5OutputStream

Writes a byte.

write(byte[], int, int) - Method in class com.github.hackerwin7.jlib.utils.drivers.algorithm.md5.util.MD5OutputStream

Writes a sub array of bytes.

Z

ZK_IDS_PATH - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.utils.KafkaUtils

ZK_TOPICS_PATH - Static variable in class com.github.hackerwin7.jlib.utils.drivers.kafka.utils.KafkaUtils

ZkCheckpointMagpieJob - Class in com.github.hackerwin7.jlib.utils.executors

set zk checkpoint to tracker and parser Created by fff on 10/28/15.

ZkCheckpointMagpieJob() - Constructor for class com.github.hackerwin7.jlib.utils.executors.ZkCheckpointMagpieJob

ZkClient - Class in com.github.hackerwin7.jlib.utils.drivers.zk

zookeeper client api Created by fff on 10/28/15.

ZkClient(String) - Constructor for class com.github.hackerwin7.jlib.utils.drivers.zk.ZkClient

zookeeper client, connection string

zks(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaInfo.KafkaInfoBuilder

zks(String) - Method in class com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo.KafkaInfoBuilder

ZkUtilCommand - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

ZkUtilCommand() - Constructor for class com.github.hackerwin7.jlib.utils.executors.ZkUtilCommand

ZkUtilsExecutors - Class in com.github.hackerwin7.jlib.utils.executors

Created by IntelliJ IDEA.

ZkUtilsExecutors() - Constructor for class com.github.hackerwin7.jlib.utils.executors.ZkUtilsExecutors

A B C D E F G H I J K L M N O P Q R S T U V W Z