概要
統合型は、Avro または JSON イベントに表示されるデータ型です。これらはソースの Oracle データベース、MySQL データベース、PostgreSQL データベース、BigQuery または Cloud Storage の宛先など、複数のデータソースと宛先でのデータタイプ固有の統合表現です。
統合型は、サポートされているすべてのソース型のすべての型表現のスーパーセットであり、元のソース型を汎用的かつロスレスに表しています。
次の表に、次の表を示します。
- データストリームに関連付けられている統合型
- Oracle データベース、MySQL データベース、PostgreSQL データベースのデータ型と、Datastream の統合型のマッピング
各種ソースのデータ型と BigQuery のデータ型のマッピングについては、BigQuery の宛先に関するドキュメントをご覧ください。
Datastream の統合タイプ
型名 | 情報 | Avro の定義 | JSON 定義 |
---|---|---|---|
BOOLEAN |
ブール値 | ブール値 | ブール値 |
BYTES |
符号なしバイトのシーケンス | バイト | 文字列 |
DATE |
エポックからの日数 | 日付論理型 | 文字列 [ISO-8601] |
DATETIME |
日付(エポックからの日数)と時間(午前 0 時からのマイクロ秒単位) | カスタム型 { "type": "record", "name": "datetime", "fields": [ {"name": "date", "type": "int", "logicalType": "date"}, {"name": "time", "type": "long", "logicalType": "time-micros"} ] } |
文字列 [ISO-8601] |
DECIMAL (p,s) |
任意精度の符号付き 10 進数 | 10 進論理型 | 数値 |
DOUBLE |
64 ビット浮動小数点数 | double | 数値 |
FLOAT |
32 ビット浮動小数点数 | float | 数値 |
INTEGER |
32 ビット整数。 | 整数 | 数値 |
INTERVAL |
2 つのイベント間の期間(月、時間、マイクロ秒) | カスタム型 { "type": "record", "name": "interval", "fields": [ {"name": "months", "type": "int"} {"name": "hours", "type": "int"}, {"name": "micros", "type": "long"} ] } |
文字列 [ISO-8601] |
JSON |
JSON オブジェクト | カスタム論理型 { "type": "string", "logicalType": "json" } |
ネストされた JSON |
LONG |
64 ビット整数。 | long | 数値 |
NUMBER |
数値データ型 | カスタム論理型 { "type": "string", "logicalType": "number" } |
文字列 |
STRING |
無制限の文字列長 | 文字列 | 文字列 |
TIME |
タイムゾーンに関係なく、午前 0 時から経過したマイクロ秒数。 | タイムマイクロの論理型 | 文字列 [ISO-8601] |
TIME_INTERVAL |
2 つのイベント間の経過時間(マイクロ秒単位) | カスタム論理型 { "type": "long", "logicalType": "time-interval-micros" } |
long |
TIMESTAMP |
エポックからの経過時間(マイクロ秒単位) | タイムスタンプ論理型 | 文字列 [ISO-8601] |
TIMESTAMP WITH TIME ZONE |
特定のタイムゾーン オフセットを持つエポックからの経過時間(ミリ秒単位) | カスタム型 { "type": "record", "name": "timestampTz", "fields": [ {"name": "timestamp", "type": "long" "logicalType": "timestamp-micros"}, {"name": "offset", "type": "int" "logicalType": "time-millis"} ] } |
文字列 [ISO-8601] |
TIME WITH TIME ZONE |
特定のタイムゾーン オフセットが午前 0 時から経過したマイクロ秒数 | カスタム型 { "type": "record", "name": "timeTz", "fields": [ {"name": "time", "type": "long" "logicalType": "time-micros"}, {"name": "offset", "type": "int", "logicalType": "time-millis"} ] } |
文字列 [ISO-8601] |
UNION |
さまざまなデータ型 | Union | 配列 |
UNSUPPORTED |
サポートされていないデータ型 | カスタム論理型 { "type": "null", "logicalType": "unsupported" } |
null |
VARCHAR |
最大 n 文字までの文字列 | カスタム論理型 { "type": "string", "logicalType": "varchar" "length": N } |
文字列 |
Oracle のデータ型を Datastream の統合型にマッピングする
Oracle のデータ型 | Datastream の統合タイプ |
---|---|
ANYDATA |
UNSUPPORTED |
BFILE |
STRING |
BINARY DOUBLE |
DOUBLE |
BINARY FLOAT |
FLOAT |
BLOB |
BYTES |
CHAR |
VARCHAR |
CLOB |
STRING |
DATE |
DATETIME
|
DOUBLE PRECISION |
DOUBLE |
FLOAT(p) |
DOUBLE |
INTERVAL DAY TO SECOND |
UNSUPPORTED |
INTERVAL YEAR TO MONTH |
UNSUPPORTED |
LONG/LONG RAW |
UNSUPPORTED |
NCHAR |
STRING |
NCLOB |
STRING |
NUMBER |
NUMBER |
NUMBER(p,s<=0) |
p<=18 の場合、 |
NUMBER(p,s>0) |
p= |
NVARCHAR2 |
STRING |
RAW |
STRING |
ROWID |
STRING |
SDO_GEOMETRY |
UNSUPPORTED |
SMALLINT |
INTEGER |
TIMESTAMP |
TIMESTAMP
|
TIMESTAMP WITH TIME ZONE |
TIMESTAMP WITH TIME ZONE
|
UDT (ユーザー定義型) |
UNSUPPORTED |
UROWID |
UNSUPPORTED |
VARCHAR |
VARCHAR |
VARCHAR2 |
VARCHAR |
XMLTYPE |
UNSUPPORTED |
MySQL のデータ型を Datastream の統合型にマッピングする
MySQL のデータ型 | Datastream の統合タイプ |
---|---|
BIGINT(size) |
署名されている場合は LONG 、署名がない場合は DECIMAL となります。 |
BINARY(size) |
STRING (hex encoded) |
BIT(size) |
LONG |
BLOB(size) |
STRING (hex encoded) |
BOOL |
INTEGER |
CHAR(size) |
STRING |
DATE |
宛先が BigQuery の場合は DATE 、Cloud Storage の場合は TIMESTAMP です。 |
DATETIME(fsp) |
DATETIME |
DECIMAL(size, d) |
DECIMAL(size, d) |
DOUBLE(size, d) |
DOUBLE |
ENUM(val1, val2, val3, ...) |
STRING |
FLOAT(p) |
FLOAT |
FLOAT(size, d) |
FLOAT |
INTEGER(size) |
INTEGER |
JSON |
JSON |
LONGBLOB |
STRING (hex encoded) |
LONGTEXT |
STRING (hex encoded) |
MEDIUMBLOB |
STRING (hex encoded) |
MEDIUMINT(size) |
INTEGER |
MEDIUMTEXT |
STRING |
SET(val1, val2, val3, ...) |
STRING |
SMALLINT(size) |
INTEGER |
TEXT(size) |
STRING |
TIME(fsp) |
INTERVAL |
TIMESTAMP(fsp) |
TIMESTAMP |
TINYBLOB |
STRING (hex encoded) |
TINYINT(size) |
INTEGER |
TINYTEXT |
STRING |
VARBINARY(size) |
STRING (hex encoded) |
VARCHAR |
STRING |
YEAR |
INTEGER |
PostgreSQL のデータ型を Datastream の統合型にマッピングする
PostgreSQL のデータ型 | Datastream の統合タイプ |
---|---|
ARRAY |
JSON
|
BIGINT |
LONG |
BIT |
BYTES |
BIT_VARYING |
BYTES |
BOOLEAN |
BOOLEAN |
BOX |
UNSUPPORTED |
BYTEA |
BYTES |
CHARACTER |
|
CHARACTER_VARYING |
|
CIDR |
STRING |
CIRCLE |
UNSUPPORTED |
CITEXT |
STRING |
DATE |
DATE |
DOUBLE_PRECISION |
DOUBLE |
ENUM |
STRING |
INET |
STRING |
INTEGER |
INTEGER |
INTERVAL |
INTERVAL |
JSON |
JSON |
JSONB |
JSON |
LINE |
UNSUPPORTED |
LSEG |
UNSUPPORTED |
MACADDR |
STRING |
MONEY |
DOUBLE |
NUMERIC |
|
OID |
LONG |
PATH |
UNSUPPORTED |
POINT |
UNSUPPORTED |
POLYGON |
UNSUPPORTED |
REAL |
FLOAT |
SMALLINT |
INTEGER |
SMALLSERIAL |
INTEGER |
SERIAL |
INTEGER |
TEXT |
STRING |
TIME |
TIME |
TIMESTAMP |
TIMESTAMP |
TIMESTAMP_WITH_TIMEZONE |
TIMESTAMP_WITH_TIMEZONE |
TIME_WITH_TIMEZONE |
TIME_WITH_TIMEZONE |
TSQUERY |
STRING |
TSVECTOR |
STRING |
TXID_SNAPSHOT |
STRING |
UUID |
STRING |
XML |
STRING |
SQL Server のデータ型を Datastream の統合型にマッピングする
SQL Server のデータ型 | Datastream の統合タイプ |
---|---|
BIGINT |
LONG |
BINARY |
BYTES |
BIT |
BOOLEAN |
CHAR |
STRING |
DATE |
DATE |
DATETIME2 |
DATETIME |
DATETIME |
DATETIME |
DATETIMEOFFSET |
TIMESTAMP WITH TIMEZONE |
DECIMAL |
DECIMAL (p, s) |
FLOAT |
DOUBLE |
HIERARCHYID |
STRING |
INT |
INTEGER |
IMAGE |
BYTES |
MONEY |
DECIMAL |
NCHAR |
STRING |
NVARCHAR |
STRING |
NVARCHAR(MAX) |
STRING |
NTEXT |
STRING |
NUMERIC |
DECIMAL (p, s) |
REAL |
FLOAT |
SMALLDATETIME |
DATETIME |
SMALLINT |
INTEGER |
SMALLMONEY |
DECIMAL |
TEXT |
STRING |
TINYINT |
INTEGER |
TIME |
TIME |
TIMESTAMP/ROWVERSION |
BYTES |
UNIQUEIDENTIFIER |
STRING |
VARCHAR |
STRING |
VARCHAR(MAX) |
STRING |
VARBINARY |
BYTES |
VARBINARY(MAX) |
BYTES |
XML |
STRING |