Kafka·Flink中转换单位的Map表

kulphzqa  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(239)

我想了解Kafka或Flink中是否有类似于Map表的东西。
我有制片人,他们会得到数据。
我想有可能把这个数据转换成一个单位范围。
我拼命寻找一个“Map表”的经验,这将使能够检查生产者是否得到一个特定单位的具体数据,并转换如果是这样的情况。
我想有一些嵌入式的灵活性,以便在事后React,并在将来需要时进行更改。
我一直在寻找一个微型机器人,这是有趣的,但作为与此无关,或任何可以帮助。如果有人对此有看法,我会很高兴。
让我们提供一个典型sql示例的摘录。在这个例子中,我有一个“度量单位”表,它使我能够快速地做事情,所以无论我有什么单位,我都可以转换它并快速地更改它。

create table unit_unit_conv(
   from_unit varchar(10)   not null
  ,to_unit   varchar(10)   not null
  ,rate      decimal(10,6) not null
  ,primary key(from_unit, to_unit)
);

insert into unit_unit_conv values('kilogram', 'kilogram',   1);
insert into unit_unit_conv values('kilogram', 'gram',       1000);
insert into unit_unit_conv values('kilogram', 'box',        0.2);
insert into unit_unit_conv values('gram',     'gram',       1);
insert into unit_unit_conv values('gram',     'kilogram',   0.001);
insert into unit_unit_conv values('gram',     'box',        0.0002);
insert into unit_unit_conv values('box',      'box',        1);
insert into unit_unit_conv values('box',      'kilogram',   5);
insert into unit_unit_conv values('box',      'gram',       5000);

我真的很高兴在Kafka找到同样的东西,一个“大师制作人”在某种程度上检查其他人,检查他们的单位,并通过参考他“自己的”固定知识进行转换。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题