程序包 org.apache.iotdb.jdbc

类 GroupedLSBWatermarkEncoder

java.lang.Object

org.apache.iotdb.jdbc.GroupedLSBWatermarkEncoder

所有已实现的接口:

WatermarkEncoder

public class GroupedLSBWatermarkEncoder
extends java.lang.Object
implements WatermarkEncoder

构造器概要

构造器

构造器	说明
GroupedLSBWatermarkEncoder(java.lang.String secretKey, java.lang.String bitString, int markRate, int minBitPosition)

方法概要

修饰符和类型	方法	说明
double	encodeDouble(double value, long timestamp)
float	encodeFloat(float value, long timestamp)
int	encodeInt(int value, long timestamp)
long	encodeLong(long value, long timestamp)
org.apache.iotdb.tsfile.read.common.RowRecord	encodeRecord(org.apache.iotdb.tsfile.read.common.RowRecord record)
static int	hashMod(java.lang.String val, java.lang.Integer base)
boolean	needEncode(long timestamp)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

GroupedLSBWatermarkEncoder

public GroupedLSBWatermarkEncoder(java.lang.String secretKey,
                                  java.lang.String bitString,
                                  int markRate,
                                  int minBitPosition)

方法详细资料

hashMod

public static int hashMod(java.lang.String val,
                          java.lang.Integer base)

needEncode

public boolean needEncode(long timestamp)

指定者:

needEncode 在接口中 WatermarkEncoder

encodeInt

public int encodeInt(int value,
                     long timestamp)

指定者:

encodeInt 在接口中 WatermarkEncoder

encodeLong

public long encodeLong(long value,
                       long timestamp)

指定者:

encodeLong 在接口中 WatermarkEncoder

encodeFloat

public float encodeFloat(float value,
                         long timestamp)

指定者:

encodeFloat 在接口中 WatermarkEncoder

encodeDouble

public double encodeDouble(double value,
                           long timestamp)

指定者:

encodeDouble 在接口中 WatermarkEncoder

encodeRecord

public org.apache.iotdb.tsfile.read.common.RowRecord encodeRecord(org.apache.iotdb.tsfile.read.common.RowRecord record)

指定者:

encodeRecord 在接口中 WatermarkEncoder