Términos
|
Término |
Descripción |
|
Project |
|
|
Topic |
Un topic es la unidad mínima para la suscripción y publicación de datos en DataHub. Utilice un topic para representar una clase o tipo de datos de streaming. |
|
Periodo de tiempo de vida (TTL) de un topic |
El periodo de tiempo de vida (TTL) de un topic especifica el periodo máximo de retención de los datos escritos en dicho topic. La unidad es el día. El valor oscila entre 1 y 7. |
|
Shard |
Un shard es un canal concurrente para la transmisión de datos dentro de un topic. Cada shard tiene un ID único. Un shard habilitado consume recursos del servidor. Cree los shards según sea necesario. Para obtener más información sobre los diferentes estados de un shard, consulte Shard states. |
|
Rango de clave hash del shard |
Propiedad de un shard que especifica el rango de valores de la clave hash. El intervalo es cerrado por la izquierda y abierto por la derecha. Los datos con la misma clave se escriben en el mismo shard. |
|
Fusión de shards |
La fusión de shards es una operación que combina shards con rangos de claves contiguos en un solo shard. Para obtener más información, consulte Shard operations. |
|
División de shards |
La división de shards es una operación que divide un shard en dos shards con rangos de claves contiguos. |
|
Record |
Unidad básica de interacción de datos entre los datos del usuario y DataHub. |
|
Tipo de record |
Tipo de datos de un topic. DataHub admite los tipos Tuple y BLOB.
Para obtener más información sobre los tipos de datos compatibles, consulte Data types. |
Tipos de datos
-
Tipo Tuple: Admite la escritura de datos de los siguientes tipos:
Los tipos de datos TINYINT, SMALLINT, INTEGER y FLOAT en DataHub son compatibles a partir de Java SDK V2.16.1-public.
Tipo
Descripción
Rango
BIGINT
Entero con signo de 8 bytes
-9223372036854775807 to 9223372036854775807DOUBLE
Número de punto flotante de doble precisión de 8 bytes
-1.0 × 10^308 to 1.0 × 10^308BOOLEAN
Tipo booleano
-
True/true/1
-
False/false/0
TIMESTAMP
Tipo de marca de tiempo
Marca de tiempo con precisión de microsegundos.
STRING
Cadena. Solo se admite la codificación UTF-8.
Una sola columna STRING puede tener un tamaño máximo de 2 MB.
TINYINT
Entero de un solo byte
-128 to 127SMALLINT
Entero de dos bytes
-32768 ~ 32767INTEGER
Entero de 4 bytes
-2147483648 to 2147483647FLOAT
Número de punto flotante de precisión sencilla de 4 bytes
-3.40292347 × 10^38 to 3.40292347 × 10^38DECIMAL
Tipo numérico
-10^38 + 1 to 10^38 - 1 -
En modo Blob, puede escribir un bloque de datos binarios como un record. Los datos se transmiten mediante codificación Base64.
Estados de los shards
|
Estado |
Descripción |
Compatibilidad de lectura/escritura |
|
Opening |
Cuando se crea un topic, todos sus shards se encuentran en estado Opening mientras se inicializan. |
No se admiten operaciones de lectura ni escritura. |
|
Active |
Después de abrirse un canal de shard, este entra en estado Active. |
Se admiten operaciones normales de lectura y escritura. |
|
Closing |
Un shard se encuentra en estado Closing cuando se somete a una operación de división o fusión. |
No se admiten operaciones de lectura ni escritura. |
|
Closed |
Una vez completada la operación de división o fusión, el shard entra en estado Closed. |
Solo lectura. |
Descripciones de errores
|
ErrorCode |
HttpCode |
Descripción |
|
InvalidUriSpec |
400 |
El URI solicitado no es válido. |
|
InvalidParameter |
400 |
Parámetro no válido. Para obtener más información, consulte el mensaje de error devuelto. |
|
Unauthorized |
401 |
Error de firma. |
|
NoPermission |
403 |
Permisos de cuenta insuficientes. |
|
InvalidSchema |
400 |
Formato de esquema no válido. |
|
InvalidCursor |
400 |
El cursor no es válido o ha caducado. |
|
NoSuchProject |
404 |
El project solicitado no existe. |
|
NoSuchTopic |
404 |
El topic solicitado no existe. |
|
NoSuchShard |
404 |
El ID de shard solicitado no existe. |
|
ProjectAlreadyExist |
400 |
El project ya existe. |
|
TopicAlreadyExist |
400 |
El topic ya existe. |
|
InvalidShardOperation |
405 |
Operación de shard no válida. Por ejemplo, escribir datos en un shard después de cerrarlo. |
|
LimitExceeded |
400 |
Los parámetros de la solicitud superan el límite. Por ejemplo, el número total de shards supera 512. |
|
InternalServerError |
500 |
Error desconocido, excepción interna del servicio o actualización del sistema en curso. |