org.graylog.plugins.netflow.codecs.NetflowV9CodecAggregator.PacketByteBuf to org.graylog.plugins.netflow.codecs.NetflowV9CodecAggregator.PacketBytes
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'graylog2-server'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
- CacheBuilder.newBuilder().expireAfterWrite(1,TimeUnit.MINUTES).maximumWeight(Size.megabytes(1).toBytes()).<Object,Queue<PacketByteBuf>>weigher((key,value) -> value.stream().map(PacketByteBuf::readableBytes).reduce(0,Integer::sum)).recordStats().build() to CacheBuilder.newBuilder().expireAfterWrite(1,TimeUnit.MINUTES).maximumWeight(Size.megabytes(1).toBytes()).removalListener((RemovalListener<TemplateKey,Queue<PacketBytes>>)notification -> LOG.debug("Removed {} from packet cache for reason {}",notification.getKey(),notification.getCause())).weigher((key,value) -> value.stream().map(PacketBytes::readableBytes).reduce(0,Integer::sum)).recordStats().build()