import kieker.common.record.IMonitoringRecord;
import kieker.common.record.misc.EmptyRecord;
@Plugin(description = "A file system reader which reads records from multiple directories", outputPorts = {
@OutputPort(name = BinaryLogReader.OUTPUT_PORT_NAME_RECORDS, eventTypes = {
IMonitoringRecord.class }, description = "Output Port of the reader") }, configuration = {
<BUG>@Property(name = BinaryLogReader.CONFIG_PROPERTY_NAME_INPUTDIRS, defaultValue = ".", description = "The name of the input dirs used to read data (multiple dirs are separated by |)."),
})</BUG>
public class BinaryLogReader extends AbstractReaderPlugin implements IMonitoringRecordReceiver {
public static final String OUTPUT_PORT_NAME_RECORDS = "monitoringRecords";
public static final String CONFIG_PROPERTY_NAME_INPUTDIRS = "inputDirs";

import kieker.common.record.IMonitoringRecord;
import kieker.common.record.misc.EmptyRecord;
@Plugin(description = "A file system reader which reads records from multiple directories", outputPorts = {
@OutputPort(name = BinaryLogReader.OUTPUT_PORT_NAME_RECORDS, eventTypes = {
IMonitoringRecord.class }, description = "Output Port of the reader") }, configuration = {
@Property(name = BinaryLogReader.CONFIG_PROPERTY_NAME_INPUTDIRS, defaultValue = ".", description = "The name of the input dirs used to read data (multiple dirs are separated by |).")
})
public class BinaryLogReader extends AbstractReaderPlugin implements IMonitoringRecordReceiver {
public static final String OUTPUT_PORT_NAME_RECORDS = "monitoringRecords";
public static final String CONFIG_PROPERTY_NAME_INPUTDIRS = "inputDirs";
