| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public List<TDeviceIngestRecord> selectSamplesOfSource(String adapterCode, int devtype, int devid, int subdevid, |
|---|
| | | int chlid, String sourceRef) |
|---|
| | | { |
|---|
| | | return samples(adapterCode, devtype, devid, subdevid, chlid).stream() |
|---|
| | | .filter(row -> sourceRef.equals(row.getSourceRef())) |
|---|
| | | .sorted(java.util.Comparator.comparing(TDeviceIngestRecord::getDeviceTimeUtc) |
|---|
| | | .thenComparing(TDeviceIngestRecord::getRecordSequence)) |
|---|
| | | .toList(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public List<TDeviceIngestRecord> selectSamplesSince(String adapterCode, int devtype, int devid, int subdevid, |
|---|
| | | int chlid, Date watermarkTime, long watermarkSequence, int limit) |
|---|
| | | { |
|---|
