El conector Blackhole funciona de manera similar a /dev/null en Unix: acepta todos los registros de entrada y los descarta sin generar notificaciones. Utilícelo para determinar si un problema en su trabajo de Flink SQL se origina en la configuración del sink o en la lógica de procesamiento anterior.
El conector Blackhole es compatible tanto con el modo por lotes como con el modo streaming, y admite actualizaciones y eliminaciones de datos en la tabla sink.
Casos de uso
Aislar errores de configuración del sink: Si una tabla sink que utiliza otro tipo de conector genera un error y no tiene certeza de si la causa es un problema del sistema o un parámetro no válido en la cláusula WITH, cambie
connectorablackholey haga clic en Validate en la esquina superior derecha de la pestaña Drafts. Si no aparece ningún error, el sistema funciona correctamente; revise los parámetros originales de su cláusula WITH.Medir la sobrecarga de rendimiento: Ejecute un despliegue en estado Running con un sink Blackhole para comprobar si se consume rendimiento al insertar datos en una tabla, sin la sobrecarga de un sistema externo real.
Validar la salida de UDF: Dirija la salida de funciones definidas por el usuario (UDF) a una tabla sink Blackhole para inspeccionar los datos sin escribir en una tabla física.
Capacidades
|
Item |
Description |
|
Tipo de tabla |
Tabla sink |
|
Modo de ejecución |
Por lotes y streaming |
|
Formato de datos |
N/A |
|
Métrica |
N/A |
|
Tipo de API |
API SQL |
|
Actualización o eliminación de datos en una tabla sink |
Compatible |
Limitaciones
Es obligatorio Realtime Compute for Apache Flink con Ververica Runtime (VVR) 2.0.0 o posterior.
Crear una tabla sink Blackhole
Defina la tabla sink con 'connector' = 'blackhole':
CREATE TABLE blackhole_sink(
name VARCHAR,
score BIGINT
) WITH (
'connector' = 'blackhole'
);Para crear una tabla sink Blackhole a partir de la definición de una tabla fuente existente, utilice la cláusula LIKE:
CREATE TABLE blackhole_sink WITH ('connector' = 'blackhole')
LIKE table_source (EXCLUDING ALL);Opciones del conector
|
Option |
Required |
Default |
Type |
Description |
|
|
Sí |
Ninguna |
STRING |
El tipo de conector. Establezca este valor en |
Ejemplo
A continuación se muestra un ejemplo que lee desde una tabla fuente y escribe todos los registros en un sink Blackhole:
CREATE TEMPORARY TABLE table_source(
name VARCHAR,
score BIGINT
) WITH (
...
);
CREATE TEMPORARY TABLE blackhole_sink(
name VARCHAR,
score BIGINT
) WITH (
'connector' = 'blackhole'
);
INSERT INTO blackhole_sink SELECT * FROM table_source;