public final class PartitionDataReaderFilter extends Object implements DataReaderFilter
Constructor and Description |
---|
PartitionDataReaderFilter(DataPartitioning dataPartitioning,
int partitionCount,
String partitionColumn)
Initializes a new instance of the
PartitionDataReaderFilter class. |
Modifier and Type | Method and Description |
---|---|
boolean |
include(DataRecord record)
Determines whether a record should be included or not.
|
public PartitionDataReaderFilter(DataPartitioning dataPartitioning, int partitionCount, String partitionColumn)
PartitionDataReaderFilter
class.dataPartitioning
- The partitioning to use to filter the data.partitionCount
- The total number of partitions.partitionColumn
- The name of the column containing ids or a zero based partition identifier.public boolean include(DataRecord record)
include
in interface DataReaderFilter
record
- The current record to include or exclude.true
if the record should be included, false
if the recorded should be excluded.Copyright © 2021. All rights reserved.