org.apache.flink.table.data.binary

Class BinaryStringDataUtil

java.lang.Object

org.apache.flink.table.data.binary.BinaryStringDataUtil

public class BinaryStringDataUtil
extends Object

Util for BinaryStringData.

Field Summary

Fields

Modifier and Type	Field and Description
static BinaryStringData[]	EMPTY_STRING_ARRAY

Constructor Summary

Constructors

Constructor and Description
BinaryStringDataUtil()

Method Summary

Modifier and Type	Method and Description
static BinaryStringData	concat(BinaryStringData... inputs) Concatenates input strings together into a single string.
static BinaryStringData	concat(Iterable<BinaryStringData> inputs)
static BinaryStringData	concatWs(BinaryStringData separator, BinaryStringData... inputs) Concatenates input strings together into a single string using the separator.
static BinaryStringData	concatWs(BinaryStringData separator, Iterable<BinaryStringData> inputs)
static BinaryStringData	hash(BinaryStringData str, MessageDigest md) Calculate the hash value of a given string use MessageDigest.
static BinaryStringData	hash(BinaryStringData str, String algorithm)
static BinaryStringData	hash(byte[] bytes, MessageDigest md) Calculate the hash value of the given bytes use MessageDigest.
static boolean	isSpaceString(BinaryStringData str)
static BinaryStringData	keyValue(BinaryStringData str, byte split1, byte split2, BinaryStringData keyName) Parse target string as key-value string and return the value matches key name.
static BinaryStringData	reverse(BinaryStringData str) Reverse each character in current string.
static String	safeToString(BinaryStringData str)
static BinaryStringData[]	splitByWholeSeparatorPreserveAllTokens(BinaryStringData str, BinaryStringData separator) Splits the provided text into an array, separator string specified.
static BinaryStringData	substringSQL(BinaryStringData str, int pos)
static BinaryStringData	substringSQL(BinaryStringData str, int pos, int length)
static Boolean	toBooleanSQL(BinaryStringData str) Decide boolean representation of a string.
static Byte	toByte(BinaryStringData str)
static DecimalData	toDecimal(BinaryStringData str, int precision, int scale) Parses this BinaryStringData to DecimalData.
static Double	toDouble(BinaryStringData str)
static Float	toFloat(BinaryStringData str)
static Integer	toInt(BinaryStringData str) Parses this BinaryStringData to Int.
static Long	toLong(BinaryStringData str) Parses this BinaryStringData to Long.
static Short	toShort(BinaryStringData str)
static BinaryStringData	trim(BinaryStringData str, BinaryStringData trimStr) Walk each character of current string from both ends, remove the character if it is in trim string.
static BinaryStringData	trim(BinaryStringData str, boolean leading, boolean trailing, BinaryStringData seek)
static BinaryStringData	trimLeft(BinaryStringData str)
static BinaryStringData	trimLeft(BinaryStringData str, BinaryStringData trimStr) Walk each character of current string from left end, remove the character if it is in trim string.
static BinaryStringData	trimRight(BinaryStringData str)
static BinaryStringData	trimRight(BinaryStringData str, BinaryStringData trimStr) Walk each character of current string from right end, remove the character if it is in trim string.

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY_STRING_ARRAY

public static final BinaryStringData[] EMPTY_STRING_ARRAY

Constructor Detail

BinaryStringDataUtil

public BinaryStringDataUtil()

Method Detail

splitByWholeSeparatorPreserveAllTokens

public static BinaryStringData[] splitByWholeSeparatorPreserveAllTokens(BinaryStringData str,
                                                                        BinaryStringData separator)

Splits the provided text into an array, separator string specified.

The separator is not included in the returned String array. Adjacent separators are treated as separators for empty tokens.

A null separator splits on whitespace.

 "".splitByWholeSeparatorPreserveAllTokens(*)                 = []
 "ab de fg".splitByWholeSeparatorPreserveAllTokens(null)      = ["ab", "de", "fg"]
 "ab   de fg".splitByWholeSeparatorPreserveAllTokens(null)    = ["ab", "", "", "de", "fg"]
 "ab:cd:ef".splitByWholeSeparatorPreserveAllTokens(":")       = ["ab", "cd", "ef"]
 "ab-!-cd-!-ef".splitByWholeSeparatorPreserveAllTokens("-!-") = ["ab", "cd", "ef"]
 

Note: returned binary strings reuse memory segments from the input str.

Parameters:

separator - String containing the String to be used as a delimiter, null splits on whitespace

Returns:

an array of parsed Strings, null if null String was input

toBooleanSQL

public static Boolean toBooleanSQL(BinaryStringData str)

Decide boolean representation of a string.

hash

public static BinaryStringData hash(byte[] bytes,
                                    MessageDigest md)

Calculate the hash value of the given bytes use MessageDigest.

hash

public static BinaryStringData hash(BinaryStringData str,
                                    MessageDigest md)

