Skip to content
Snippets Groups Projects

Migrate Beam benchmark implementation

Compare and Show latest version
19 files
+ 314
204
Compare changes
  • Side-by-side
  • Inline
Files
19
@@ -14,9 +14,15 @@ public class AbstractPipeline extends Pipeline {
// Application Configurations
private final Configuration config;
protected final String inputTopic;
protected final String bootstrapServer;
protected AbstractPipeline(final PipelineOptions options, final Configuration config) {
super(options);
this.config = config;
inputTopic = config.getString(ConfigurationKeys.KAFKA_INPUT_TOPIC);
bootstrapServer = config.getString(ConfigurationKeys.KAFKA_BOOTSTRAP_SERVERS);
}
/**
Loading