Package org.apache.nifi.processors.standard

Class SampleRecord.RangeSamplingStrategy

java.lang.Object

org.apache.nifi.processors.standard.SampleRecord.RangeSamplingStrategy

All Implemented Interfaces:

SampleRecord.SamplingStrategy

Enclosing class:

SampleRecord

static class SampleRecord.RangeSamplingStrategy
extends Object
implements SampleRecord.SamplingStrategy

Field Summary

Fields

Modifier and Type	Field	Description
(package private) int	currentCount
(package private) final String	rangeExpression
(package private) final List<org.apache.commons.lang3.Range<Integer>>	ranges
(package private) final RecordSetWriter	writer

Constructor Summary

Constructors

Constructor	Description
RangeSamplingStrategy(RecordSetWriter writer, String rangeExpression)

Method Summary

Modifier and Type	Method	Description
WriteResult	finish()
void	init()
private boolean	isRangeExpressionInvalid()
void	sample(Record record)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

writer

final RecordSetWriter writer

rangeExpression

final String rangeExpression

currentCount

int currentCount

ranges

final List<org.apache.commons.lang3.Range<Integer>> ranges

Constructor Details

RangeSamplingStrategy

RangeSamplingStrategy(RecordSetWriter writer,
 String rangeExpression)

Method Details

isRangeExpressionInvalid

private boolean isRangeExpressionInvalid()

init

public void init()
          throws IOException

Specified by:

init in interface SampleRecord.SamplingStrategy

Throws:

IOException

sample

public void sample(Record record)
            throws IOException

Specified by:

sample in interface SampleRecord.SamplingStrategy

Throws:

IOException

finish

public WriteResult finish()
                   throws IOException

Specified by:

finish in interface SampleRecord.SamplingStrategy

Throws:

IOException