Calculate the hash value of a given string use MessageDigest.

hash

public static BinaryStringData hash(BinaryStringData str,
                                    String algorithm)
                             throws NoSuchAlgorithmException

Throws:

NoSuchAlgorithmException

toDecimal

public static DecimalData toDecimal(BinaryStringData str,
                                    int precision,
                                    int scale)

Parses this BinaryStringData to DecimalData.

Returns:

DecimalData value if the parsing was successful, or null if overflow

Throws:

NumberFormatException - if the parsing failed.

toLong

public static Long toLong(BinaryStringData str)

Parses this BinaryStringData to Long.

Note that, in this method we accumulate the result in negative format, and convert it to positive format at the end, if this string is not started with '-'. This is because min value is bigger than max value in digits, e.g. Long.MAX_VALUE is '9223372036854775807' and Long.MIN_VALUE is '-9223372036854775808'.

This code is mostly copied from LazyLong.parseLong in Hive.

Returns:

Long value if the parsing was successful else null.

toInt

public static Integer toInt(BinaryStringData str)

Parses this BinaryStringData to Int.

Note that, in this method we accumulate the result in negative format, and convert it to positive format at the end, if this string is not started with '-'. This is because min value is bigger than max value in digits, e.g. Integer.MAX_VALUE is '2147483647' and Integer.MIN_VALUE is '-2147483648'.

This code is mostly copied from LazyInt.parseInt in Hive.

Note that, this method is almost same as `toLong`, but we leave it duplicated for performance reasons, like Hive does.

Returns:

Integer value if the parsing was successful else null.

toShort

public static Short toShort(BinaryStringData str)

toByte

public static Byte toByte(BinaryStringData str)

toDouble

public static Double toDouble(BinaryStringData str)

toFloat

public static Float toFloat(BinaryStringData str)

keyValue

public static BinaryStringData keyValue(BinaryStringData str,
                                        byte split1,
                                        byte split2,
                                        BinaryStringData keyName)

Parse target string as key-value string and return the value matches key name. If accept any null arguments, return null. example: keyvalue('k1=v1;k2=v2', ';', '=', 'k2') = 'v2' keyvalue('k1:v1,k2:v2', ',', ':', 'k3') = NULL

Parameters:

split1 - separator between key-value tuple.

split2 - separator between key and value.

keyName - name of the key whose value you want return.

Returns:

target value.

substringSQL

public static BinaryStringData substringSQL(BinaryStringData str,
                                            int pos)

substringSQL

public static BinaryStringData substringSQL(BinaryStringData str,
                                            int pos,
                                            int length)

concat

public static BinaryStringData concat(BinaryStringData... inputs)

Concatenates input strings together into a single string. Returns NULL if any argument is NULL.

concat

public static BinaryStringData concat(Iterable<BinaryStringData> inputs)

concatWs

public static BinaryStringData concatWs(BinaryStringData separator,
                                        BinaryStringData... inputs)

Concatenates input strings together into a single string using the separator. Returns NULL If the separator is NULL.

Note: CONCAT_WS() does not skip any empty strings, however it does skip any NULL values after the separator. For example, concat_ws(",", "a", null, "c") would yield "a,c".

concatWs

public static BinaryStringData concatWs(BinaryStringData separator,
                                        Iterable<BinaryStringData> inputs)

reverse

public static BinaryStringData reverse(BinaryStringData str)

Reverse each character in current string.

Returns:

a new string which character order is reverse to current string.

trim

public static BinaryStringData trim(BinaryStringData str,
                                    BinaryStringData trimStr)

Walk each character of current string from both ends, remove the character if it is in trim string. Return the new substring which both ends trim characters have been removed.

Parameters:

trimStr - the trim string

Returns:

A subString which both ends trim characters have been removed.

trimLeft

public static BinaryStringData trimLeft(BinaryStringData str)

isSpaceString

public static boolean isSpaceString(BinaryStringData str)

trimLeft

public static BinaryStringData trimLeft(BinaryStringData str,
                                        BinaryStringData trimStr)

Walk each character of current string from left end, remove the character if it is in trim string. Stops at the first character which is not in trim string. Return the new substring.

Parameters:

trimStr - the trim string

Returns:

A subString which removes all of the character from the left side that is in trim string.

trimRight

public static BinaryStringData trimRight(BinaryStringData str)

trimRight

public static BinaryStringData trimRight(BinaryStringData str,
                                         BinaryStringData trimStr)

Walk each character of current string from right end, remove the character if it is in trim string. Stops at the first character which is not in trim string. Return the new substring.

Parameters:

trimStr - the trim string

Returns:

A subString which removes all of the character from the right side that is in trim string.

trim

public static BinaryStringData trim(BinaryStringData str,
                                    boolean leading,
                                    boolean trailing,
                                    BinaryStringData seek)

safeToString

public static String safeToString(BinaryStringData str)