Package org.apache.storm.kafka.spout

Interface Func<V,R>

All Superinterfaces:

Serializable

All Known Subinterfaces:

RecordTranslator<K,V>

All Known Implementing Classes:

ByTopicRecordTranslator, DefaultRecordTranslator, OnlyValueRecordTranslator, RecordTranslatorSchemeAdapter, SimpleRecordTranslator

public interface Func<V,R>
extends Serializable

A simple interface to allow compatibility with non java 8 code bases.

Method Summary

Modifier and Type	Method	Description
R	apply(V record)

Method Detail

apply

R apply(V record)