diff --git a/theodolite-benchmarks/uc1-beam/src/main/java/application/ConverterAdapter.java b/theodolite-benchmarks/uc1-beam/src/main/java/application/ConverterAdapter.java index 521a47afd0da1bb1e1bda5b85c68dfca39562529..e368c3a06cde50ea8d49d84b038fb2ec5aa97d1a 100644 --- a/theodolite-benchmarks/uc1-beam/src/main/java/application/ConverterAdapter.java +++ b/theodolite-benchmarks/uc1-beam/src/main/java/application/ConverterAdapter.java @@ -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; diff --git a/theodolite-benchmarks/uc1-beam/src/main/java/application/WriterAdapter.java b/theodolite-benchmarks/uc1-beam/src/main/java/application/WriterAdapter.java index 5fc9ed3e136395f73bd6c25a1b6751d73ba3f4bc..eb9a2670cd8e61ed103a277e9d26072dc926dbeb 100644 --- a/theodolite-benchmarks/uc1-beam/src/main/java/application/WriterAdapter.java +++ b/theodolite-benchmarks/uc1-beam/src/main/java/application/WriterAdapter.java @@ -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> { diff --git a/theodolite-benchmarks/uc1-flink/src/main/java/theodolite/uc1/application/ConverterAdapter.java b/theodolite-benchmarks/uc1-flink/src/main/java/theodolite/uc1/application/ConverterAdapter.java index d8b833169ed38dfd811b3d09b8e250d2774f40b0..af0a0b1cf5a25d22c1fdc5e7adb7467be03f9b9f 100644 --- a/theodolite-benchmarks/uc1-flink/src/main/java/theodolite/uc1/application/ConverterAdapter.java +++ b/theodolite-benchmarks/uc1-flink/src/main/java/theodolite/uc1/application/ConverterAdapter.java @@ -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> { diff --git a/theodolite-benchmarks/uc1-flink/src/main/java/theodolite/uc1/application/WriterAdapter.java b/theodolite-benchmarks/uc1-flink/src/main/java/theodolite/uc1/application/WriterAdapter.java index 7974fd19b05c508dc970e6bd5173b0e55c5df561..b2f375ec5f5a66141a2551015fb9fbd013ab9c16 100644 --- a/theodolite-benchmarks/uc1-flink/src/main/java/theodolite/uc1/application/WriterAdapter.java +++ b/theodolite-benchmarks/uc1-flink/src/main/java/theodolite/uc1/application/WriterAdapter.java @@ -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> {