Skip to content
Snippets Groups Projects
Commit cb8bd1ca authored by Sören Henning's avatar Sören Henning
Browse files

Fix checkstyle warnings

parent de672990
No related branches found
No related tags found
1 merge request!245Firestore sink for UC1 Beam
Pipeline #6591 passed
......@@ -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;
......
......@@ -6,6 +6,8 @@ import rocks.theodolite.benchmarks.uc1.commons.DatabaseWriter;
/**
* {@link DoFn} which wraps a {@link DatabaseAdapter} to be used with Beam.
*
* @param <T> type the {@link DatabaseWriter} is associated with.
*/
public class WriterAdapter<T> extends DoFn<T, Void> {
......
......@@ -6,6 +6,8 @@ import titan.ccp.model.records.ActivePowerRecord;
/**
* {@link MapFunction} which wraps a {@link RecordConverter} to be used with Flink.
*
* @param <T> type the {@link RecordConverter} is associated with.
*/
public class ConverterAdapter<T> implements MapFunction<ActivePowerRecord, T> {
......
......@@ -7,6 +7,8 @@ import rocks.theodolite.benchmarks.uc1.commons.DatabaseWriter;
/**
* {@link FlatMapFunction} which wraps a {@link DatabaseAdapter} to be used with Flink.
*
* @param <T> type the {@link DatabaseWriter} is associated with.
*/
public class WriterAdapter<T> implements FlatMapFunction<T, Void> {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment