Skip to content
Snippets Groups Projects

Add generic database interface in UC1 to support different storage types

Merged Sören Henning requested to merge uc1-database-interface into master
4 files
+ 12
0
Compare changes
  • Side-by-side
  • Inline
Files
4
@@ -7,6 +7,8 @@ import titan.ccp.model.records.ActivePowerRecord;
/**
* {@link SimpleFunction} which wraps a {@link RecordConverter} to be used with Beam.
*
* @param <T> type the {@link RecordConverter} is associated with.
*/
public class ConverterAdapter<T> extends SimpleFunction<ActivePowerRecord, T> {
@@ -15,6 +17,10 @@ public class ConverterAdapter<T> extends SimpleFunction<ActivePowerRecord, T> {
private final RecordConverter<T> recordConverter;
private final TypeDescriptor<T> type;
/**
* Create a new {@link ConverterAdapter} with a given {@link RecordConverter} and the associated
* type.
*/
public ConverterAdapter(final RecordConverter<T> recordConverter, final Class<T> type) {
super();
this.recordConverter = recordConverter;
Loading