Realtime Compute for Apache Flink; skaler işlevler, tablo değerli işlevler ve toplama işlevleri olmak üzere üç kategoriye ayrılan yerleşik işlevleri destekler. Yerleşik işlevler kullanım durumunuzu karşılamıyorsa bunun yerine kullanıcı tanımlı işlevleri (UDF) kullanın.
Aşağıdaki tablolar, Apache Flink 1.15 tabanlı Realtime Compute for Apache Flink'te kullanılabilen tüm yerleşik işlevleri listeler. Kullanılabilir işlevler Apache Flink sürümüne göre değişir; 1.12, 1.13, 1.14, 1.15, 1.16 ve 1.17 için resmi belgelere bakın. Ververica Runtime (VVR) 3.0.0, Apache Flink 1.12'de bulunanlara ek olarak ilave yerleşik işlevler de sunar — bkz. Skaler işlevler, Tablo değerli işlevler ve Toplama işlevleri.
Sınırlamalar
VVR 11.1 ve sonraki sürümler, Table API görevlerinde SQL metni kullanarak yerleşik işlevlerin çağrılmasını destekler.
Skaler işlevler
Karşılaştırma işlevleri
Mantıksal işlevler
| İşlev | Açıklama |
|---|---|
| BITAND | Bit düzeyinde AND işlemi gerçekleştirir. |
| BITNOT | Bit düzeyinde NOT işlemi gerçekleştirir. |
| BITOR | Bit düzeyinde OR işlemi gerçekleştirir. |
| BITXOR | Bit düzeyinde XOR işlemi gerçekleştirir. |
| boolean1 OR boolean2 | boolean1 veya boolean2 TRUE ise TRUE döndürür. |
| boolean1 AND boolean2 | boolean1 ve boolean2'nin her ikisi de TRUE ise TRUE döndürür. |
| NOT boolean | boolean FALSE ise TRUE; boolean TRUE ise FALSE; boolean UNKNOWN ise UNKNOWN döndürür. |
| boolean IS FALSE | boolean FALSE ise TRUE; boolean TRUE veya UNKNOWN ise FALSE döndürür. |
| boolean IS NOT FALSE | boolean TRUE veya UNKNOWN ise TRUE; boolean FALSE ise FALSE döndürür. |
| boolean IS TRUE | boolean TRUE ise TRUE; boolean FALSE veya UNKNOWN ise FALSE döndürür. |
| boolean IS NOT TRUE | boolean FALSE veya UNKNOWN ise TRUE; boolean TRUE ise FALSE döndürür. |
| boolean IS UNKNOWN | boolean UNKNOWN ise TRUE; boolean TRUE veya FALSE ise FALSE döndürür. |
| boolean IS NOT UNKNOWN | boolean TRUE veya FALSE ise TRUE; boolean UNKNOWN ise FALSE döndürür. |
Aritmetik işlevler
| İşlev | Açıklama |
|---|---|
| + numeric | Sayısal değeri döndürür. |
| - numeric | Sayısal değerin negatifini döndürür. |
| numeric1 + numeric2 | numeric1 ile numeric2'nin toplamını döndürür. |
| numeric1 - numeric2 | numeric1 ile numeric2 arasındaki farkı döndürür. |
| numeric1 \* numeric2 | numeric1 ile numeric2'nin çarpımını döndürür. |
| numeric1 / numeric2 | numeric1'in numeric2'ye bölümünün sonucunu döndürür. |
| numeric1 % numeric2 | numeric1'in numeric2'ye bölümünden kalanı döndürür. |
| POWER(numeric1, numeric2) | numeric1'in numeric2 üssünü döndürür. |
| ABS(numeric) | Sayısal değerin mutlak değerini döndürür. |
| SQRT(numeric) | Sayısal değerin karekökünü döndürür. |
| LN(numeric) | Sayısal değerin doğal logaritmasını (e tabanlı) döndürür. |
| LOG10(numeric) | Sayısal değerin 10 tabanındaki logaritmasını döndürür. |
| LOG2(numeric) | Sayısal değerin 2 tabanındaki logaritmasını döndürür. |
| LOG(numeric2) | LOG(numeric1, numeric2) | Tek bağımsız değişkenle, numeric2'nin doğal logaritmasını döndürür. İki bağımsız değişkenle, numeric2'nin numeric1 tabanındaki logaritmasını döndürür. numeric2 > 0 ve numeric1 > 1 olmalıdır. |
| EXP(numeric) | e'nin sayısal üssünü döndürür. |
| CEIL(numeric) | CEILING(numeric) | Sayısal değeri yukarı doğru en yakın tam sayıya yuvarlar. |
| FLOOR(numeric) | Sayısal değeri aşağı doğru en yakın tam sayıya yuvarlar. |
| SIN(numeric) | Sayısal değerin sinüsünü döndürür. |
| SINH(numeric) | Sayısal değerin hiperbolik sinüsünü döndürür. DOUBLE döndürür. |
| COS(numeric) | Sayısal değerin kosinüsünü döndürür. |
| TAN(numeric) | Sayısal değerin tanjantını döndürür. |
| TANH(numeric) | Sayısal değerin hiperbolik tanjantını döndürür. DOUBLE döndürür. |
| COT(numeric) | Sayısal değerin kotanjantını döndürür. |
| ASIN(numeric) | Sayısal değerin ark sinüsünü döndürür. |
| ACOS(numeric) | Sayısal değerin ark kosinüsünü döndürür. |
| ATAN(numeric) | Sayısal değerin ark tanjantını döndürür. |
| ATAN2(numeric1, numeric2) | (numeric1, numeric2) koordinatının ark tanjantını döndürür. |
| COSH(numeric) | Sayısal değerin hiperbolik kosinüsünü döndürür. DOUBLE döndürür. |
| DEGREES(numeric) | Radyanı dereceye dönüştürür. |
| RADIANS(numeric) | Dereceyi radyana dönüştürür. |
| SIGN(numeric) | Sayısal değerin işaretini döndürür. |
| ROUND(numeric, INT) | Sayısal değeri INT ondalık basamağa yuvarlar. |
| PI() | π değerine yakın bir değer döndürür. |
| E() | e değerine yakın bir değer döndürür. |
| RAND() | [0,0, 1,0) aralığında sözde rastgele bir double değer döndürür. |
| RAND(INT) | INT tohum değeriyle [0,0, 1,0) aralığında sözde rastgele bir double değer döndürür. |
| RAND_INTEGER(INT) | [0, INT) aralığında sözde rastgele bir tamsayı döndürür. |
| RAND_INTEGER(INT1, INT2) | INT1 tohum değeriyle [0, INT2) aralığında sözde rastgele bir tamsayı döndürür. |
| UUID() | Sözde rastgele bir UUID dizesi döndürür (RFC 4122 Tip 4). |
| BIN(INT) | INT değerinin ikili dize gösterimini döndürür. |
| HEX(numeric) | HEX(string) | Bir sayının veya dizenin onaltılık dize gösterimini döndürür. |
| TRUNCATE(numeric1, integer2) | numeric1 değerini integer2 ondalık basamağa kadar kısaltır. |
| UNHEX(expr) | Onaltılık bir dizeyi BINARY türüne dönüştürür. |
| [PERCENTILE(expr, percentage\[, frequency\])](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/#arithmetic-functions) | Belirtilen yüzde için expr ifadesinin tam yüzdelik değerini döndürür. |
Dize işlevleri
| İşlev | Açıklama |
|---|---|
| string1 || string2 | string1 ile string2'nin birleşimini döndürür. |
| CHAR_LENGTH(string) | CHARACTER_LENGTH(string) | Dizedeki karakter sayısını döndürür. |
| UPPER(string) | Dizeyi büyük harfle döndürür. |
| LOWER(string) | Dizeyi küçük harfle döndürür. |
| POSITION(string1 IN string2) | string1'in string2 içindeki ilk oluşumunun konumunu (1 tabanlı) döndürür. Bulunamazsa 0 döndürür. |
| [TRIM(\[BOTH | LEADING | TRAILING\] string1 FROM string2)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions) | string2'den baştaki, sondaki veya her iki taraftaki string1 örneklerini kaldırır. Örneğin, TRIM(TRAILING 'fe' FROM 'abcdef') ifadesi 'abcd' değerini döndürür. |
| LTRIM(string) | Diziden baştaki boşlukları kaldırır. |
| RTRIM(string) | Dizeden sondaki boşlukları kaldırır. |
| REPEAT(string, int) | Dizeyi int kez tekrarlayarak döndürür. |
| REGEXP_REPLACE | Bir dizedeki desen eşleşmelerini değiştirir ve sonucu döndürür. |
| [OVERLAY(string1 PLACING string2 FROM integer1 \[FOR integer2\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions) | string1 içinde integer1 konumundan başlayarak integer2 karakteri string2 ile değiştirir. integer2 varsayılan olarak string2 uzunluğuna ayarlanır. |
| [SUBSTRING(string FROM integer1 \[FOR integer2\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions) | integer1 konumundan başlayan dizenin alt dizesini döndürür. integer2 belirtilirse uzunluk integer2 karakterle sınırlanır. |
| REPLACE(string1, string2, string3) | string1 içindeki string2'nin örtüşmeyen tüm oluşumlarını string3 ile değiştirir. |
| [REGEXP_EXTRACT(string1, string2\[, integer\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions) | string1'i string2 düzenli ifadesini kullanarak böler ve integer konumundaki alt dizeyi döndürür. |
| INITCAP(string) | Her kelimenin ilk harfini büyük, geri kalanını küçük yapar. |
| CONCAT(string1, string2, ...) | Birden çok dizeyi birleştirir. Herhangi bir giriş NULL ise NULL döndürür. |
| CONCAT_WS(string1, string2, string3, ...) | string2, string3 vb. dizeleri string1 ayırıcısıyla birleştirir. |
| LPAD(string1, integer, string2) | string1'i sol taraftan string2 ile integer uzunluğuna ulaşana kadar doldurur. |
| RPAD(string1, integer, string2) | string1'i sağ taraftan string2 ile integer uzunluğuna ulaşana kadar doldurur. |
| FROM_BASE64(string) | Base64 kodlu bir dizenin kodunu çözer. |
| TO_BASE64(string) | Dizeyi Base64 kullanarak kodlar. |
| ASCII(string) | Dizideki ilk karakterin ASCII kodunu döndürür. |
| CHR(integer) | Tamsayıya karşılık gelen ASCII karakterini döndürür. |
| DECODE(binary, string) | İkili veriyi belirtilen kodlama ile (US-ASCII, ISO-8859-1, UTF-8, UTF-16BE, UTF-16LE veya UTF-16) çözer. |
| ENCODE(string1, string2) | string1'i string2 tarafından belirtilen kodlamayla (US-ASCII, ISO-8859-1, UTF-8, UTF-16BE, UTF-16LE veya UTF-16) kodlar. |
| INSTR(string1, string2) | string2'nin string1 içindeki ilk oluşumunun konumunu döndürür. |
| LEFT(string, integer) | Dizenin en soldaki integer karakterlerini döndürür. |
| RIGHT(string, integer) | Dizenin en sağdaki integer karakterlerini döndürür. |
| [LOCATE(string1, string2\[, integer\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions) | string1'in string2 içindeki ilk oluşumunun konumunu integer konumundan başlayarak döndürür. |
| PARSE_URL | URL'nin belirli bir bölümünü ayrıştırır ve değeri döndürür. |
| REGEXP | Bir dizede düzenli ifade desenini arar ve boolean döndürür. |
| REGEXP_SUBSTR(str, regex) | str içinde regex ile eşleşen ilk alt dizeyi döndürür. |
| REGEXP_INSTR(str, regex) | str içinde regex ile eşleşen ilk alt dizenin konumunu döndürür. |
| REGEXP_COUNT(str, regex) | str'nin regex ile kaç kez eşleştiğini döndürür. |
| [REGEXP_EXTRACT_ALL(str, regex\[, extractIndex\])](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/#string-functions) | str içinde regex ile eşleşen ve extractIndex grubuna karşılık gelen tüm alt dizeleri çıkarır. |
| REVERSE(string) | Dizeyi ters sırada döndürür. |
| SPLIT_INDEX | Bir dizeyi bir sınırlayıcıya göre böler ve belirtilen konumdaki öğeyi döndürür. |
| [STR_TO_MAP(string1\[, string2, string3\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions) | string1'i sınırlayıcıları kullanarak anahtar-değer çiftlerine böler ve bir eşlem döndürür. |
| [SUBSTR(string\[, integer1\[, integer2\]\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions) | integer1 konumundan başlayan ve integer2 uzunluğundaki dizenin alt dizesini döndürür. |
| [PRINTF(format\[, obj\]\*)](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/#string-functions) | printf tarzı biçimlendirme kullanarak biçimlendirilmiş bir dize döndürür. |
| TRANSLATE(expr, fromStr, toStr) | fromStr'deki her karakteri toStr'deki karşılık gelen karakterle değiştirir. |
| [ELT(index, expr\[, exprs\]\*)](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/#string-functions) | index konumundaki (1 tabanlı) ifadeyi döndürür. |
| [BTRIM(str\[, trimStr\])](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/#string-functions) | str'den trimStr'deki baştaki ve sondaki karakterleri kaldırır. Varsayılan olarak boşluk karakterlerini kaldırır. |
| STARTSWITH(expr, startExpr) | expr, startExpr ile başlıyorsa TRUE döndürür. startExpr boşsa TRUE döndürür. |
| ENDSWITH(expr, endExpr) | expr, endExpr ile bitiyorsa TRUE döndürür. endExpr boşsa TRUE döndürür. |
Zaman işlevleri
| İşlev | Açıklama |
|---|---|
| DATE string | yyyy-MM-dd biçimindeki bir dizeden ayrıştırılan SQL DATE değerini döndürür. |
| DATEDIFF | İki tarih değeri arasındaki farkı hesaplar. |
| DATE_ADD | Belirtilen sayıda gün sonrasına ait bir tarihi döndürür. |
| DATE_SUB | Belirtilen sayıda gün öncesine ait bir tarihi döndürür. |
| TIME string | HH:mm:ss biçimindeki bir dizeden ayrıştırılan SQL TIME değerini döndürür. |
| TIMESTAMP string | yyyy-MM-dd HH:mm:ss[.SSS] biçimindeki bir dizeden ayrıştırılan SQL TIMESTAMP değerini döndürür. |
| INTERVAL string range | dd hh:mm:ss.fff biçiminden milisaniye cinsinden veya yyyy-mm biçiminden ay cinsinden aralıkları ayrıştırır. |
| LOCALTIME | Geçerli yerel saati SQL TIME(0) olarak döndürür. |
| LOCALTIMESTAMP | Geçerli yerel zaman damgasını SQL TIMESTAMP(3) olarak döndürür. |
| CURRENT_TIME | Geçerli yerel saati SQL TIME olarak döndürür. LOCALTIME ile eşdeğerdir. |
| CURRENT_DATE | Geçerli yerel tarihi SQL DATE olarak döndürür. |
| CURRENT_TIMESTAMP | Geçerli yerel zaman damgasını SQL TIMESTAMP olarak döndürür. |
| NOW() | Geçerli yerel zaman damgasını SQL TIMESTAMP olarak döndürür. CURRENT_TIMESTAMP ile eşdeğerdir. |
| CURRENT_ROW_TIMESTAMP() | Geçerli yerel zaman damgasını SQL TIMESTAMP olarak döndürür. |
| EXTRACT(timeintervalunit FROM temporal) | Belirtilen timeintervalunit için LONG değerini zamansal ifadeden çıkarır. |
| YEAR(date) | SQL DATE değerinin yıl bileşenini döndürür. |
| QUARTER(date) | SQL DATE değerinin çeyrek bileşenini döndürür. |
| MONTH(date) | SQL DATE değerinin ay bileşenini döndürür. |
| WEEK(date) | SQL DATE değeri için yılın hafta numarasını döndürür. |
| DAYOFYEAR(date) | SQL DATE değeri için yılın gün numarasını döndürür. |
| DAYOFMONTH(date) | SQL DATE değeri için ayın gün numarasını döndürür. |
| HOUR(timestamp) | SQL TIMESTAMP değerinin saat bileşenini döndürür. |
| MINUTE(timestamp) | SQL TIMESTAMP değerinin dakika bileşenini döndürür. |
| SECOND(timestamp) | SQL TIMESTAMP değerinin saniye bileşenini döndürür. |
| FLOOR(timepoint TO timeintervalunit) | Zaman noktasını en yakın timeintervalunit birimine aşağı yuvarlar. |
| CEIL(timepoint TO timeintervalunit) | Zaman noktasını en yakın timeintervalunit birimine yukarı yuvarlar. |
| (timepoint1, temporal1) OVERLAPS (timepoint2, temporal2) | İki zaman aralığı örtüşüyorsa TRUE döndürür. |
| DATE_FORMAT | Bir STRING tarih değerini belirtilen desene göre biçimlendirir. |
| DATE_FORMAT_TZ | Bir TIMESTAMP değerini belirtilen saat dilimi ve biçimde STRING olarak biçimlendirir. |
| TIMESTAMPADD(timeintervalunit, interval, timepoint) | Zaman noktasına bir aralık ekler ve yeni zaman noktasını döndürür. |
| TIMESTAMPDIFF(timepointunit, timepoint1, timepoint2) | timepoint1 ile timepoint2 arasındaki zaman aralığını döndürür. |
| CONVERT_TZ(string1, string2, string3) | datetime dizesi string1'i string2 saat diliminden string3 saat dilimine dönüştürür. yyyy-MM-dd HH:mm:ss biçimini bekler. |
| FROM_UNIXTIME | Unix zaman damgasından bir VARCHAR tarih değeri döndürür. |
| UNIX_TIMESTAMP | Bir tarih değerini Unix zaman damgasına dönüştürür. |
| TO_DATE | Bir INT veya VARCHAR tarih değerini DATE veri türüne dönüştürür. |
| TO_TIMESTAMP_LTZ(numeric, precision) | Bir Unix zaman damgasını TIMESTAMP_LTZ türüne (milisaniye veya saniye cinsinden) dönüştürür. |
| [TO_TIMESTAMP(string1\[, string2\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#temporal-functions) | string1'i UTC+0'da bir zaman damgasına dönüştürür. Biçim dizesi string2 varsayılan olarak yyyy-MM-dd HH:mm:ss olur. |
| TO_TIMESTAMP_TZ | Bir VARCHAR tarih değerini belirtilen saat diliminde TIMESTAMP türüne dönüştürür. |
| CURRENT_WATERMARK(rowtime) | rowtime sütunu için geçerli su işaretini döndürür. |
Koşullu işlevler
Veri türü dönüştürme işlevleri
| İşlev | Açıklama |
|---|---|
| CONV | Sayısal değerleri veya karakterleri tabanlar arasında dönüştürür. |
| CAST(value AS type) | Değeri belirtilen türe dönüştürür. |
| TYPEOF(input) | TYPEOF(input, force\_serializable) | Girişin veri türünün dize gösterimini döndürür. |
Koleksiyon işlevleri
| İşlev | Açıklama |
|---|---|
| CARDINALITY(array) | Dizideki öğe sayısını döndürür. |
| [array\[INT\]](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#collection-functions) | Dizideki INT konumundaki öğeyi döndürür. |
| ELEMENT(array) | Dizinin kardinalitesi 1 ise tek öğeyi döndürür. |
| CARDINALITY(map) | Eşlemdeki girdi sayısını döndürür. |
| [map\[value\]](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#collection-functions) | Eşlemde belirtilen anahtarla ilişkili değeri döndürür. |
JSON işlevleri
Değer oluşturma işlevleri
| İşlev | Açıklama |
|---|---|
| [(value1 \[, value2\]\*)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#value-construction-functions) | Verilen değerlerden oluşturulan bir satır döndürür. |
| [ARRAY\[value1 \[, value2\]\*\]](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#value-construction-functions) | Verilen değerlerden oluşturulan bir dizi döndürür. |
| [MAP\[value1, value2 \[, value3, value4\]\*\]](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#value-construction-functions) | Verilen anahtar-değer çiftlerinden oluşturulan bir eşlem döndürür. |
Değer alma işlevleri
| İşlev | Açıklama |
|---|---|
| tableName.compositeType.field | Tuple veya POJO gibi birleşik türlerden bir alan değerini çıkarır. |
| tableName.compositeType.\* | Tuple veya POJO gibi birleşik türleri ayrı alanlara genişletir. |
Gruplama işlevleri
| İşlev | Açıklama |
|---|---|
| GROUP_ID() | Gruplama anahtarlarının bir kombinasyonunu benzersiz şekilde tanımlayan bir tamsayı döndürür. |
| [GROUPING(expression1 \[, expression2\]\*) | GROUPING_ID(expression1 \[, expression2\]\*)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#grouping-functions) | Verilen ifadelerin gruplama durumunu temsil eden bir bit vektörü döndürür. |
Hash işlevleri
| İşlev | Açıklama |
|---|---|
| MD5(string) | Dizenin MD5 hash değerini 32 karakterlik onaltılık dize olarak döndürür. |
| SHA1(string) | Dizenin SHA-1 hash değerini 40 karakterlik onaltılık dize olarak döndürür. |
| SHA224(string) | Dizenin SHA-224 hash değerini 56 karakterlik onaltılık dize olarak döndürür. |
| SHA256(string) | Dizenin SHA-256 hash değerini 64 karakterlik onaltılık dize olarak döndürür. |
| SHA384(string) | Dizenin SHA-384 hash değerini 96 karakterlik onaltılık dize olarak döndürür. |
| SHA512(string) | Dizenin SHA-512 hash değerini 128 karakterlik onaltılık dize olarak döndürür. |
| SHA2(string, hashLength) | hashLength değerine bağlı olarak SHA-224, SHA-256, SHA-384 veya SHA-512 kullanarak hash değeri döndürür. |
| MURMUR_HASH | Girişin 32 bitlik Murmur hash değerini hesaplar. |
| MURMUR_HASH_64 | Murmur 128 algoritmasını kullanarak girişin 64 bitlik Murmur hash değerini hesaplar. |
Diğer skaler işlevler
| İşlev | Açıklama |
|---|---|
| ISNAN | Belirtilen kayan noktalı sayı NaN ise TRUE döndürür (Java'daki Double.isNaN() veya Float.isNaN() ile eşdeğerdir). |
| KEYVALUE | Bir dizeyi split1'i çift ayırıcısı ve split2'yi anahtar-değer ayırıcısı olarak kullanarak anahtar-değer çiftlerine böler ve ardından belirtilen anahtar için değeri döndürür. |
Tablo değerli işlevler
| İşlev | Açıklama |
|---|---|
| GENERATE_SERIES | from, from+1, from+2 ... to-1 desenini izleyen bir değer dizisi oluşturur. |
| JSON_TUPLE | Bir JSON dizesinden belirtilen yollardaki değerleri çıkarır. |
| MULTI_KEYVALUE | Bir dizeyi split1'i çift ayırıcısı ve split2'yi anahtar-değer ayırıcısı olarak kullanarak anahtar-değer çiftlerine böler ve ardından belirtilen anahtarlar için değerleri döndürür. |
| STRING_SPLIT | Bir dizeyi belirtilen bir sınırlayıcı kullanarak alt dizelere böler ve bunları liste olarak döndürür. |
| FROM_CHANGELOG(input => TABLE t [, ...]) |
İşlem kodları içeren yalnızca ekleme yapılabilen bir akışı, güncellemeler içerebilen bir değişiklik günlüğü akışına dönüştürür. Tam parametre listesi, anlamlar ve kullanım için bkz. Değişiklik Günlüğü Dönüştürme. Not
Yalnızca VVR 11.9 ve sonraki sürümlerde desteklenir. |
| TO_CHANGELOG(input => TABLE t [, ...]) |
Bir değişiklik günlüğü akışını, açık işlem kodları içeren yalnızca ekleme yapılabilen bir akışa dönüştürür. Tam parametre listesi, anlamlar ve kullanım için bkz. Değişiklik Günlüğü Dönüştürme. Not
Yalnızca VVR 11.9 ve sonraki sürümlerde desteklenir. |
Toplama işlevleri
Not
VVR 11.6'dan itibaren varyans ve standart sapma işlevleri daha iyi hesaplama doğruluğu için geliştirilmiş algoritmalar kullanır. Bu değişiklik durum uyumsuzluğuna neden olur — bu işlevleri kullanan görevler durumsuz yeniden başlatma gerektirir. Önceki davranışı korumak için table.exec.legacy-stddev-behaviour parametresini true olarak ayarlayın. Etkilenen işlevler: STDDEV_POP, STDDEV_SAMP, VAR_POP, VAR_SAMP.